io.toro.martini.jabber.model

Class JabberConnection

java.lang.Object

org.jivesoftware.smack.AbstractXMPPConnection

org.jivesoftware.smack.tcp.XMPPTCPConnection

io.toro.martini.jabber.model.JabberConnection

All Implemented Interfaces:

AutoCloseable, org.jivesoftware.smack.XMPPConnection

public class JabberConnection
extends org.jivesoftware.smack.tcp.XMPPTCPConnection
implements AutoCloseable

Author:

jerrickpua

Nested Class Summary

Nested classes/interfaces inherited from class org.jivesoftware.smack.tcp.XMPPTCPConnection

org.jivesoftware.smack.tcp.XMPPTCPConnection.PacketReader, org.jivesoftware.smack.tcp.XMPPTCPConnection.PacketWriter

Nested classes/interfaces inherited from class org.jivesoftware.smack.AbstractXMPPConnection

org.jivesoftware.smack.AbstractXMPPConnection.InterceptorWrapper, org.jivesoftware.smack.AbstractXMPPConnection.ListenerWrapper

Nested classes/interfaces inherited from interface org.jivesoftware.smack.XMPPConnection

org.jivesoftware.smack.XMPPConnection.FromMode

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_CONNECTION_TIMEOUT
static int	DEFAULT_PACKET_REPLY_TIMEOUT
static int	DEFAULT_PING_INTERVAL

Fields inherited from class org.jivesoftware.smack.tcp.XMPPTCPConnection

packetReader, packetWriter

Fields inherited from class org.jivesoftware.smack.AbstractXMPPConnection

authenticated, compressionHandler, connected, connectionCounterValue, connectionListeners, connectionLock, debugger, host, hostAddresses, lastFeaturesReceived, port, reader, saslAuthentication, saslFeatureReceived, streamFeatures, streamId, user, wasAuthenticated, writer

Constructor Summary

Constructors

Constructor and Description
JabberConnection(String name, CharSequence jid, String password, boolean allowReconnection, Integer pingInterval)
JabberConnection(String name, CharSequence username, String password, String serviceName, boolean allowReconnection, Integer pingInterval)
JabberConnection(String name, Map configuration)
JabberConnection(String name, org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration config, boolean allowReconnection, long pingInterval)

Method Summary

Modifier and Type	Method and Description
void	addChatListener(org.jivesoftware.smack.chat.ChatManagerListener listener)
static org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration	buildConfiguration(Map configuration) Creates a jabber based on the configuration map provided Properties for configuring jabber connection NOTE THIS IS FOR ENDPOINT ONLY { Key: replyServiceResponse, Type: Boolean } - Set to true if service response will return its object to the sender.
void	close()
JabberConnection	connect()
protected void	connectInternal()
void	disconnect()
String	getName()
Integer	getPingInterval()
Set<org.jivesoftware.smack.roster.RosterEntry>	getUsers()
void	instantShutdown()
boolean	isAllowReconnection()
void	login()
void	login(CharSequence username, String password)
void	login(CharSequence username, String password, String resource)
void	sendMessage(String jid, org.jivesoftware.smack.packet.Message message)
void	sendMessage(String jid, String message)
void	setName(io.toro.martini.endpoint.Endpoint endpoint)
void	setName(String name)

Methods inherited from class org.jivesoftware.smack.tcp.XMPPTCPConnection

addRequestAckPredicate, addStanzaAcknowledgedListener, addStanzaIdAcknowledgedListener, afterFeaturesReceived, afterSuccessfulLogin, getMaxSmResumptionTime, isDisconnectedButSmResumptionPossible, isSecureConnection, isSmAvailable, isSmEnabled, isSmResumptionPossible, isSocketClosed, isUsingCompression, loginAnonymously, loginNonAnonymously, removeAllRequestAckPredicates, removeAllStanzaAcknowledgedListeners, removeAllStanzaIdAcknowledgedListeners, removeRequestAckPredicate, removeStanzaAcknowledgedListener, removeStanzaIdAcknowledgedListener, requestSmAcknowledgement, send, sendSmAcknowledgement, sendStanzaInternal, setBundleandDeferCallback, setDefaultBundleAndDeferCallback, setPreferredResumptionTime, setUseStreamManagement, setUseStreamManagementDefault, setUseStreamManagementResumptiodDefault, setUseStreamManagementResumption, setUseStreamManagementResumptionDefault, setWriter, shutdown, streamWasResumed, throwAlreadyConnectedExceptionIfAppropriate, throwAlreadyLoggedInExceptionIfAppropriate, throwNotConnectedExceptionIfAppropriate

Methods inherited from class org.jivesoftware.smack.AbstractXMPPConnection

