org.codehaus.activemq.transport.jxta
Class JxtaTransportChannel

java.lang.Object
  extended byorg.codehaus.activemq.transport.TransportChannelSupport
      extended byorg.codehaus.activemq.transport.tcp.TcpTransportChannel
          extended byorg.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


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