org.codehaus.activemq.transport.gnet
Class GTransportChannel

java.lang.Object
  org.codehaus.activemq.transport.TransportChannelSupport
      org.codehaus.activemq.transport.gnet.GTransportChannel

All Implemented Interfaces:

Service, TransportChannel

public class GTransportChannel

extends TransportChannelSupport

An implementation of a TransportChannel which uses the Geronimo network layer for connectivity.

Version:

$Revision: 1.16 $

Field Summary

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

pendingStop, transportConnected

Constructor Summary

	GTransportChannel(WireFormat wireFormat, org.apache.geronimo.network.protocol.Protocol protocol, org.apache.geronimo.pool.ThreadPool tp)
protected	GTransportChannel(WireFormat wireFormat, org.apache.geronimo.pool.ThreadPool tp) Construct basic helpers
	GTransportChannel(WireFormat wireFormat, URI remoteLocation, URI localLocation, org.apache.geronimo.network.SelectorManager sm, org.apache.geronimo.pool.ThreadPool tp, org.apache.geronimo.pool.ClockPool cp)

Method Summary

void	asyncSend(Packet packet) Asynchronously send a Packet
boolean	canProcessWireFormatVersion(int version) Can this wireformat process packets of this version
int	getCurrentWireFormatVersion()
boolean	isMulticast()
void	start() start listeneing for events
void	stop() close the channel
protected Packet	toPacket(org.apache.geronimo.network.protocol.UpPacket packet)
protected org.apache.geronimo.network.protocol.PlainDownPacket	toPlainDownPacket(Packet mqpacket)
String	toString() pretty print for object

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

addTransportStatusEventListener, doAsyncSend, doConsumePacket, doConsumePacket, doHandleReceipt, doHandleWireFormat, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getPacketListener, getTransportChannelListener, isPendingStop, isServerSide, isTransportConnected, onAsyncException, removeTransportStatusEventListener, 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

GTransportChannel

protected GTransportChannel(WireFormat wireFormat,
                            org.apache.geronimo.pool.ThreadPool tp)

Construct basic helpers

GTransportChannel

public GTransportChannel(WireFormat wireFormat,
                         org.apache.geronimo.network.protocol.Protocol protocol,
                         org.apache.geronimo.pool.ThreadPool tp)

Parameters:

protocol -

GTransportChannel

public GTransportChannel(WireFormat wireFormat,
                         URI remoteLocation,
                         URI localLocation,
                         org.apache.geronimo.network.SelectorManager sm,
                         org.apache.geronimo.pool.ThreadPool tp,
                         org.apache.geronimo.pool.ClockPool cp)
                  throws UnknownHostException,
                         org.apache.geronimo.network.protocol.ProtocolException

Parameters:

remoteLocation -

localLocation -

Method Detail

stop

public void stop()

close the channel

Specified by:

stop in interface TransportChannel

Overrides:

stop in class TransportChannelSupport

start

public void start()
           throws JMSException

start listeneing for events

Throws:

JMSException - if an error occurs

asyncSend

public void asyncSend(Packet packet)
               throws JMSException

Asynchronously send a Packet

Parameters:

packet -

Throws:

JMSException

isMulticast

public boolean isMulticast()

Returns:

true if this transport is multicast based (i.e. broadcasts to multiple nodes)

toPlainDownPacket

protected org.apache.geronimo.network.protocol.PlainDownPacket toPlainDownPacket(Packet mqpacket)
                                                                          throws IOException,
                                                                                 JMSException

Throws:

IOException

JMSException

toPacket

protected Packet toPacket(org.apache.geronimo.network.protocol.UpPacket packet)
                   throws IOException

Throws:

IOException

toString

public String toString()

pretty print for object

Returns:

String representation of this object

canProcessWireFormatVersion

public boolean canProcessWireFormatVersion(int version)

Can this wireformat process packets of this version

Parameters:

version - the version number to test

Returns:

true if can accept the version

getCurrentWireFormatVersion

public int getCurrentWireFormatVersion()

Returns:

the current version of this wire format