activemq::transport::inactivity::InactivityMonitor Class Reference

#include <src/main/activemq/transport/inactivity/InactivityMonitor.h>

Inheritance diagram for activemq::transport::inactivity::InactivityMonitor:

[legend]

Public Member Functions
	InactivityMonitor (const Pointer< Transport > next, const Pointer< wireformat::WireFormat > wireFormat)
	InactivityMonitor (const Pointer< Transport > next, const decaf::util::Properties &properties, const Pointer< wireformat::WireFormat > wireFormat)
virtual	~InactivityMonitor ()
virtual void	onException (const decaf::lang::Exception &ex)
	Event handler for an exception from a command transport.
virtual void	onCommand (const Pointer< Command > command)
	Event handler for the receipt of a command.
virtual void	oneway (const Pointer< Command > command)
	Sends a one-way command.
bool	isKeepAliveResponseRequired () const
void	setKeepAliveResponseRequired (bool value)
long long	getReadCheckTime () const
void	setReadCheckTime (long long value)
long long	getWriteCheckTime () const
void	setWriteCheckTime (long long value)
long long	getInitialDelayTime () const
void	setInitialDelayTime (long long value) const
Protected Member Functions
virtual void	afterNextIsStarted ()
	Subclasses can override this method to do their own post startup work.
virtual void	beforeNextIsStopped ()
	Subclasses can override this method to do their own pre-stop work.
virtual void	doClose ()
	Subclasses can override this method to do their own close work.
Friends
class	ReadChecker
class	AsyncSignalReadErrorkTask
class	WriteChecker
class	AsyncWriteTask

---

Constructor & Destructor Documentation

activemq::transport::inactivity::InactivityMonitor::InactivityMonitor	(	const Pointer< Transport >	next,
		const Pointer< wireformat::WireFormat >	wireFormat
	)

activemq::transport::inactivity::InactivityMonitor::InactivityMonitor	(	const Pointer< Transport >	next,
		const decaf::util::Properties &	properties,
		const Pointer< wireformat::WireFormat >	wireFormat
	)

virtual activemq::transport::inactivity::InactivityMonitor::~InactivityMonitor

(

)

[virtual]

---

Member Function Documentation

virtual void activemq::transport::inactivity::InactivityMonitor::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::transport::inactivity::InactivityMonitor::beforeNextIsStopped

(

)

[protected, virtual]

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

This method will always be called before the next transport's own stop() method or this filter's own doStop() method is called.

Reimplemented from activemq::transport::TransportFilter.

virtual void activemq::transport::inactivity::InactivityMonitor::doClose

(

)

[protected, virtual]

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

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

Reimplemented from activemq::transport::TransportFilter.

long long activemq::transport::inactivity::InactivityMonitor::getInitialDelayTime

(

)

const

long long activemq::transport::inactivity::InactivityMonitor::getReadCheckTime

(

)

const

long long activemq::transport::inactivity::InactivityMonitor::getWriteCheckTime

(

)

const

bool activemq::transport::inactivity::InactivityMonitor::isKeepAliveResponseRequired

(

)

const

virtual void activemq::transport::inactivity::InactivityMonitor::onCommand

(

const Pointer< 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::transport::inactivity::InactivityMonitor::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.

Reimplemented from activemq::transport::TransportFilter.

virtual void activemq::transport::inactivity::InactivityMonitor::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.

void activemq::transport::inactivity::InactivityMonitor::setInitialDelayTime

(

long long

value

)

const

void activemq::transport::inactivity::InactivityMonitor::setKeepAliveResponseRequired

(

bool

value

)

void activemq::transport::inactivity::InactivityMonitor::setReadCheckTime

(

long long

value

)

void activemq::transport::inactivity::InactivityMonitor::setWriteCheckTime

(

long long

value

)

---

Friends And Related Function Documentation

friend class AsyncSignalReadErrorkTask [friend]

friend class AsyncWriteTask [friend]

friend class ReadChecker [friend]

friend class WriteChecker [friend]

---

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

• src/main/activemq/transport/inactivity/InactivityMonitor.h