|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.codehaus.activemq.transport.AbstractTransportChannel
org.codehaus.activemq.transport.vm.VmTransportChannel
A VM implementation of a TransportChannel
Constructor Summary | |
VmTransportChannel()
|
|
VmTransportChannel(Channel sendChannel,
Channel receiveChannel)
|
|
VmTransportChannel(int capacity)
|
Method Summary | |
void |
asyncSend(Packet packet)
Asynchronously send a Packet |
TransportChannel |
createServerSide()
Creates the server side version of this client side channel. |
static int |
getNextThreadId()
|
boolean |
isMulticast()
|
void |
run()
reads packets from a Socket |
void |
start()
start listeneing for events |
void |
stop()
close the channel |
java.lang.String |
toString()
pretty print for object |
Methods inherited from class org.codehaus.activemq.transport.AbstractTransportChannel |
addTransportStatusEventListener, doAsyncSend, doConsumePacket, doHandleReceipt, fireStatusEvent, fireStatusEvent, getClientID, getExceptionListener, getPacketListener, getTransportChannelListener, onAsyncException, removeTransportStatusEventListener, send, send, setClientID, setExceptionListener, setPacketListener, setTransportChannelListener, stopExecutor |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
public VmTransportChannel(Channel sendChannel, Channel receiveChannel)
public VmTransportChannel()
public VmTransportChannel(int capacity)
Method Detail |
public void stop()
stop
in interface TransportChannel
stop
in class AbstractTransportChannel
public void start() throws JMSException
start
in interface TransportChannel
JMSException
- if an error occurspublic static int getNextThreadId()
public void asyncSend(Packet packet) throws JMSException
asyncSend
in interface TransportChannel
packet
-
JMSException
public boolean isMulticast()
isMulticast
in interface TransportChannel
public void run()
run
in interface java.lang.Runnable
public java.lang.String toString()
public TransportChannel createServerSide() throws JMSException
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |