public class WireFormatNegotiator extends TransportFilter
next, transportListener
Constructor and Description |
---|
WireFormatNegotiator(Transport next,
OpenWireFormat wireFormat,
int minimumVersion)
Negotiator
|
Modifier and Type | Method and Description |
---|---|
long |
getNegotiateTimeout() |
void |
negociate(WireFormatInfo info) |
void |
onCommand(Object o)
called to process a command
|
void |
oneway(Object command)
A one way asynchronous send
|
void |
onException(IOException error)
An unrecoverable exception has occured on the transport
|
protected void |
onWireFormatNegotiated(WireFormatInfo info) |
void |
sendWireFormat() |
protected void |
sendWireFormat(WireFormatInfo info) |
void |
setNegotiateTimeout(long negotiateTimeout) |
void |
start() |
void |
stop() |
String |
toString() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, transportInterupted, transportResumed, updateURIs
public WireFormatNegotiator(Transport next, OpenWireFormat wireFormat, int minimumVersion)
next
- public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
public void sendWireFormat() throws IOException
IOException
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
public void oneway(Object command) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public void onCommand(Object o)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void negociate(WireFormatInfo info)
public void onException(IOException error)
TransportListener
onException
in interface TransportListener
onException
in class TransportFilter
public String toString()
toString
in class TransportFilter
protected void sendWireFormat(WireFormatInfo info) throws IOException
IOException
protected void onWireFormatNegotiated(WireFormatInfo info)
public long getNegotiateTimeout()
public void setNegotiateTimeout(long negotiateTimeout)
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.