org.apache.activemq.transport
Class WireFormatNegotiator

java.lang.Object
  extended by org.apache.activemq.transport.TransportFilter
      extended by org.apache.activemq.transport.WireFormatNegotiator
All Implemented Interfaces:
Service, Transport, TransportListener

public class WireFormatNegotiator
extends TransportFilter

Negotiates the wire format with a new connection


Field Summary
 
Fields inherited from class org.apache.activemq.transport.TransportFilter
next, transportListener
 
Constructor Summary
WireFormatNegotiator(Transport next, OpenWireFormat wireFormat, int minimumVersion)
          Negotiator
 
Method Summary
 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()
           
 
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
 

Constructor Detail

WireFormatNegotiator

public WireFormatNegotiator(Transport next,
                            OpenWireFormat wireFormat,
                            int minimumVersion)
Negotiator

Parameters:
next -
Method Detail

start

public void start()
           throws Exception
Specified by:
start in interface Service
Overrides:
start in class TransportFilter
Throws:
Exception
See Also:
Service.start()

sendWireFormat

public void sendWireFormat()
                    throws IOException
Throws:
IOException

stop

public void stop()
          throws Exception
Specified by:
stop in interface Service
Overrides:
stop in class TransportFilter
Throws:
Exception
See Also:
Service.stop()

oneway

public void oneway(Object command)
            throws IOException
Description copied from interface: Transport
A one way asynchronous send

Specified by:
oneway in interface Transport
Overrides:
oneway in class TransportFilter
Throws:
IOException

onCommand

public void onCommand(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(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 String toString()
Overrides:
toString in class TransportFilter

sendWireFormat

protected void sendWireFormat(WireFormatInfo info)
                       throws IOException
Throws:
IOException

onWireFormatNegotiated

protected void onWireFormatNegotiated(WireFormatInfo info)

getNegotiateTimeout

public long getNegotiateTimeout()

setNegotiateTimeout

public void setNegotiateTimeout(long negotiateTimeout)


Copyright © 2005-2013 The Apache Software Foundation. All Rights Reserved.