addAsyncStanzaListener, addConnectionListener, addOneTimeSyncCallback, addPacketInterceptor, addPacketListener, addPacketSendingListener, addSyncStanzaListener, asyncGo, bindResourceAndEstablishSession, callConnectionAuthenticatedListener, callConnectionClosedOnErrorListener, callConnectionConnectedListener, createPacketCollector, createPacketCollector, createPacketCollectorAndSend, createPacketCollectorAndSend, disconnect, finalize, firePacketSendingListeners, getConfiguration, getConnectionCounter, getConnectionCreationListeners, getConnectionLock, getFeature, getFromMode, getHost, getLastStanzaReceived, getPacketReplyTimeout, getParsingExceptionCallback, getPort, getSASLAuthentication, getServiceName, getStreamId, getUser, hasFeature, initDebugger, invokePacketCollectorsAndNotifyRecvListeners, isAnonymous, isAuthenticated, isConnected, notifyReconnection, parseAndProcessStanza, parseFeatures, populateHostAddresses, processPacket, registerIQRequestHandler, removeAsyncStanzaListener, removeConnectionListener, removePacketCollector, removePacketInterceptor, removePacketListener, removePacketSendingListener, removeSyncStanzaListener, schedule, sendIqWithResponseCallback, sendIqWithResponseCallback, sendIqWithResponseCallback, sendPacket, sendStanza, sendStanzaWithResponseCallback, sendStanzaWithResponseCallback, sendStanzaWithResponseCallback, setFromMode, setPacketReplyTimeout, setParsingExceptionCallback, setReplyToUnknownIq, setReplyToUnknownIqDefault, setWasAuthenticated, throwNotConnectedExceptionIfAppropriate, unregisterIQRequestHandler, unregisterIQRequestHandler

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_PING_INTERVAL

public static final int DEFAULT_PING_INTERVAL

See Also:

Constant Field Values

DEFAULT_CONNECTION_TIMEOUT

public static final int DEFAULT_CONNECTION_TIMEOUT

See Also:

Constant Field Values

DEFAULT_PACKET_REPLY_TIMEOUT

public static final int DEFAULT_PACKET_REPLY_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

JabberConnection

public JabberConnection(String name,
                        Map configuration)
                 throws ToroException

Throws:

ToroException

JabberConnection

public JabberConnection(String name,
                        CharSequence username,
                        String password,
                        String serviceName,
                        boolean allowReconnection,
                        Integer pingInterval)

JabberConnection

public JabberConnection(String name,
                        org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration config,
                        boolean allowReconnection,
                        long pingInterval)

JabberConnection

public JabberConnection(String name,
                        CharSequence jid,
                        String password,
                        boolean allowReconnection,
                        Integer pingInterval)

Method Detail

buildConfiguration

public static org.jivesoftware.smack.tcp.XMPPTCPConnectionConfiguration buildConfiguration(Map configuration)
                                                                                    throws ToroException

Creates a jabber based on the configuration map provided Properties for configuring jabber connection NOTE THIS IS FOR ENDPOINT ONLY

• { Key: replyServiceResponse, Type: Boolean } - Set to true if service response will return its object to the sender. Only String and Gstring will be returned. if you want to return marshalled object make sure to set useObjectConverter configuration to true
• { Key: useObjectConverter, Type: Boolean } - If service response is set to true. Objects will return as json

Parameters:

name - Jabber connection name

configuration -

