The MockTransport defines a base level Transport class that is intended to be used in place of an a regular protocol Transport suck as TCP. More...

#include <src/main/activemq/transport/mock/MockTransport.h>

Inheritance diagram for activemq::transport::mock::MockTransport:

[legend]

Public Member Functions
	MockTransport (const Pointer< wireformat::WireFormat > wireFormat, const Pointer< ResponseBuilder > responseBuilder)

virtual	~MockTransport ()

virtual void	fireCommand (const Pointer< Command > command)
	Fires a Command back through this transport to its registered CommandListener if there is one.

virtual void	fireException (const exceptions::ActiveMQException &ex)
	Fires a Exception back through this transport to its registered ExceptionListener if there is one.

void	setResponseBuilder (const Pointer< ResponseBuilder > responseBuilder)
	Sets the ResponseBuilder that this class uses to create Responses to Commands sent.

virtual void	setOutgoingListener (TransportListener *listener)
	Sets a Listener that gets notified for every command that would have been sent by this transport to the Broker, this allows a client to verify that its messages are making it to the wire.

Pointer< wireformat::WireFormat >	getWireFormat () const
	Gets the currently set WireFormat.

virtual void	oneway (const Pointer< Command > command)
	Sends a one-way command.

virtual Pointer< FutureResponse >	asyncRequest (const Pointer< Command > command, const Pointer< ResponseCallback > responseCallback)
	Sends a commands asynchronously, returning a FutureResponse object that the caller can use to check to find out the response from the broker.

virtual Pointer< Response >	request (const Pointer< Command > command)
	Sends the given command to the broker and then waits for the response.

virtual Pointer< Response >	request (const Pointer< Command > command, unsigned int timeout)
	Sends the given command to the broker and then waits for the response.

virtual void	setWireFormat (const Pointer< wireformat::WireFormat > wireFormat AMQCPP_UNUSED)
	Sets the WireFormat instance to use.

virtual void	setTransportListener (TransportListener *listener)
	Sets the observer of asynchronous events from this transport.

virtual TransportListener *	getTransportListener () const
	Gets the observer of asynchronous events from this transport.

virtual void	start ()
	Starts the Transport, the send methods of a Transport will throw an exception if used before the Transport is started.

virtual void	stop ()
	Stops the Transport.

virtual void	close ()
	Closes this object and deallocates the appropriate resources.

virtual Transport *	narrow (const std::type_info &typeId)
	Narrows down a Chain of Transports to a specific Transport to allow a higher level transport to skip intermediate Transports in certain circumstances.

virtual bool	isFaultTolerant () const
	Is this Transport fault tolerant, meaning that it will reconnect to a broker on disconnect.

virtual bool	isConnected () const
	Is the Transport Connected to its Broker.

virtual bool	isClosed () const
	Has the Transport been shutdown and no longer usable.

virtual std::string	getRemoteAddress () const

virtual void	reconnect (const decaf::net::URI &uri AMQCPP_UNUSED)

std::string	getName () const

void	setName (const std::string &name)

bool	isFailOnSendMessage () const

void	setFailOnSendMessage (bool value)

int	getNumSentMessageBeforeFail () const

void	setNumSentMessageBeforeFail (int value)

int	getNumSentMessages () const

void	setNumSentMessages (int value)

bool	isFailOnReceiveMessage () const

void	setFailOnReceiveMessage (bool value)

int	getNumReceivedMessageBeforeFail () const

void	setNumReceivedMessageBeforeFail (int value)

int	getNumReceivedMessages () const

void	setNumReceivedMessages (int value)

bool	isFailOnKeepAliveSends () const

void	setFailOnKeepAliveSends (bool value)

int	getNumSentKeepAlivesBeforeFail () const

void	setNumSentKeepAlivesBeforeFail (int value)

int	getNumSentKeepAlives () const

void	setNumSentKeepAlives (int value)

bool	isFailOnStart () const

void	setFailOnStart (bool value)

bool	isFailOnStop () const

void	setFailOnStop (bool value)

bool	isFailOnClose () const

void	setFailOnClose (bool value)

virtual bool	isReconnectSupported () const

virtual bool	isUpdateURIsSupported () const

virtual void	updateURIs (bool rebalance AMQCPP_UNUSED, const decaf::util::List< decaf::net::URI > &uris AMQCPP_UNUSED)

Public Member Functions inherited from activemq::transport::Transport
virtual	~Transport ()

virtual void	start ()=0
	Starts the Transport, the send methods of a Transport will throw an exception if used before the Transport is started.

virtual void	stop ()=0
	Stops the Transport.

virtual void	oneway (const Pointer< Command > command)=0
	Sends a one-way command.

virtual Pointer< FutureResponse >	asyncRequest (const Pointer< Command > command, const Pointer< ResponseCallback > responseCallback)=0
	Sends a commands asynchronously, returning a FutureResponse object that the caller can use to check to find out the response from the broker.

virtual Pointer< Response >	request (const Pointer< Command > command)=0
	Sends the given command to the broker and then waits for the response.

virtual Pointer< Response >	request (const Pointer< Command > command, unsigned int timeout)=0
	Sends the given command to the broker and then waits for the response.

virtual Pointer< wireformat::WireFormat >	getWireFormat () const =0
	Gets the WireFormat instance that is in use by this transport.

virtual void	setWireFormat (const Pointer< wireformat::WireFormat > wireFormat)=0
	Sets the WireFormat instance to use.

virtual void	setTransportListener (TransportListener *listener)=0
	Sets the observer of asynchronous events from this transport.

virtual TransportListener *	getTransportListener () const =0
	Gets the observer of asynchronous events from this transport.

virtual Transport *	narrow (const std::type_info &typeId)=0
	Narrows down a Chain of Transports to a specific Transport to allow a higher level transport to skip intermediate Transports in certain circumstances.

virtual bool	isFaultTolerant () const =0
	Is this Transport fault tolerant, meaning that it will reconnect to a broker on disconnect.

virtual bool	isConnected () const =0
	Is the Transport Connected to its Broker.

virtual bool	isClosed () const =0
	Has the Transport been shutdown and no longer usable.

virtual bool	isReconnectSupported () const =0

virtual bool	isUpdateURIsSupported () const =0

virtual std::string	getRemoteAddress () const =0

virtual void	reconnect (const decaf::net::URI &uri)=0
	reconnect to another location

virtual void	updateURIs (bool rebalance, const decaf::util::List< decaf::net::URI > &uris)=0
	Updates the set of URIs the Transport can connect to.

Public Member Functions inherited from activemq::util::Service
virtual	~Service ()

virtual void	start ()=0

virtual void	stop ()=0

Public Member Functions inherited from decaf::io::Closeable
virtual	~Closeable ()

virtual void	close ()=0
	Closes this object and deallocates the appropriate resources.

Static Public Member Functions
static MockTransport *	getInstance ()

Detailed Description

The MockTransport defines a base level Transport class that is intended to be used in place of an a regular protocol Transport suck as TCP.

This Transport assumes that it is the base Transport in the Transports stack, and destroys any Transports that are passed to it in its constructor.

This Transport defines an Interface ResponseBuilder which must be implemented by any protocol for which the Transport is used to Emulate. The Transport hands off all outbound commands to the ResponseBuilder for processing, it is up to the builder to create appropriate responses and schedule any asynchronous messages that might result from a message sent to the Broker.

Constructor & Destructor Documentation

◆ MockTransport()

activemq::transport::mock::MockTransport::MockTransport	(	const Pointer< wireformat::WireFormat >	wireFormat,
		const Pointer< ResponseBuilder >	responseBuilder
	)

◆ ~MockTransport()

virtual activemq::transport::mock::MockTransport::~MockTransport ( )

inlinevirtual

Member Function Documentation

◆ asyncRequest()

virtual Pointer< FutureResponse > activemq::transport::mock::MockTransport::asyncRequest	(	const Pointer< Command >	command,
		const Pointer< ResponseCallback >	responseCallback
	)

virtual

Sends a commands asynchronously, returning a FutureResponse object that the caller can use to check to find out the response from the broker.

Parameters

command	The Command object that is to sent out.
responseCallback	A callback object that will be notified once a response to the command is received.

Returns: A FutureResponse instance that can be queried for the Response to the Command.

Exceptions

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

Implements activemq::transport::Transport.

◆ close()

virtual void activemq::transport::mock::MockTransport::close ( )

virtual

Closes this object and deallocates the appropriate resources.

The object is generally no longer usable after calling close.

Exceptions

IOException if an error occurs while closing.

Implements decaf::io::Closeable.

◆ fireCommand()

virtual void activemq::transport::mock::MockTransport::fireCommand ( const Pointer< Command > command )

inlinevirtual

Fires a Command back through this transport to its registered CommandListener if there is one.

Parameters

command - Command to send to the Listener.

References NULL, and activemq::transport::TransportListener::onCommand().

◆ fireException()

virtual void activemq::transport::mock::MockTransport::fireException ( const exceptions::ActiveMQException & ex )

inlinevirtual

Fires a Exception back through this transport to its registered ExceptionListener if there is one.

Parameters

ex	The Exception that will be passed on the the Transport listener.

References NULL, and activemq::transport::TransportListener::onException().

◆ getInstance()

static MockTransport * activemq::transport::mock::MockTransport::getInstance ( )

inlinestatic

◆ getName()

std::string activemq::transport::mock::MockTransport::getName ( ) const

inline

◆ getNumReceivedMessageBeforeFail()

int activemq::transport::mock::MockTransport::getNumReceivedMessageBeforeFail ( ) const

inline

◆ getNumReceivedMessages()

int activemq::transport::mock::MockTransport::getNumReceivedMessages ( ) const

inline

◆ getNumSentKeepAlives()

int activemq::transport::mock::MockTransport::getNumSentKeepAlives ( ) const

inline

◆ getNumSentKeepAlivesBeforeFail()

int activemq::transport::mock::MockTransport::getNumSentKeepAlivesBeforeFail ( ) const

inline

◆ getNumSentMessageBeforeFail()

int activemq::transport::mock::MockTransport::getNumSentMessageBeforeFail ( ) const

inline

◆ getNumSentMessages()

int activemq::transport::mock::MockTransport::getNumSentMessages ( ) const

inline

◆ getRemoteAddress()

virtual std::string activemq::transport::mock::MockTransport::getRemoteAddress ( ) const

inlinevirtual

Returns: the remote address for this connection

Implements activemq::transport::Transport.

◆ getTransportListener()

virtual TransportListener * activemq::transport::mock::MockTransport::getTransportListener ( ) const

inlinevirtual

Gets the observer of asynchronous events from this transport.

Returns: the listener of transport events.

Implements activemq::transport::Transport.

◆ getWireFormat()

Pointer< wireformat::WireFormat > activemq::transport::mock::MockTransport::getWireFormat ( ) const

inlinevirtual

Gets the currently set WireFormat.

Returns: the current WireFormat object.

Implements activemq::transport::Transport.

◆ isClosed()

virtual bool activemq::transport::mock::MockTransport::isClosed ( ) const

inlinevirtual

Has the Transport been shutdown and no longer usable.

Returns: true if the Transport

Implements activemq::transport::Transport.

◆ isConnected()

virtual bool activemq::transport::mock::MockTransport::isConnected ( ) const

inlinevirtual

Is the Transport Connected to its Broker.

Returns: true if a connection has been made.

Implements activemq::transport::Transport.

◆ isFailOnClose()

bool activemq::transport::mock::MockTransport::isFailOnClose ( ) const

inline

◆ isFailOnKeepAliveSends()

bool activemq::transport::mock::MockTransport::isFailOnKeepAliveSends ( ) const

inline

◆ isFailOnReceiveMessage()

bool activemq::transport::mock::MockTransport::isFailOnReceiveMessage ( ) const

inline

◆ isFailOnSendMessage()

bool activemq::transport::mock::MockTransport::isFailOnSendMessage ( ) const

inline

◆ isFailOnStart()

bool activemq::transport::mock::MockTransport::isFailOnStart ( ) const

inline

◆ isFailOnStop()

bool activemq::transport::mock::MockTransport::isFailOnStop ( ) const

inline

◆ isFaultTolerant()

virtual bool activemq::transport::mock::MockTransport::isFaultTolerant ( ) const

inlinevirtual

Is this Transport fault tolerant, meaning that it will reconnect to a broker on disconnect.

Returns: true if the Transport is fault tolerant.

Implements activemq::transport::Transport.

◆ isReconnectSupported()

virtual bool activemq::transport::mock::MockTransport::isReconnectSupported ( ) const

inlinevirtual

Returns: true if reconnect is supported.

Implements activemq::transport::Transport.

◆ isUpdateURIsSupported()

virtual bool activemq::transport::mock::MockTransport::isUpdateURIsSupported ( ) const

inlinevirtual

Returns: true if updating uris is supported.

Implements activemq::transport::Transport.

◆ narrow()

virtual Transport * activemq::transport::mock::MockTransport::narrow ( const std::type_info & typeId )

inlinevirtual

Narrows down a Chain of Transports to a specific Transport to allow a higher level transport to skip intermediate Transports in certain circumstances.

Parameters

typeId - The type_info of the Object we are searching for.

Returns: the requested Object. or NULL if its not in this chain.

Implements activemq::transport::Transport.

References NULL.

◆ oneway()

