|
|||||||||||
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.ember.EmberTransportChannel
An EmberIO (using NIO) implementation of a TransportChannel
Field Summary |
Fields inherited from class org.codehaus.activemq.transport.TransportChannelSupport |
pendingStop, transportConnected |
Constructor Summary | |
protected |
EmberTransportChannel(WireFormat wireFormat)
Construct basic helpers |
|
EmberTransportChannel(WireFormat wireFormat,
pyrasun.eio.EIOGlobalContext context,
pyrasun.eio.services.EmberServiceController controller,
pyrasun.eio.services.bytearray.ByteArrayServerClient client)
Connect to a remote Node - e.g. |
Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
boolean |
canProcessWireFormatVersion(int version)
Can this wireformat process packets of this version |
protected JMSException |
createJMSException(String message,
Exception ex)
Factory method to create a JMSException which is linked to the base exception |
int |
getCurrentWireFormatVersion()
|
boolean |
isMulticast()
|
void |
newMessage(pyrasun.eio.services.bytearray.ByteArrayServerClient client,
Object msg)
|
void |
start()
start listeneing for events |
void |
stop()
close the channel |
String |
toString()
pretty print for object |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
protected EmberTransportChannel(WireFormat wireFormat)
public EmberTransportChannel(WireFormat wireFormat, pyrasun.eio.EIOGlobalContext context, pyrasun.eio.services.EmberServiceController controller, pyrasun.eio.services.bytearray.ByteArrayServerClient client)
Method Detail |
public void stop()
stop
in interface TransportChannel
stop
in class TransportChannelSupport
public void start() throws JMSException
start
in interface TransportChannel
JMSException
- if an error occurspublic void asyncSend(Packet packet) throws JMSException
asyncSend
in interface TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface TransportChannel
protected JMSException createJMSException(String message, Exception ex)
public String toString()
public void newMessage(pyrasun.eio.services.bytearray.ByteArrayServerClient client, Object msg)
newMessage
in interface pyrasun.eio.services.bytearray.ByteArrayServerClientListener
public boolean canProcessWireFormatVersion(int version)
canProcessWireFormatVersion
in interface TransportChannel
version
- the version number to test
public int getCurrentWireFormatVersion()
getCurrentWireFormatVersion
in interface TransportChannel
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |