Package org.jivesoftware.smack.c2s.internal

Class ModularXmppClientToServerConnectionInternal

java.lang.Object

org.jivesoftware.smack.c2s.internal.ModularXmppClientToServerConnectionInternal

public abstract class ModularXmppClientToServerConnectionInternal
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
final ModularXmppClientToServerConnection	connection
final Queue<TopLevelStreamElement>	outgoingElementsQueue
final SmackDebugger	smackDebugger

Constructor Summary

Constructors

Constructor	Description
ModularXmppClientToServerConnectionInternal(ModularXmppClientToServerConnection connection, SmackReactor reactor, SmackDebugger smackDebugger, Queue<TopLevelStreamElement> outgoingElementsQueue)

Method Summary

Modifier and Type	Method	Description
abstract void	addXmppInputOutputFilter(XmppInputOutputFilter xmppInputOutputFilter)
abstract void	asyncGo(Runnable runnable)
abstract void	fireFirstLevelElementSendListeners(TopLevelStreamElement element)
abstract XmlEnvironment	getOutgoingStreamXmlEnvironment()
abstract SmackTlsContext	getSmackTlsContext()
abstract ListIterator<XmppInputOutputFilter>	getXmppInputOutputFilterBeginIterator()
abstract ListIterator<XmppInputOutputFilter>	getXmppInputOutputFilterEndIterator()
abstract void	invokeConnectionStateMachineListener(ConnectionStateEvent connectionStateEvent)
abstract void	newStreamOpenWaitForFeaturesSequence(String waitFor)
abstract void	notifyConnectionError(Exception e)
abstract void	notifyWaitingThreads()
abstract void	onStreamClosed()
final String	onStreamOpen(String streamOpen)
abstract String	onStreamOpen(XmlPullParser parser)
abstract void	parseAndProcessElement(String wrappedCompleteIncomingElement)
SelectionKey	registerWithSelector(SelectableChannel channel, int ops, SmackReactor.ChannelSelectedCallback callback)
abstract <SN extends Nonza, FN extends Nonza> SN	sendAndWaitForResponse(Nonza nonza, Class<SN> successNonzaClass, Class<FN> failedNonzaClass)
abstract void	setCompressionEnabled(boolean compressionEnabled)
void	setInterestOps(SelectionKey selectionKey, int interestOps)
abstract void	setTransport(XmppClientToServerTransport xmppTransport)	Set the active transport (TCP, BOSH, WebSocket, …) to be used for the XMPP connection.
abstract void	waitForConditionOrThrowConnectionException(Supplier<Boolean> condition, String waitFor)
abstract void	waitForFeaturesReceived(String waitFor)
final void	withSmackDebugger(Consumer<SmackDebugger> smackDebuggerConsumer)

Methods inherited from class java.lang.Object

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

Field Details

connection

public final ModularXmppClientToServerConnection connection

smackDebugger

public final SmackDebugger smackDebugger

outgoingElementsQueue

public final Queue<TopLevelStreamElement> outgoingElementsQueue

Constructor Details

ModularXmppClientToServerConnectionInternal

public ModularXmppClientToServerConnectionInternal(ModularXmppClientToServerConnection connection,
 SmackReactor reactor,
 SmackDebugger smackDebugger,
 Queue<TopLevelStreamElement> outgoingElementsQueue)

Method Details

registerWithSelector

public SelectionKey registerWithSelector(SelectableChannel channel,
 int ops,
 SmackReactor.ChannelSelectedCallback callback)
                                  throws ClosedChannelException

Throws:

ClosedChannelException

setInterestOps

public void setInterestOps(SelectionKey selectionKey,
 int interestOps)

withSmackDebugger

public final void withSmackDebugger(Consumer<SmackDebugger> smackDebuggerConsumer)

getOutgoingStreamXmlEnvironment

public abstract XmlEnvironment getOutgoingStreamXmlEnvironment()

parseAndProcessElement

public abstract void parseAndProcessElement(String wrappedCompleteIncomingElement)

notifyConnectionError

public abstract void notifyConnectionError(Exception e)

onStreamOpen

public final String onStreamOpen(String streamOpen)

onStreamOpen

public abstract String onStreamOpen(XmlPullParser parser)

onStreamClosed

public abstract void onStreamClosed()

fireFirstLevelElementSendListeners

public abstract void fireFirstLevelElementSendListeners(TopLevelStreamElement element)

invokeConnectionStateMachineListener

public abstract void invokeConnectionStateMachineListener(ConnectionStateEvent connectionStateEvent)

addXmppInputOutputFilter

public abstract void addXmppInputOutputFilter(XmppInputOutputFilter xmppInputOutputFilter)

getXmppInputOutputFilterBeginIterator

public abstract ListIterator<XmppInputOutputFilter> getXmppInputOutputFilterBeginIterator()

getXmppInputOutputFilterEndIterator

public abstract ListIterator<XmppInputOutputFilter> getXmppInputOutputFilterEndIterator()

waitForFeaturesReceived

public abstract void waitForFeaturesReceived(String waitFor)
                                      throws InterruptedException,
SmackException,
XMPPException

Throws:

InterruptedException

SmackException

XMPPException

newStreamOpenWaitForFeaturesSequence

public abstract void newStreamOpenWaitForFeaturesSequence(String waitFor)
                                                   throws InterruptedException,
SmackException.NoResponseException,
SmackException.NotConnectedException,
SmackException,
XMPPException

Throws:

InterruptedException

SmackException.NoResponseException

SmackException.NotConnectedException

SmackException

XMPPException

getSmackTlsContext

public abstract SmackTlsContext getSmackTlsContext()

sendAndWaitForResponse

public abstract <SN extends Nonza,
FN extends Nonza>
SN sendAndWaitForResponse(Nonza nonza,
 Class<SN> successNonzaClass,
 Class<FN> failedNonzaClass)
                   throws SmackException.NoResponseException,
SmackException.NotConnectedException,
XMPPException.FailedNonzaException,
InterruptedException

Throws:

SmackException.NoResponseException

SmackException.NotConnectedException

XMPPException.FailedNonzaException

InterruptedException

asyncGo

public abstract void asyncGo(Runnable runnable)

waitForConditionOrThrowConnectionException

public abstract void waitForConditionOrThrowConnectionException(Supplier<Boolean> condition,
 String waitFor)
                                                         throws InterruptedException,
SmackException.SmackWrappedException,
SmackException.NoResponseException

Throws:

InterruptedException

SmackException.SmackWrappedException

SmackException.NoResponseException

notifyWaitingThreads

public abstract void notifyWaitingThreads()

setCompressionEnabled

public abstract void setCompressionEnabled(boolean compressionEnabled)

setTransport

public abstract void setTransport(XmppClientToServerTransport xmppTransport)

Set the active transport (TCP, BOSH, WebSocket, …) to be used for the XMPP connection. Also marks the connection as connected.

Parameters:

xmppTransport - the active transport.