org.activemq.transport.jabber
Class JabberTransportChannel

java.lang.Object
  extended by org.activemq.transport.TransportChannelSupport
      extended by org.activemq.transport.tcp.TcpTransportChannel
          extended by 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 $

Field Summary
 
Fields inherited from class org.activemq.transport.tcp.TcpTransportChannel
dataIn, dataOut, socket
 
Fields inherited from class org.activemq.transport.TransportChannelSupport
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally
 
Constructor Summary
JabberTransportChannel()
           
JabberTransportChannel(Socket socket, Executor executor)
           
JabberTransportChannel(TcpTransportServerChannel serverChannel, Socket socket, Executor executor)
           
JabberTransportChannel(URI remoteLocation)
           
JabberTransportChannel(URI remoteLocation, URI localLocation)
           
 
Method Summary
 JabberWireFormat getJabberWireFormat()
           
protected  void initializeStreams()
           
 void run()
          reads packets from a Socket
 
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
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

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
Method Detail

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-2008 Protique, Ltd.. All Rights Reserved.