|
||||||||||
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
public class 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()
Called to start the service |
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
Service
start
in interface Service
start
in interface TransportChannel
JMSException
- if an error occurspublic void stop()
TransportChannelSupport
stop
in interface Service
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
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 |