|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.TransportChannelSupport
org.codehaus.activemq.transport.gnet.GTransportChannel
An implementation of a TransportChannel which uses the Geronimo network layer for connectivity.
Field Summary |
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
pendingStop, transportConnected |
Constructor Summary | |
|
GTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
org.apache.geronimo.network.protocol.Protocol protocol,
org.apache.geronimo.pool.ThreadPool tp)
|
protected |
GTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
org.apache.geronimo.pool.ThreadPool tp)
Construct basic helpers |
|
GTransportChannel(org.codehaus.activemq.io.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(org.codehaus.activemq.message.Packet packet)
Asynchronously send a Packet |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
void |
forceDisconnect()
|
int |
getCurrentWireFormatVersion()
|
boolean |
isMulticast()
|
void |
start()
start listeneing for events |
void |
stop()
close the channel |
protected org.codehaus.activemq.message.Packet |
toPacket(org.apache.geronimo.network.protocol.UpPacket packet)
|
protected org.apache.geronimo.network.protocol.PlainDownPacket |
toPlainDownPacket(org.codehaus.activemq.message.Packet mqpacket)
|
String |
toString()
pretty print for object |
Methods inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
addTransportStatusEventListener, asyncSendWithReceipt, doAsyncSend, 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 |
protected GTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, org.apache.geronimo.pool.ThreadPool tp)
public GTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, org.apache.geronimo.network.protocol.Protocol protocol, org.apache.geronimo.pool.ThreadPool tp)
protocol
- public GTransportChannel(org.codehaus.activemq.io.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
remoteLocation
- localLocation
- Method Detail |
public void stop()
public void start() throws JMSException
JMSException
- if an error occurspublic void asyncSend(org.codehaus.activemq.message.Packet packet) throws JMSException
packet
-
JMSException
public boolean isMulticast()
protected org.apache.geronimo.network.protocol.PlainDownPacket toPlainDownPacket(org.codehaus.activemq.message.Packet mqpacket) throws IOException, JMSException
IOException
JMSException
protected org.codehaus.activemq.message.Packet toPacket(org.apache.geronimo.network.protocol.UpPacket packet) throws IOException
IOException
public String toString()
public boolean canProcessWireFormatVersion(int version)
version
- the version number to test
public int getCurrentWireFormatVersion()
public void forceDisconnect()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |