org.activemq.transport.jabber
Class JabberTransportChannel
java.lang.Object
org.activemq.transport.TransportChannelSupport
org.activemq.transport.tcp.TcpTransportChannel
org.activemq.transport.jabber.JabberTransportChannel
- All Implemented Interfaces:
- Runnable, Service, TransportChannel
public class JabberTransportChannel
- extends TcpTransportChannel
A transport for using Jabber (XMPP) to talk to ActiveMQ
- Version:
- $Revision: 1.1 $
Methods inherited from class org.activemq.transport.tcp.TcpTransportChannel |
asyncSend, canProcessWireFormatVersion, closeStreams, createSocket, createSocket, doAsyncSend, doClose, forceDisconnect, getCurrentWireFormatVersion, getSocket, getSocketBufferSize, getSoTimeout, initialiseSocket, isClosed, isMulticast, isUseAsyncSend, readWireFormat, setNoDelay, setSocketBufferSize, setSoTimeout, setUseAsyncSend, start, stop, toString |
Methods inherited from class org.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, asyncSendWithReceipt, doConsumePacket, doConsumePacket, doesSupportMessageCompression, doesSupportMessageFragmentation, doesSupportWireFormatVersioning, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, getWireFormat, isCachingEnabled, isNoDelay, isPendingStop, isServerSide, isTransportConnected, isUsedInternally, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setCachingEnabled, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, setUsedInternally, setWireFormat, stopExecutor |
JabberTransportChannel
public JabberTransportChannel()
JabberTransportChannel
public JabberTransportChannel(URI remoteLocation)
throws JMSException
- Throws:
JMSException
JabberTransportChannel
public JabberTransportChannel(URI remoteLocation,
URI localLocation)
throws JMSException
- Throws:
JMSException
JabberTransportChannel
public JabberTransportChannel(TcpTransportServerChannel serverChannel,
Socket socket,
Executor executor)
throws JMSException
- Throws:
JMSException
JabberTransportChannel
public JabberTransportChannel(Socket socket,
Executor executor)
throws JMSException
- Throws:
JMSException
run
public void run()
- Description copied from class:
TcpTransportChannel
- reads packets from a Socket
- Specified by:
run
in interface Runnable
- Overrides:
run
in class TcpTransportChannel
getJabberWireFormat
public JabberWireFormat getJabberWireFormat()
initializeStreams
protected void initializeStreams()
throws IOException
- Overrides:
initializeStreams
in class TcpTransportChannel
- Throws:
IOException
Copyright © 2004-2009 Protique, Ltd.. All Rights Reserved.