|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.TransportChannelSupport
org.activemq.transport.activeio.ActiveIOTransportChannel
A tcp implementation of a TransportChannel
Field Summary |
Fields inherited from class org.activemq.transport.TransportChannelSupport |
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
Constructor Summary | |
ActiveIOTransportChannel(WireFormat wireFormat,
org.activeio.AsyncChannel asynchChannel)
|
Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
protected Packet |
doAsyncSend(Packet packet)
send a Packet to the raw underlying transport This method is here to allow specific implementations to override this method |
void |
forceDisconnect()
Forces an immediate transport-level disconnect which will be asynchronously reported as an exception to the exceptionListener. |
org.activeio.AsyncChannel |
getAsyncChannel()
|
int |
getCurrentWireFormatVersion()
|
void |
onPacket(org.activeio.Packet packet)
|
void |
onPacketError(IOException ex)
|
void |
start()
start listeneing for events |
void |
stop()
close the channel |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ActiveIOTransportChannel(WireFormat wireFormat, org.activeio.AsyncChannel asynchChannel)
Method Detail |
public void start() throws JMSException
TransportChannel
start
in interface TransportChannel
JMSException
- if an error occurspublic void stop()
TransportChannelSupport
stop
in interface TransportChannel
stop
in class TransportChannelSupport
public void forceDisconnect()
TransportChannel
forceDisconnect
in interface TransportChannel
public void asyncSend(Packet packet) throws JMSException
TransportChannel
asyncSend
in interface TransportChannel
packet
- the packet to send
JMSException
protected Packet doAsyncSend(Packet packet) throws JMSException
TransportChannelSupport
doAsyncSend
in class TransportChannelSupport
packet
-
JMSException
public void onPacket(org.activeio.Packet packet)
onPacket
in interface org.activeio.AsyncChannelListener
public void onPacketError(IOException ex)
onPacketError
in interface org.activeio.AsyncChannelListener
public org.activeio.AsyncChannel getAsyncChannel()
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in interface TransportChannel
getCurrentWireFormatVersion
in class TransportChannelSupport
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |