rwsf::JmsConnectorImp
Group: JMS Transport
rwsf::JmsConnectorImprwsf::ConnectorImp
Local Index
Members
|
init() isShutdown() JmsConnectorImp() |
reinit() restoreRequests() restoreSpecificRequests() |
start() stop() ~JmsConnectorImp() |
Header File
#include rwsf/transport/jms/JmsConnectorImp.h
Description
Class JmsConnectorImp implements a Hydra JMS connector.
Public Constructors
JmsConnectorImp();
Default constructor.
Public Destructors
virtual ~JmsConnectorImp();
Default destructor.
Public Member Functions
void
init(const rwsf::Config & config,
const rwsf::AgentContext & agent);
Implements method in rwsf::ConnectorImp
Base class documentation:
Initializes this connector implementation. If this function is overridden in derived classes, the overriding function must call this function first before doing anything else.
Implementation documentation:
Initializes the handler with the specified configuration options. When this method is called, the base class init() method is also invoked. Refer to the JMS Connector design specification for valid config options.
Exceptions
rwsfs::Exception |
When jms is misconfigured with message discribing the misconfiguration. |
runtime |
if for any reason the JMS implementation fails for an unknow reason. |
bool isShutdown();
Indicates if stop() has been called. ThreadPool threads call this method to determine when they should stop consuming.
void
reinit(const rwsf::Config & config,
const rwsf::AgentContext & agent);
Implements method in rwsf::ConnectorImp
Base class documentation:
Overridden to provide specific conenctor reconfiguration.
Implementation documentation:
Reinit the handler. Not yet implemented.
void restoreRequests(bool startup);
Reimplements method in rwsf::ConnectorImp
Base class documentation:
Called to restore persisted requests for this connector. Base class implementation does nothing.
Implementation documentation:
Called to restore persisted requests, if any, for this connector
void restoreSpecificRequests(const std::vector< std::string > & requestKeys);
Reimplements method in rwsf::ConnectorImp
Base class documentation:
Restores the persisted requests specified by the vector of persistence keys passed in. Base class implementation does nothing.
Implementation documentation:
Restores the persisted requests specified by the vector of persistence keys passed in.
void start();
Implements method in rwsf::ConnectorImp
Base class documentation:
Starts this connector. This function must be implemented by derived classes. Also, the implementation should not block process execution, that is, it should return control immediately to the caller.
Implementation documentation:
Starts the specified connector. This is implemented as a non-blocking method.
void stop();
Implements method in rwsf::ConnectorImp
Base class documentation:
Stops this connector. This function must be implemented by derived classes. The implementation can block process execution, if neccessary, until shutdown is completed.
Implementation documentation:
Stops the specified connector. This method will block until the connector has completed it's shutdown.
© Copyright Rogue Wave Software, Inc. All Rights Reserved. All Rights Reserved. Rogue Wave is a registered trademark of Rogue Wave Software, Inc. in the United States and other countries. HydraExpress is a trademark of Rogue Wave Software, Inc. All other trademarks are the property of their respective owners.
Contact Rogue Wave about documentation or support issues.