org.apache.activemq.transport
Class WireFormatNegotiator
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.WireFormatNegotiator
- All Implemented Interfaces:
- Service, Transport, TransportListener
public class WireFormatNegotiator
- extends TransportFilter
Negotiates the wire format with a new connection
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, reconnect, request, request, setTransportListener, transportInterupted, transportResumed, updateURIs |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
WireFormatNegotiator
public WireFormatNegotiator(Transport next,
OpenWireFormat wireFormat,
int minimumVersion)
- Negotiator
- Parameters:
next
-
start
public void start()
throws java.lang.Exception
- Specified by:
start
in interface Service
- Overrides:
start
in class TransportFilter
- Throws:
java.lang.Exception
- See Also:
Service.start()
sendWireFormat
public void sendWireFormat()
throws java.io.IOException
- Throws:
java.io.IOException
stop
public void stop()
throws java.lang.Exception
- Specified by:
stop
in interface Service
- Overrides:
stop
in class TransportFilter
- Throws:
java.lang.Exception
- See Also:
Service.stop()
oneway
public void oneway(java.lang.Object command)
throws java.io.IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TransportFilter
- Throws:
java.io.IOException
onCommand
public void onCommand(java.lang.Object o)
- Description copied from interface:
TransportListener
- called to process a command
- Specified by:
onCommand
in interface TransportListener
- Overrides:
onCommand
in class TransportFilter
negociate
public void negociate(WireFormatInfo info)
onException
public void onException(java.io.IOException error)
- Description copied from interface:
TransportListener
- An unrecoverable exception has occured on the transport
- Specified by:
onException
in interface TransportListener
- Overrides:
onException
in class TransportFilter
toString
public java.lang.String toString()
- Overrides:
toString
in class TransportFilter
sendWireFormat
protected void sendWireFormat(WireFormatInfo info)
throws java.io.IOException
- Throws:
java.io.IOException
onWireFormatNegotiated
protected void onWireFormatNegotiated(WireFormatInfo info)
getNegotiateTimeout
public long getNegotiateTimeout()
setNegotiateTimeout
public void setNegotiateTimeout(long negotiateTimeout)
Copyright © 2005-2015. All Rights Reserved.