|
||||||||||
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.jgroups.JGroupsTransportChannel
A JGroups implementation of a TransportChannel
Field Summary |
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
pendingStop, transportConnected |
Constructor Summary | |
JGroupsTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat,
org.jgroups.Channel channel,
Executor executor)
|
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 |
run()
reads packets from a Socket |
void |
start()
start listeneing for events |
void |
stop()
close the channel |
String |
toString()
|
protected void |
writePacket(org.codehaus.activemq.message.Packet packet)
writes the packet to the channel |
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 |
public JGroupsTransportChannel(org.codehaus.activemq.io.WireFormat wireFormat, org.jgroups.Channel channel, Executor executor)
Method Detail |
public String toString()
public void stop()
stop
in interface org.codehaus.activemq.transport.TransportChannel
public void start() throws JMSException
start
in interface org.codehaus.activemq.transport.TransportChannel
JMSException
- if an error occurspublic void asyncSend(org.codehaus.activemq.message.Packet packet) throws JMSException
asyncSend
in interface org.codehaus.activemq.transport.TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface org.codehaus.activemq.transport.TransportChannel
public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion
in interface org.codehaus.activemq.transport.TransportChannel
version
- the version number to test
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in interface org.codehaus.activemq.transport.TransportChannel
public void run()
run
in interface Runnable
protected void writePacket(org.codehaus.activemq.message.Packet packet) throws JMSException
JMSException
public void forceDisconnect()
forceDisconnect
in interface org.codehaus.activemq.transport.TransportChannel
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |