activemq::wireformat::openwire::OpenWireFormatNegotiator Class Reference

#include <src/main/activemq/wireformat/openwire/OpenWireFormatNegotiator.h>

Inheritance diagram for activemq::wireformat::openwire::OpenWireFormatNegotiator:

[legend]

Public Member Functions
	OpenWireFormatNegotiator (OpenWireFormat *wireFormat, const Pointer< transport::Transport > next)
	Constructor - Initializes this object around another Transport.
virtual	~OpenWireFormatNegotiator ()
virtual void	oneway (const Pointer< commands::Command > command)
	Sends a one-way command.
virtual Pointer < commands::Response >	request (const Pointer< commands::Command > command)
	Sends the given command to the broker and then waits for the response.
virtual Pointer < commands::Response >	request (const Pointer< commands::Command > command, unsigned int timeout)
	Sends the given command to the broker and then waits for the response.
virtual void	onCommand (const Pointer< commands::Command > command)
	Event handler for the receipt of a command.
virtual void	onException (const decaf::lang::Exception &ex)
	Event handler for an exception from a command transport.
Protected Member Functions
virtual void	afterNextIsStarted ()
	Subclasses can override this method to do their own post startup work.
virtual void	afterNextIsStopped ()
	Subclasses can override this method to do their own stop work.

---

Constructor & Destructor Documentation

activemq::wireformat::openwire::OpenWireFormatNegotiator::OpenWireFormatNegotiator	(	OpenWireFormat *	wireFormat,
		const Pointer< transport::Transport >	next
	)

Constructor - Initializes this object around another Transport.

Parameters:

	wireFormat	- The WireFormat object we use to negotiate
	next	- The next transport in the chain

virtual activemq::wireformat::openwire::OpenWireFormatNegotiator::~OpenWireFormatNegotiator

(

)

[virtual]

---

Member Function Documentation

virtual void activemq::wireformat::openwire::OpenWireFormatNegotiator::afterNextIsStarted

(

)

[protected, virtual]

Subclasses can override this method to do their own post startup work.

This method will always be called after the doStart() method and the next transport's own start() methods have been successfully run.

Reimplemented from activemq::transport::TransportFilter.

virtual void activemq::wireformat::openwire::OpenWireFormatNegotiator::afterNextIsStopped

(

)

[protected, virtual]

Subclasses can override this method to do their own stop work.

This method is always called after all the next transports have been stopped to prevent this transport for destroying resources needed by the lower level transports.

Reimplemented from activemq::transport::TransportFilter.

virtual void activemq::wireformat::openwire::OpenWireFormatNegotiator::onCommand

(

const Pointer< commands::Command >

command

)

[virtual]

Event handler for the receipt of a command.

Parameters:

command

- the received command object.

Reimplemented from activemq::transport::TransportFilter.

virtual void activemq::wireformat::openwire::OpenWireFormatNegotiator::oneway

(

const Pointer< commands::Command >

command

)

[virtual]

Sends a one-way command.

Does not wait for any response from the broker.

Parameters:

command

The command to be sent.

Exceptions:

	IOException	if an exception occurs during writing of the command.
	UnsupportedOperationException	if this method is not implemented by this transport.

Reimplemented from activemq::transport::TransportFilter.

virtual void activemq::wireformat::openwire::OpenWireFormatNegotiator::onException

(

const decaf::lang::Exception &

ex

)

[virtual]

Event handler for an exception from a command transport.

Parameters:

ex

The exception to handle.

Reimplemented from activemq::transport::TransportFilter.

virtual Pointer<commands::Response> activemq::wireformat::openwire::OpenWireFormatNegotiator::request	(	const Pointer< commands::Command >	command,
		unsigned int	timeout
	)			[virtual]

Sends the given command to the broker and then waits for the response.

Parameters:

	command	The command to be sent.
	timeout	The time to wait for this response.

Returns:

the response from the broker.

Exceptions:

	IOException	if an exception occurs during the read of the command.
	UnsupportedOperationException	if this method is not implemented by this transport.

Reimplemented from activemq::transport::TransportFilter.

virtual Pointer<commands::Response> activemq::wireformat::openwire::OpenWireFormatNegotiator::request

(

const Pointer< commands::Command >

command

)

[virtual]

Sends the given command to the broker and then waits for the response.

Parameters:

command

the command to be sent.

Returns:

the response from the broker.

Exceptions:

	IOException	if an exception occurs during the read of the command.
	UnsupportedOperationException	if this method is not implemented by this transport.

Reimplemented from activemq::transport::TransportFilter.

---

The documentation for this class was generated from the following file:

• src/main/activemq/wireformat/openwire/OpenWireFormatNegotiator.h