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
JabberTransportChannel
public JabberTransportChannel(URI remoteLocation,
URI localLocation)
throws JMSException
JabberTransportChannel
public JabberTransportChannel(TcpTransportServerChannel serverChannel,
Socket socket,
Executor executor)
throws JMSException
JabberTransportChannel
public JabberTransportChannel(Socket socket,
Executor executor)
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-2007 Protique, Ltd.. All Rights Reserved.