Package 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, XMPPConnection

Direct Known Subclasses:

XmppConnection

public class JabberConnection
extends XMPPTCPConnection
implements AutoCloseable

Author:

jerrickpua

Nested Class Summary

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

XMPPTCPConnection.PacketReader, XMPPTCPConnection.PacketWriter

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

AbstractXMPPConnection.InterceptorWrapper, AbstractXMPPConnection.ListenerWrapper

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

XMPPConnection.FromMode

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_CONNECTION_TIMEOUT
static final int	DEFAULT_PACKET_REPLY_TIMEOUT
static final 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	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, XMPPTCPConnectionConfiguration config, boolean allowReconnection, long pingInterval)

Method Summary

Modifier and Type	Method	Description
void	addChatListener(ChatManagerListener listener)
static 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<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, String message)
void	sendMessage(String jid, Message 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 Details

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 Details

JabberConnection

public JabberConnection(String name,
 Map configuration)

JabberConnection

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

JabberConnection

public JabberConnection(String name,
 XMPPTCPConnectionConfiguration config,
 boolean allowReconnection,
 long pingInterval)

JabberConnection

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

Method Details

buildConfiguration

public static 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. 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:

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<String> } - See ConnectionConfiguration.Builder.setEnabledSSLCiphers(String[])
• { enabledSSLProtocols, Type: String or List<String> } - 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

name - Jabber connection name

connect

public JabberConnection connect()
                         throws SmackException,
IOException,
XMPPException

Overrides:

connect in class AbstractXMPPConnection

Throws:

SmackException

IOException

XMPPException

connectInternal

protected void connectInternal()
                        throws SmackException,
IOException,
XMPPException

Overrides:

connectInternal in class XMPPTCPConnection

Throws:

SmackException

IOException

XMPPException

login

public void login()
           throws XMPPException,
SmackException,
IOException

Overrides:

login in class AbstractXMPPConnection

Throws:

XMPPException

SmackException

IOException

login

public void login(CharSequence username,
 String password)
           throws XMPPException,
SmackException,
IOException

Overrides:

login in class AbstractXMPPConnection

Throws:

XMPPException

SmackException

IOException

login

public void login(CharSequence username,
 String password,
 String resource)
           throws XMPPException,
SmackException,
IOException

Overrides:

login in class AbstractXMPPConnection

Throws:

XMPPException

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<RosterEntry> getUsers()

sendMessage

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

Throws:

SmackException.NotConnectedException

sendMessage

public void sendMessage(String jid,
 Message message)
                 throws SmackException.NotConnectedException

Throws:

SmackException.NotConnectedException

addChatListener

public void addChatListener(ChatManagerListener listener)

disconnect

public void disconnect()

Overrides:

disconnect in class AbstractXMPPConnection

instantShutdown

public void instantShutdown()

Overrides:

instantShutdown in class XMPPTCPConnection

close

public void close()

Specified by:

close in interface AutoCloseable