org.activemq.transport.jabber
Class JabberTransportChannel

java.lang.Object
  extended byorg.activemq.transport.TransportChannelSupport
      extended byorg.activemq.transport.tcp.TcpTransportChannel
          extended byorg.activemq.transport.jabber.JabberTransportChannel
All Implemented Interfaces:
java.lang.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(java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.Executor executor)
           
JabberTransportChannel(TcpTransportServerChannel serverChannel, java.net.Socket socket, EDU.oswego.cs.dl.util.concurrent.Executor executor)
           
JabberTransportChannel(java.net.URI remoteLocation)
           
JabberTransportChannel(java.net.URI remoteLocation, java.net.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, 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(java.net.URI remoteLocation)
                       throws javax.jms.JMSException

JabberTransportChannel

public JabberTransportChannel(java.net.URI remoteLocation,
                              java.net.URI localLocation)
                       throws javax.jms.JMSException

JabberTransportChannel

public JabberTransportChannel(TcpTransportServerChannel serverChannel,
                              java.net.Socket socket,
                              EDU.oswego.cs.dl.util.concurrent.Executor executor)
                       throws javax.jms.JMSException

JabberTransportChannel

public JabberTransportChannel(java.net.Socket socket,
                              EDU.oswego.cs.dl.util.concurrent.Executor executor)
                       throws javax.jms.JMSException
Method Detail

run

public void run()
Description copied from class: TcpTransportChannel
reads packets from a Socket

Specified by:
run in interface java.lang.Runnable
Overrides:
run in class TcpTransportChannel

getJabberWireFormat

public JabberWireFormat getJabberWireFormat()

initializeStreams

protected void initializeStreams()
                          throws java.io.IOException
Overrides:
initializeStreams in class TcpTransportChannel
Throws:
java.io.IOException


Copyright © 2004-2005 Protique, Ltd.. All Rights Reserved.