virtual void activemq::transport::mock::MockTransport::oneway ( const Pointer< 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.

Implements activemq::transport::Transport.

◆ reconnect()

virtual void activemq::transport::mock::MockTransport::reconnect ( const decaf::net::URI &uri AMQCPP_UNUSED )

inlinevirtual

◆ request() [1/2]

virtual Pointer< Response > activemq::transport::mock::MockTransport::request ( const Pointer< 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.

Implements activemq::transport::Transport.

◆ request() [2/2]

virtual Pointer< Response > activemq::transport::mock::MockTransport::request	(	const Pointer< 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.

Implements activemq::transport::Transport.

◆ setFailOnClose()

void activemq::transport::mock::MockTransport::setFailOnClose ( bool value )

inline

◆ setFailOnKeepAliveSends()

void activemq::transport::mock::MockTransport::setFailOnKeepAliveSends ( bool value )

inline

◆ setFailOnReceiveMessage()

void activemq::transport::mock::MockTransport::setFailOnReceiveMessage ( bool value )

inline

◆ setFailOnSendMessage()

void activemq::transport::mock::MockTransport::setFailOnSendMessage ( bool value )

inline

◆ setFailOnStart()

void activemq::transport::mock::MockTransport::setFailOnStart ( bool value )

inline

◆ setFailOnStop()

void activemq::transport::mock::MockTransport::setFailOnStop ( bool value )

inline

◆ setName()

void activemq::transport::mock::MockTransport::setName ( const std::string & name )

inline

◆ setNumReceivedMessageBeforeFail()

void activemq::transport::mock::MockTransport::setNumReceivedMessageBeforeFail ( int value )

inline

◆ setNumReceivedMessages()

void activemq::transport::mock::MockTransport::setNumReceivedMessages ( int value )

inline

◆ setNumSentKeepAlives()

void activemq::transport::mock::MockTransport::setNumSentKeepAlives ( int value )

inline

◆ setNumSentKeepAlivesBeforeFail()

void activemq::transport::mock::MockTransport::setNumSentKeepAlivesBeforeFail ( int value )

inline

◆ setNumSentMessageBeforeFail()

void activemq::transport::mock::MockTransport::setNumSentMessageBeforeFail ( int value )

inline

◆ setNumSentMessages()

void activemq::transport::mock::MockTransport::setNumSentMessages ( int value )

inline

◆ setOutgoingListener()

virtual void activemq::transport::mock::MockTransport::setOutgoingListener ( TransportListener * listener )

inlinevirtual

Sets a Listener that gets notified for every command that would have been sent by this transport to the Broker, this allows a client to verify that its messages are making it to the wire.

Parameters

listener - The CommandListener to notify for each message

◆ setResponseBuilder()

void activemq::transport::mock::MockTransport::setResponseBuilder ( const Pointer< ResponseBuilder > responseBuilder )

inline

Sets the ResponseBuilder that this class uses to create Responses to Commands sent.

These are either real Response Objects, or Commands that would have been sent Asynchronously be the Broker.

Parameters

responseBuilder - The ResponseBuilder to use from now on.

◆ setTransportListener()

virtual void activemq::transport::mock::MockTransport::setTransportListener ( TransportListener * listener )

inlinevirtual

Sets the observer of asynchronous events from this transport.

Parameters

listener the listener of transport events.

Implements activemq::transport::Transport.

◆ setWireFormat()

virtual void activemq::transport::mock::MockTransport::setWireFormat ( const Pointer< wireformat::WireFormat > wireFormat wireFormat )

inlinevirtual

Sets the WireFormat instance to use.

Parameters

wireFormat The WireFormat the object used to encode / decode commands.

Implements activemq::transport::Transport.

◆ start()

virtual void activemq::transport::mock::MockTransport::start ( )

virtual

Starts the Transport, the send methods of a Transport will throw an exception if used before the Transport is started.

Exceptions

IOException if and error occurs while starting the Transport.

Implements activemq::transport::Transport.

◆ stop()

virtual void activemq::transport::mock::MockTransport::stop ( )

virtual

Stops the Transport.

Exceptions

IOException if an error occurs while stopping the transport.

Implements activemq::transport::Transport.

◆ updateURIs()

virtual void activemq::transport::mock::MockTransport::updateURIs	(	bool rebalance	AMQCPP_UNUSED,
		const decaf::util::List< decaf::net::URI > &uris	AMQCPP_UNUSED
	)

inlinevirtual

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

src/main/activemq/transport/mock/MockTransport.h

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ MockTransport()

◆ ~MockTransport()

Member Function Documentation

◆ asyncRequest()

◆ close()

◆ fireCommand()

◆ fireException()

◆ getInstance()

◆ getName()

◆ getNumReceivedMessageBeforeFail()

◆ getNumReceivedMessages()

◆ getNumSentKeepAlives()

◆ getNumSentKeepAlivesBeforeFail()

◆ getNumSentMessageBeforeFail()

◆ getNumSentMessages()

◆ getRemoteAddress()

◆ getTransportListener()

◆ getWireFormat()

◆ isClosed()

◆ isConnected()

◆ isFailOnClose()

◆ isFailOnKeepAliveSends()

◆ isFailOnReceiveMessage()

◆ isFailOnSendMessage()

◆ isFailOnStart()

◆ isFailOnStop()

◆ isFaultTolerant()

◆ isReconnectSupported()

◆ isUpdateURIsSupported()

◆ narrow()

◆ oneway()

◆ reconnect()

◆ request() [1/2]

◆ request() [2/2]

◆ setFailOnClose()

◆ setFailOnKeepAliveSends()

◆ setFailOnReceiveMessage()

◆ setFailOnSendMessage()

◆ setFailOnStart()

◆ setFailOnStop()

◆ setName()

◆ setNumReceivedMessageBeforeFail()

◆ setNumReceivedMessages()

◆ setNumSentKeepAlives()

◆ setNumSentKeepAlivesBeforeFail()

◆ setNumSentMessageBeforeFail()

◆ setNumSentMessages()

◆ setOutgoingListener()

◆ setResponseBuilder()

◆ setTransportListener()

◆ setWireFormat()

◆ start()

◆ stop()

◆ updateURIs()