org.codehaus.activemq.transport.jxta
Class JxtaTransportChannel

java.lang.Object
  org.codehaus.activemq.transport.TransportChannelSupport
      org.codehaus.activemq.transport.tcp.TcpTransportChannel
          org.codehaus.activemq.transport.jxta.JxtaTransportChannel

All Implemented Interfaces:

Runnable, org.codehaus.activemq.service.Service, org.codehaus.activemq.transport.TransportChannel

public class JxtaTransportChannel

extends org.codehaus.activemq.transport.tcp.TcpTransportChannel

A JXTA implementation of a TransportChannel

Version:

$Revision: 1.2 $

Field Summary

Fields inherited from class org.codehaus.activemq.transport.tcp.TcpTransportChannel

socket

Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport

pendingStop, transportConnected

Constructor Summary

JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, URI remoteLocation)
Connect to a remote Node - e.g.

JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, URI remoteLocation, URI localLocation)
Connect to a remote Node - e.g.

Method Summary

protected Socket	createSocket(URI remoteLocation)
protected Socket	createSocket(URI remoteLocation, URI localLocation)
String	toString() pretty print for object

Methods inherited from class org.codehaus.activemq.transport.tcp.TcpTransportChannel

asyncSend, canProcessWireFormatVersion, doAsyncSend, forceDisconnect, getCurrentWireFormatVersion, getSocket, getSoTimeout, initialiseSocket, isChangeTimeout, isMulticast, isUseAsyncSend, run, setChangeTimeout, setSoTimeout, setUseAsyncSend, start, stop

Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport

addTransportStatusEventListener, asyncSendWithReceipt, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getEmbeddedBrokerConnector, getExceptionListener, getLastReceiptTimestamp, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, requiresEmbeddedBroker, send, send, setClientID, setExceptionListener, setPacketListener, setPendingStop, setServerSide, setTransportChannelListener, setTransportConnected, stopExecutor

Methods inherited from class java.lang.Object

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

Constructor Detail

JxtaTransportChannel

public JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
                            URI remoteLocation)
                     throws JMSException

Connect to a remote Node - e.g. a Broker

Parameters:

remoteLocation -

Throws:

JMSException

JxtaTransportChannel

public JxtaTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
                            URI remoteLocation,
                            URI localLocation)
                     throws JMSException

Connect to a remote Node - e.g. a Broker

Parameters:

remoteLocation -

localLocation - - e.g. local InetAddress and local port

Throws:

JMSException

Method Detail

toString

public String toString()

pretty print for object

Returns:

String representation of this object

createSocket

protected Socket createSocket(URI remoteLocation)
                       throws UnknownHostException,
                              IOException

Throws:

UnknownHostException

IOException

createSocket

protected Socket createSocket(URI remoteLocation,
                              URI localLocation)
                       throws IOException,
                              UnknownHostException

Throws:

IOException

UnknownHostException