org.apache.activemq.transport
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(java.lang.Object o)
called to process a command
|
void |
oneway(java.lang.Object command)
A one way asynchronous send
|
void |
onException(java.io.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() |
java.lang.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 java.lang.Exception
start
in interface Service
start
in class TransportFilter
java.lang.Exception
Service.start()
public void sendWireFormat() throws java.io.IOException
java.io.IOException
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class TransportFilter
java.lang.Exception
Service.stop()
public void oneway(java.lang.Object command) throws java.io.IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
java.io.IOException
public void onCommand(java.lang.Object o)
TransportListener
onCommand
in interface TransportListener
onCommand
in class TransportFilter
public void negociate(WireFormatInfo info)
public void onException(java.io.IOException error)
TransportListener
onException
in interface TransportListener
onException
in class TransportFilter
public java.lang.String toString()
toString
in class TransportFilter
protected void sendWireFormat(WireFormatInfo info) throws java.io.IOException
java.io.IOException
protected void onWireFormatNegotiated(WireFormatInfo info)
public long getNegotiateTimeout()
public void setNegotiateTimeout(long negotiateTimeout)
Copyright © 2005-2014. All Rights Reserved.