tigase.server.websocket

Class WebSocketXMPPIOService<RefObject>

java.lang.Object

tigase.net.IOService<RefObject>

tigase.xmpp.XMPPIOService<RefObject>

tigase.server.websocket.WebSocketXMPPIOService<RefObject>

Type Parameters:

RefObject -

All Implemented Interfaces:

Callable<IOService<?>>, TLSEventHandler, tigase.util.IOListener

public class WebSocketXMPPIOService<RefObject>
extends XMPPIOService<RefObject>

Class implements basic support for WebSocket protocol. It extends XMPPIOService so it can be used instead of XMPPIOService in ClientConnectionManager to allow web clients to connect to it without using BOSH extension.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WebSocketXMPPIOService.WebSocketXMPPSpec

Field Summary

Fields

Modifier and Type	Field and Description
protected long	frameLength
protected byte[]	maskingKey

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, REQ_NAME, writeInProgress

Fields inherited from class tigase.net.IOService

cb, CERT_CHECK_RESULT, CERT_REQUIRED_DOMAIN, decoder, encoder, HOSTNAME_KEY, partialCharacterBytes, PORT_TYPE_PROP_KEY, SESSION_ID_KEY, SSL_PROTOCOLS_KEY

Constructor Summary

Constructors

Constructor and Description
WebSocketXMPPIOService(WebSocketProtocolIfc[] enabledProtocols)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addReceivedPacket(Packet packet) Method addReceivedPacket puts processing results to queue.
void	dumpHeaders(Map<String,String> headers)
protected WebSocketXMPPIOService.WebSocketXMPPSpec	getWebSocketXMPPSpec()
protected String	prepareStreamClose()
protected char[]	readData() Custom implementation of readData function which decodes WebSocket protocol frames
void	stop() Describe stop method here.
protected void	writeBytes(ByteBuffer data) Method description
protected void	writeData(String data) Custom implementation of writeData function which encodes data in WebSocket protocol frames

Methods inherited from class tigase.xmpp.XMPPIOService

addPacketToSend, checkBufferLimit, checkData, clearWaitingPackets, forceStop, getLastXmppPacketReceiveTime, getPacketsReceived, getPacketsSent, getReceivedPackets, getTotalPacketsReceived, getTotalPacketsSent, getUserJid, getWaitingForAct, getWaitingPackets, getXMLNS, processSocketData, processWaitingPackets, receivedPackets, setAckMode, setElementLimits, setIOServiceListener, setProcessors, setUserJid, setXMLNS, toString, writeRawData, xmppStreamClosed, xmppStreamOpen, xmppStreamOpened

Methods inherited from class tigase.net.IOService

accept, byteOrder, call, connectionType, debug, debug, getBuffOverflow, getBytesReceived, getBytesSent, getConnectionId, getDataReceiver, getLastTransferTime, getLocalAddress, getLocalPort, getPeersJIDsFromCert, getReadCounters, getRefObject, getRemoteAddress, getSessionData, getSocketChannel, getStatistics, getTotalBuffOverflow, getTotalBytesReceived, getTotalBytesSent, getUniqueId, getWriteCounters, getX509TrustManagers, handshakeCompleted, isConnected, isInputBufferEmpty, readBytes, readCompleted, setBufferLimit, setConnectionId, setDataReceiver, setIOServiceListener, setRefObject, setSessionData, setX509TrustManagers, startSSL, startTLS, startZLib, waitingToRead, waitingToSend, waitingToSendSize

Methods inherited from class java.lang.Object

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

Field Detail

frameLength

protected long frameLength

maskingKey

protected byte[] maskingKey

Constructor Detail

WebSocketXMPPIOService

public WebSocketXMPPIOService(WebSocketProtocolIfc[] enabledProtocols)

Method Detail

stop

public void stop()

Description copied from class: XMPPIOService

Describe stop method here.

Overrides:

stop in class XMPPIOService<RefObject>

addReceivedPacket

protected void addReceivedPacket(Packet packet)

Description copied from class: XMPPIOService

Method addReceivedPacket puts processing results to queue. The processing results are usually data (messages) which has been just received from socket.

Overrides:

addReceivedPacket in class XMPPIOService<RefObject>

Parameters:

packet - a Packet value of processing results.

getWebSocketXMPPSpec

protected WebSocketXMPPIOService.WebSocketXMPPSpec getWebSocketXMPPSpec()

prepareStreamClose

protected String prepareStreamClose()

Overrides:

prepareStreamClose in class XMPPIOService<RefObject>

readData

protected char[] readData()
                   throws IOException

Custom implementation of readData function which decodes WebSocket protocol frames

Overrides:

readData in class IOService<RefObject>

Returns:

a char[] value

Throws:

IOException

writeData

protected void writeData(String data)

Custom implementation of writeData function which encodes data in WebSocket protocol frames

Overrides:

writeData in class IOService<RefObject>

Parameters:

data -

writeBytes

protected void writeBytes(ByteBuffer data)

Description copied from class: IOService

Method description

Overrides:

writeBytes in class IOService<RefObject>

dumpHeaders

public void dumpHeaders(Map<String,String> headers)