Package tigase.server.xmppclient
Class C2SIOService<RefObject>
java.lang.Object
tigase.net.IOService<RefObject>
tigase.xmpp.XMPPIOService<RefObject>
tigase.server.xmppclient.C2SIOService<RefObject>
- All Implemented Interfaces:
Callable<IOService<?>>,TLSEventHandler,IOListener
-
Field Summary
Fields inherited from class tigase.xmpp.XMPPIOService
ACK_NAME, CROSS_DOMAIN_POLICY_FILE_PROP_KEY, CROSS_DOMAIN_POLICY_FILE_PROP_VAL, DOM_HANDLER, ID_ATT, parser, processors, REQ_NAME, serviceListener, STREAM_CLOSING, writeInProgressFields inherited from class tigase.net.IOService
cb, CERT_CHECK_RESULT, CERT_REQUIRED_DOMAIN, decoder, encoder, HOSTNAME_KEY, LOCAL_CERT_CHECK_RESULT, partialCharacterBytes, PORT_TYPE_PROP_KEY, SESSION_ID_KEY, SSL_PROTOCOLS_KEY -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidaddReceivedPacket(Packet packet) MethodaddReceivedPacketputs processing results to queue.protected booleanhandleMalformedInput(ByteBuffer buffer, CharBuffer cb) booleanvoidvoidbooleanvoidstartTLS(boolean clientMode, boolean wantClientAuth, boolean needClientAuth) voidbooleanMethods inherited from class tigase.xmpp.XMPPIOService
addPacketToSend, call, checkBufferLimit, checkData, clearWaitingPackets, forceStop, getAuthorisedUserJid, getLastXmppPacketReceiveTime, getPacketsReceived, getPacketsSent, getReceivedPackets, getTotalPacketsReceived, getTotalPacketsSent, getUserJid, getWaitingForAct, getWaitingPackets, getXMLNS, hasParsedElements, moveParsedPacketsToReceived, prepareStreamClose, processSocketData, receivedPackets, setAckMode, setAuthorisedUserJid, setElementLimits, setIOServiceListener, setProcessors, setUserJid, setXMLNS, shouldCountPacket, stop, toString, writeRawData, xmppStreamClosed, xmppStreamOpen, xmppStreamOpenedMethods inherited from class tigase.net.IOService
accept, accept, byteOrder, connectionType, debug, debug, getBuffOverflow, getBytesReceived, getBytesSent, getCertificateContainer, getConnectionId, getDataReceiver, getIO, getLastTransferTime, getLocalAddress, getLocalCertificate, getLocalPort, getPeerCertificate, getReadCounters, getRefObject, getRemoteAddress, getSessionData, getSocketChannel, getSocketInputSize, getStatistics, getTlsExporter, getTlsUniqueId, getTotalBuffOverflow, getTotalBytesReceived, getTotalBytesSent, getUniqueId, getWriteCounters, handshakeCompleted, isConnected, isInputBufferEmpty, isSocketServiceReady, readBytes, readCompleted, readData, setBufferLimit, setCertificateContainer, setConnectionId, setDataReceiver, setIOServiceListener, setRefObject, setSessionData, setSocketServiceReady, setSslContextContainer, setX509TrustManagers, startSSL, startZLib, waitingToSend, waitingToSendSize, writeBytes, writeData
-
Constructor Details
-
C2SIOService
public C2SIOService()
-
-
Method Details
-
addReceivedPacket
Description copied from class:XMPPIOServiceMethodaddReceivedPacketputs processing results to queue. The processing results are usually data (messages) which has been just received from socket.- Overrides:
addReceivedPacketin classXMPPIOService<RefObject>- Parameters:
packet- aPacketvalue of processing results.
-
waitingToRead
public boolean waitingToRead()- Overrides:
waitingToReadin classIOService<RefObject>
-
processWaitingPackets
- Overrides:
processWaitingPacketsin classXMPPIOService<RefObject>- Throws:
IOException
-
waitForResponse
public void waitForResponse() -
isWaitingForResponse
public boolean isWaitingForResponse() -
queueTask
-
shouldQueueStreamOpened
public boolean shouldQueueStreamOpened() -
handleMalformedInput
- Overrides:
handleMalformedInputin classIOService<RefObject>
-
startTLS
public void startTLS(boolean clientMode, boolean wantClientAuth, boolean needClientAuth) throws IOException - Overrides:
startTLSin classIOService<RefObject>- Throws:
IOException
-