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, writeInProgress
Fields 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
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
addReceivedPacket
(Packet packet) MethodaddReceivedPacket
puts processing results to queue.protected boolean
handleMalformedInput
(ByteBuffer buffer, CharBuffer cb) boolean
void
void
boolean
void
startTLS
(boolean clientMode, boolean wantClientAuth, boolean needClientAuth) void
boolean
Methods 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, xmppStreamOpened
Methods 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, 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:XMPPIOService
MethodaddReceivedPacket
puts processing results to queue. The processing results are usually data (messages) which has been just received from socket.- Overrides:
addReceivedPacket
in classXMPPIOService<RefObject>
- Parameters:
packet
- aPacket
value of processing results.
-
waitingToRead
public boolean waitingToRead()- Overrides:
waitingToRead
in classIOService<RefObject>
-
processWaitingPackets
- Overrides:
processWaitingPackets
in classXMPPIOService<RefObject>
- Throws:
IOException
-
waitForResponse
public void waitForResponse() -
isWaitingForResponse
public boolean isWaitingForResponse() -
queueTask
-
shouldQueueStreamOpened
public boolean shouldQueueStreamOpened() -
handleMalformedInput
- Overrides:
handleMalformedInput
in classIOService<RefObject>
-
startTLS
public void startTLS(boolean clientMode, boolean wantClientAuth, boolean needClientAuth) throws IOException - Overrides:
startTLS
in classIOService<RefObject>
- Throws:
IOException
-