Modifier and Type | Field and Description |
---|---|
protected boolean |
async |
protected int |
asyncQueueDepth |
protected boolean |
disposed |
protected long |
id |
protected java.net.URI |
location |
protected boolean |
marshal |
protected java.util.concurrent.LinkedBlockingQueue<java.lang.Object> |
messageQueue |
protected boolean |
network |
protected VMTransport |
peer |
protected boolean |
started |
protected java.util.concurrent.atomic.AtomicBoolean |
stopping |
protected TransportListener |
transportListener |
Constructor and Description |
---|
VMTransport(java.net.URI location) |
Modifier and Type | Method and Description |
---|---|
FutureResponse |
asyncRequest(java.lang.Object command,
ResponseCallback responseCallback)
An asynchronous request response where the Receipt will be returned in
the future.
|
void |
dispatch(VMTransport transport,
TransportListener transportListener,
java.lang.Object command) |
int |
getAsyncQueueDepth() |
int |
getReceiveCounter()
Returns a counter which gets incremented as data is read from the transport.
|
java.lang.String |
getRemoteAddress() |
TransportListener |
getTransportListener()
Returns the current transport listener
|
boolean |
isAsync() |
boolean |
isConnected() |
boolean |
isDisposed() |
boolean |
isFaultTolerant()
Indicates if the transport can handle faults
|
boolean |
isMarshal() |
boolean |
isNetwork() |
boolean |
isReconnectSupported() |
boolean |
isUpdateURIsSupported() |
boolean |
iterate() |
<T> T |
narrow(java.lang.Class<T> target) |
void |
oneway(java.lang.Object command)
A one way asynchronous send
|
void |
reconnect(java.net.URI uri)
reconnect to another location
|
java.lang.Object |
request(java.lang.Object command)
A synchronous request response
|
java.lang.Object |
request(java.lang.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() |
java.lang.String |
toString() |
void |
updateURIs(boolean reblance,
java.net.URI[] uris)
Provide a list of available alternative locations
|
protected void |
wakeup() |
protected VMTransport peer
protected TransportListener transportListener
protected boolean disposed
protected boolean marshal
protected boolean network
protected boolean async
protected int asyncQueueDepth
protected java.util.concurrent.LinkedBlockingQueue<java.lang.Object> messageQueue
protected boolean started
protected final java.net.URI location
protected final long id
protected final java.util.concurrent.atomic.AtomicBoolean stopping
public VMTransport(java.net.URI location)
public void setPeer(VMTransport peer)
public void oneway(java.lang.Object command) throws java.io.IOException
Transport
public void dispatch(VMTransport transport, TransportListener transportListener, java.lang.Object command)
public void start() throws java.lang.Exception
public void stop() throws java.lang.Exception
public boolean iterate()
iterate
in interface Task
Task.iterate()
public void setTransportListener(TransportListener commandListener)
Transport
setTransportListener
in interface Transport
public FutureResponse asyncRequest(java.lang.Object command, ResponseCallback responseCallback) throws java.io.IOException
Transport
asyncRequest
in interface Transport
responseCallback
- TODOjava.io.IOException
public java.lang.Object request(java.lang.Object command) throws java.io.IOException
Transport
public java.lang.Object request(java.lang.Object command, int timeout) throws java.io.IOException
Transport
public TransportListener getTransportListener()
Transport
getTransportListener
in interface Transport
public <T> T narrow(java.lang.Class<T> target)
public boolean isMarshal()
public void setMarshal(boolean marshal)
public boolean isNetwork()
public void setNetwork(boolean network)
public java.lang.String toString()
toString
in class java.lang.Object
public java.lang.String getRemoteAddress()
getRemoteAddress
in interface Transport
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()
public boolean isFaultTolerant()
Transport
isFaultTolerant
in interface Transport
public boolean isDisposed()
isDisposed
in interface Transport
public boolean isConnected()
isConnected
in interface Transport
public void reconnect(java.net.URI uri) throws java.io.IOException
Transport
public boolean isReconnectSupported()
isReconnectSupported
in interface Transport
public boolean isUpdateURIsSupported()
isUpdateURIsSupported
in interface Transport
public void updateURIs(boolean reblance, java.net.URI[] uris) throws java.io.IOException
Transport
updateURIs
in interface Transport
java.io.IOException
public int getReceiveCounter()
Transport
getReceiveCounter
in interface Transport
Copyright © 2005-2012. All Rights Reserved.