• { Key: callbackHandler, Type: CallbackHandler } - See ConnectionConfiguration.Builder#setCallbackHandler(CallbackHandler)
• { compressionEnabled, Type: Boolean } - See XMPPTCPConnectionConfiguration.Builder#setCompressionEnabled(boolean)
• { connectTimeout, Type: Integer DEFAULT 50seconds } - See XMPPTCPConnectionConfiguration.Builder#setConnectTimeout(int)
• { sslContext, Type: SSLContext } - See ConnectionConfiguration.Builder#setCustomSSLContext(SSLContext)
• { debuggerEnabled, Type: Boolean } - See ConnectionConfiguration.Builder#setDebuggerEnabled(boolean)
• { enabledSSLCiphers, Type: String[] or List } - See ConnectionConfiguration.Builder#setEnabledSSLCiphers(String[])
• { enabledSSLProtocols, Type: String[] or List } - See ConnectionConfiguration.Builder#setEnabledSSLProtocols(String[])
• { host, Type: String } - See ConnectionConfiguration.Builder#setHost(String)
• { hostnameVerifier, Type: HostnameVerifier } - See ConnectionConfiguration.Builder#setHostnameVerifier(HostnameVerifier)
• { keystorePath, Type: String } - See ConnectionConfiguration.Builder#setKeystorePath(String)
• { keystoreType, Type: String } - See ConnectionConfiguration.Builder#setKeystoreType(String)
• { legacySessionDisabled, Type: Boolean } - See ConnectionConfiguration.Builder#setLegacySessionDisabled(boolean)
• { pkcs11Library, Type: String } - See ConnectionConfiguration.Builder#setPKCS11Library(String)
• { port, Type: Integer } - See ConnectionConfiguration.Builder#setPort(int)
• { proxyInfo, Type: ProxyInfo } - See ConnectionConfiguration.Builder#setProxyInfo(ProxyInfo)
• { resource, Type: String } - See ConnectionConfiguration.Builder#setResource(String)
• { securityMode, Type: ConnectionConfiguration.SecurityMode or String } - See ConnectionConfiguration.Builder#setSecurityMode(SecurityMode)
• { sendPresence, Type: Boolean } - See ConnectionConfiguration.Builder#setSendPresence(boolean)
• { serviceName, Type: String } - See ConnectionConfiguration.Builder#setServiceName(String)
• { socketFactory, Type: SocketFactory } - See ConnectionConfiguration.Builder#setSocketFactory(SocketFactory)
• { username, Type: String } - Username of your jabber account
• { password, Type: Boolean } - password of jabber account
• { packetReplyTimeout, Type: Long DEFAULT 10seconds } - See AbstractXMPPConnection.setPacketReplyTimeout(long)
• { pingInterval, Type: Integer DEFAULT 20seconds } - See PingManager.setPingInterval(int)
• { allowEmptyOrNullUsernames, Type: Boolean } - See ConnectionConfiguration.Builder#allowEmptyOrNullUsernames()
• { allowReconnection, Type: Boolean DEFAULT: true } - Enables ReconnectionManager

Throws:

ToroException

connect

public JabberConnection connect()
                         throws org.jivesoftware.smack.SmackException,
                                IOException,
                                org.jivesoftware.smack.XMPPException

Overrides:

connect in class org.jivesoftware.smack.AbstractXMPPConnection

Throws:

org.jivesoftware.smack.SmackException

IOException

org.jivesoftware.smack.XMPPException

connectInternal

protected void connectInternal()
                        throws org.jivesoftware.smack.SmackException,
                               IOException,
                               org.jivesoftware.smack.XMPPException

Overrides:

connectInternal in class org.jivesoftware.smack.tcp.XMPPTCPConnection

Throws:

org.jivesoftware.smack.SmackException

IOException

org.jivesoftware.smack.XMPPException

login

public void login()
           throws org.jivesoftware.smack.XMPPException,
                  org.jivesoftware.smack.SmackException,
                  IOException

Overrides:

login in class org.jivesoftware.smack.AbstractXMPPConnection

Throws:

org.jivesoftware.smack.XMPPException

org.jivesoftware.smack.SmackException

IOException

login

public void login(CharSequence username,
                  String password)
           throws org.jivesoftware.smack.XMPPException,
                  org.jivesoftware.smack.SmackException,
                  IOException

Overrides:

login in class org.jivesoftware.smack.AbstractXMPPConnection

Throws:

org.jivesoftware.smack.XMPPException

org.jivesoftware.smack.SmackException

IOException

login

public void login(CharSequence username,
                  String password,
                  String resource)
           throws org.jivesoftware.smack.XMPPException,
                  org.jivesoftware.smack.SmackException,
                  IOException

Overrides:

login in class org.jivesoftware.smack.AbstractXMPPConnection

Throws:

org.jivesoftware.smack.XMPPException

org.jivesoftware.smack.SmackException

IOException

getName

public String getName()

setName

public void setName(io.toro.martini.endpoint.Endpoint endpoint)

setName

public void setName(String name)

isAllowReconnection

public boolean isAllowReconnection()

getPingInterval

public Integer getPingInterval()

getUsers

public Set<org.jivesoftware.smack.roster.RosterEntry> getUsers()

sendMessage

public void sendMessage(String jid,
                        String message)
                 throws org.jivesoftware.smack.SmackException.NotConnectedException

Throws:

org.jivesoftware.smack.SmackException.NotConnectedException

sendMessage

public void sendMessage(String jid,
                        org.jivesoftware.smack.packet.Message message)
                 throws org.jivesoftware.smack.SmackException.NotConnectedException

Throws:

org.jivesoftware.smack.SmackException.NotConnectedException

addChatListener

public void addChatListener(org.jivesoftware.smack.chat.ChatManagerListener listener)

disconnect

public void disconnect()

Overrides:

disconnect in class org.jivesoftware.smack.AbstractXMPPConnection

instantShutdown

public void instantShutdown()

Overrides:

instantShutdown in class org.jivesoftware.smack.tcp.XMPPTCPConnection

close

public void close()

Specified by:

close in interface AutoCloseable