|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.transport.vm.VMTransport
public class VMTransport
A Transport implementation that uses direct method invocations.
Field Summary | |
---|---|
protected boolean |
async
|
protected int |
asyncQueueDepth
|
protected boolean |
disposed
|
protected long |
id
|
protected URI |
location
|
protected boolean |
marshal
|
protected edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue |
messageQueue
|
protected boolean |
network
|
protected VMTransport |
peer
|
protected List |
prePeerSetQueue
|
protected boolean |
started
|
protected TransportListener |
transportListener
|
Constructor Summary | |
---|---|
VMTransport(URI location)
|
Method Summary | |
---|---|
protected void |
asyncOneWay(Object command)
|
FutureResponse |
asyncRequest(Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in the future. |
int |
getAsyncQueueDepth()
|
protected edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue |
getMessageQueue()
|
VMTransport |
getPeer()
|
String |
getRemoteAddress()
|
TransportListener |
getTransportListener()
Returns the current transport listener |
boolean |
isAsync()
|
boolean |
isMarshal()
|
boolean |
isNetwork()
|
boolean |
iterate()
|
Object |
narrow(Class target)
|
void |
oneway(Object command)
A one way asynchronous send |
Object |
request(Object command)
A synchronous request response |
Object |
request(Object command,
int timeout)
A synchronous request response |
void |
setAsync(boolean async)
|
void |
setAsyncQueueDepth(int asyncQueueDepth)
|
void |
setMarshal(boolean marshal)
|
void |
setNetwork(boolean network)
|
void |
setPeer(VMTransport peer)
|
void |
setTransportListener(TransportListener commandListener)
Registers an inbound command listener |
void |
start()
|
void |
stop()
|
protected void |
syncOneWay(Object command)
|
String |
toString()
|
protected void |
wakeup()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected VMTransport peer
protected TransportListener transportListener
protected boolean disposed
protected boolean marshal
protected boolean network
protected boolean async
protected boolean started
protected int asyncQueueDepth
protected List prePeerSetQueue
protected edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue messageQueue
protected final URI location
protected final long id
Constructor Detail |
---|
public VMTransport(URI location)
Method Detail |
---|
public VMTransport getPeer()
public void setPeer(VMTransport peer)
public void oneway(Object command) throws IOException
Transport
oneway
in interface Transport
IOException
protected void syncOneWay(Object command)
protected void asyncOneWay(Object command) throws IOException
IOException
public FutureResponse asyncRequest(Object command, ResponseCallback responseCallback) throws IOException
Transport
asyncRequest
in interface Transport
responseCallback
- TODO
IOException
public Object request(Object command) throws IOException
Transport
request
in interface Transport
IOException
public Object request(Object command, int timeout) throws IOException
Transport
request
in interface Transport
IOException
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public void setTransportListener(TransportListener commandListener)
Transport
setTransportListener
in interface Transport
public void start() throws Exception
start
in interface Service
Exception
public void stop() throws Exception
stop
in interface Service
Exception
public Object narrow(Class target)
narrow
in interface Transport
public boolean isMarshal()
public void setMarshal(boolean marshal)
public boolean isNetwork()
public void setNetwork(boolean network)
public String toString()
toString
in class Object
public String getRemoteAddress()
getRemoteAddress
in interface Transport
public boolean iterate()
iterate
in interface Task
Task.iterate()
public boolean isAsync()
public void setAsync(boolean async)
async
- the async to setpublic int getAsyncQueueDepth()
public void setAsyncQueueDepth(int asyncQueueDepth)
asyncQueueDepth
- the asyncQueueDepth to setprotected void wakeup()
protected edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue getMessageQueue()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |