Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,265 @@ + + +activemq-cpp: activemq::transport::FutureResponse Class Reference + + + + +
+
+
+
+ +

activemq::transport::FutureResponse Class Reference

#include <FutureResponse.h> +

+

Inheritance diagram for activemq::transport::FutureResponse: +

+ +activemq::concurrent::Synchronizable + +List of all members. + + + + + + + + + + + + + + + + + + +

Public Member Functions

virtual void lock () throw ( exceptions::ActiveMQException )
virtual void unlock () throw ( exceptions::ActiveMQException )
virtual void wait () throw ( exceptions::ActiveMQException )
virtual void wait (unsigned long millisecs) throw ( exceptions::ActiveMQException )
virtual void notify () throw ( exceptions::ActiveMQException )
virtual void notifyAll () throw ( exceptions::ActiveMQException )
virtual const Response * getResponse () const
virtual void setResponse (Response *response)
+

Detailed Description

+A container that holds a response object. Since this object is Synchronizable, callers can wait on this object and when a response comes in, notify can be called to inform those waiting that the response is now available. +

+


Member Function Documentation

+ +
+
+ + + + + + + + +
virtual const Response* activemq::transport::FutureResponse::getResponse (  )  const [inline, virtual]
+
+
+ +

+Getters for the response property.

Returns:
the response object for the request
+ +
+

+ +

+
+ + + + + + + + +
virtual void activemq::transport::FutureResponse::lock (  )  throw ( exceptions::ActiveMQException ) [inline, virtual]
+
+
+ +

+Locks the object.

Exceptions:
+ + +
ActiveMQException 
+
+ +

+Implements activemq::concurrent::Synchronizable. +

+

+ +

+
+ + + + + + + + +
virtual void activemq::transport::FutureResponse::notify (  )  throw ( exceptions::ActiveMQException ) [inline, virtual]
+
+
+ +

+Signals a waiter on this object that it can now wake up and continue. Must have this object locked before calling.

Exceptions:
+ + +
ActiveMQException 
+
+ +

+Implements activemq::concurrent::Synchronizable. +

+

+ +

+
+ + + + + + + + +
virtual void activemq::transport::FutureResponse::notifyAll (  )  throw ( exceptions::ActiveMQException ) [inline, virtual]
+
+
+ +

+Signals the waiters on this object that it can now wake up and continue. Must have this object locked before calling.

Exceptions:
+ + +
ActiveMQException 
+
+ +

+Implements activemq::concurrent::Synchronizable. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::FutureResponse::setResponse (Response *  response  )  [inline, virtual]
+
+
+ +

+Setter for the response property.

Parameters:
+ + +
response the response object for the request.
+
+ +
+

+ +

+
+ + + + + + + + +
virtual void activemq::transport::FutureResponse::unlock (  )  throw ( exceptions::ActiveMQException ) [inline, virtual]
+
+
+ +

+Unlocks the object.

Exceptions:
+ + +
ActiveMQException 
+
+ +

+Implements activemq::concurrent::Synchronizable. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::FutureResponse::wait (unsigned long  millisecs  )  throw ( exceptions::ActiveMQException ) [inline, virtual]
+
+
+ +

+Waits on a signal from this object, which is generated by a call to Notify. Must have this object locked before calling. This wait will timeout after the specified time interval.

Parameters:
+ + +
millisecs time in millisecsonds to wait, or WAIT_INIFINITE
+
+
Exceptions:
+ + +
ActiveMQException 
+
+ +

+Implements activemq::concurrent::Synchronizable. +

+

+ +

+
+ + + + + + + + +
virtual void activemq::transport::FutureResponse::wait (  )  throw ( exceptions::ActiveMQException ) [inline, virtual]
+
+
+ +

+Waits on a signal from this object, which is generated by a call to Notify. Must have this object locked before calling.

Exceptions:
+ + +
ActiveMQException 
+
+ +

+Implements activemq::concurrent::Synchronizable. +

+

+


The documentation for this class was generated from the following file: +
Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.png URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.png?rev=428212&view=auto ============================================================================== Binary file - no diff available. Propchange: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_future_response.png ------------------------------------------------------------------------------ svn:mime-type = application/octet-stream Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport-members.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport-members.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport-members.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport-members.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,35 @@ + + +activemq-cpp: Member List + + + + +
+
+
+
+

activemq::transport::IOTransport Member List

This is the complete list of members for activemq::transport::IOTransport, including all inherited members.

+ + + + + + + + + + + +
close()activemq::transport::IOTransport [virtual]
oneway(Command *command)activemq::transport::IOTransport [virtual]
request(Command *command)activemq::transport::IOTransport [inline, virtual]
run()activemq::transport::IOTransport [virtual]
setCommandListener(CommandListener *listener)activemq::transport::IOTransport [inline, virtual]
setCommandReader(CommandReader *reader)activemq::transport::IOTransport [inline, virtual]
setCommandWriter(CommandWriter *writer)activemq::transport::IOTransport [inline, virtual]
setInputStream(io::InputStream *is)activemq::transport::IOTransport [inline, virtual]
setOutputStream(io::OutputStream *os)activemq::transport::IOTransport [inline, virtual]
setTransportExceptionListener(TransportExceptionListener *listener)activemq::transport::IOTransport [inline, virtual]
start()activemq::transport::IOTransport [virtual]


Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,367 @@ + + +activemq-cpp: activemq::transport::IOTransport Class Reference + + + + +
+
+
+
+ +

activemq::transport::IOTransport Class Reference

#include <IOTransport.h> +

+

Inheritance diagram for activemq::transport::IOTransport: +

+ +activemq::transport::Transport +activemq::concurrent::Runnable +cms::Startable +cms::Closeable + +List of all members. + + + + + + + + + + + + + + + + + + + + + + + + +

Public Member Functions

virtual void oneway (Command *command) throw ( CommandIOException, exceptions::UnsupportedOperationException )
virtual Response * request (Command *command) throw ( CommandIOException, exceptions::UnsupportedOperationException )
virtual void setCommandListener (CommandListener *listener)
virtual void setCommandReader (CommandReader *reader)
virtual void setCommandWriter (CommandWriter *writer)
virtual void setTransportExceptionListener (TransportExceptionListener *listener)
virtual void setInputStream (io::InputStream *is)
virtual void setOutputStream (io::OutputStream *os)
virtual void start () throw ( cms::CMSException )
virtual void close () throw ( cms::CMSException )
virtual void run ()
+

Detailed Description

+Implementation of the Transport interface that performs marshalling of commands to IO streams. This class does not implement the request method, it only handles oneway messages. A thread polls on the input stream for in-coming commands. When a command is received, the command listener is notified. The polling thread is not started until the start method is called. The close method will close the associated streams. Close can be called explicitly by the user, but is also called in the destructor. Once this object has been closed, it cannot be restarted. +

+


Member Function Documentation

+ +
+
+ + + + + + + + +
void IOTransport::close (  )  throw ( cms::CMSException ) [virtual]
+
+
+ +

+Stops the polling thread and closes the streams. This can be called explicitly, but is also called in the destructor. Once this object has been closed, it cannot be restarted.

Exceptions:
+ + +
CMSException if errors occur.
+
+ +

+Close the input stream.

+Close the output stream. +

+Implements cms::Closeable. +

+

+ +

+
+ + + + + + + + + +
void IOTransport::oneway (Command *  command  )  throw ( CommandIOException, exceptions::UnsupportedOperationException ) [virtual]
+
+
+ +

+Sends a one-way command. Does not wait for any response from the broker.

Parameters:
+ + +
command the command to be sent.
+
+
Exceptions:
+ + + +
CommandIOException if an exception occurs during writing of the command.
UnsupportedOperationException if this method is not implemented by this transport.
+
+ +

+Implements activemq::transport::Transport. +

+

+ +

+
+ + + + + + + + + +
virtual Response* activemq::transport::IOTransport::request (Command *  command  )  throw ( CommandIOException, exceptions::UnsupportedOperationException ) [inline, virtual]
+
+
+ +

+Not supported by this class - throws an exception.

Parameters:
+ + +
command the command to be sent.
+
+
Returns:
the response to the command sent.
+
Exceptions:
+ + +
UnsupportedOperationException. 
+
+ +

+Implements activemq::transport::Transport. +

+

+ +

+
+ + + + + + + + +
void IOTransport::run (  )  [virtual]
+
+
+ +

+Runs the polling thread. +

+Implements activemq::concurrent::Runnable. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::IOTransport::setCommandListener (CommandListener listener  )  [inline, virtual]
+
+
+ +

+Assigns the command listener for non-response commands.

Parameters:
+ + +
listener the listener.
+
+ +

+Implements activemq::transport::Transport. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::IOTransport::setCommandReader (CommandReader reader  )  [inline, virtual]
+
+
+ +

+Sets the command reader.

Parameters:
+ + +
reader the object that will be used for reading command objects.
+
+ +

+Implements activemq::transport::Transport. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::IOTransport::setCommandWriter (CommandWriter writer  )  [inline, virtual]
+
+
+ +

+Sets the command writer.

Parameters:
+ + +
writer the object that will be used for writing command objects.
+
+ +

+Implements activemq::transport::Transport. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::IOTransport::setInputStream (io::InputStream is  )  [inline, virtual]
+
+
+ +

+Sets the input stream for in-coming commands.

Parameters:
+ + +
is The input stream.
+
+ +
+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::IOTransport::setOutputStream (io::OutputStream os  )  [inline, virtual]
+
+
+ +

+Sets the output stream for out-going commands.

Parameters:
+ + +
os The output stream.
+
+ +
+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::IOTransport::setTransportExceptionListener (TransportExceptionListener listener  )  [inline, virtual]
+
+
+ +

+Sets the observer of asynchronous exceptions from this transport.

Parameters:
+ + +
listener the listener of transport exceptions.
+
+ +

+Implements activemq::transport::Transport. +

+

+ +

+
+ + + + + + + + +
void IOTransport::start (  )  throw ( cms::CMSException ) [virtual]
+
+
+ +

+Starts this transport object and creates the thread for polling on the input stream for commands. If this object has been closed, throws an exception. Before calling start, the caller must set the IO streams and the reader and writer objects.

Exceptions:
+ + +
CMSException if an error occurs or if this transport has already been closed.
+
+ +

+Implements cms::Startable. +

+

+


The documentation for this class was generated from the following files: +
Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.png URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.png?rev=428212&view=auto ============================================================================== Binary file - no diff available. Propchange: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport.png ------------------------------------------------------------------------------ svn:mime-type = application/octet-stream Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory-members.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory-members.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory-members.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory-members.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,26 @@ + + +activemq-cpp: Member List + + + + +
+
+
+
+

activemq::transport::IOTransportFactory Member List

This is the complete list of members for activemq::transport::IOTransportFactory, including all inherited members.

+ + +
createTransport(const activemq::util::Properties &properties)activemq::transport::IOTransportFactory [inline, virtual]
getInstance(void)activemq::transport::IOTransportFactory [static]


Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_i_o_transport_factory.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,88 @@ + + +activemq-cpp: activemq::transport::IOTransportFactory Class Reference + + + + +
+
+
+
+ +

activemq::transport::IOTransportFactory Class Reference

#include <IOTransportFactory.h> +

+List of all members. + + + + + + + +

Public Member Functions

virtual TransportcreateTransport (const activemq::util::Properties &properties)

Static Public Member Functions

static TransportFactory & getInstance (void)
+


Detailed Description

+Manufactures IOTransports, which are objects that read from input streams and write to output streams. +

+


Member Function Documentation

+ +
+
+ + + + + + + + + +
virtual Transport* activemq::transport::IOTransportFactory::createTransport (const activemq::util::Properties properties  )  [inline, virtual]
+
+
+ +

+Creates a Transport instance.

Parameters:
+ + +
properties The properties for the transport.
+
+ +
+

+ +

+
+ + + + + + + + + +
TransportFactory & IOTransportFactory::getInstance (void   )  [static]
+
+
+ +

+Returns a reference to this TransportFactory

Returns:
TransportFactory Reference
+ +
+

+


The documentation for this class was generated from the following files: +
Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator-members.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator-members.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator-members.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator-members.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,44 @@ + + +activemq-cpp: Member List + + + + +
+
+
+
+

activemq::transport::ResponseCorrelator Member List

This is the complete list of members for activemq::transport::ResponseCorrelator, including all inherited members.

+ + + + + + + + + + + + + + + + + + + + +
close()activemq::transport::ResponseCorrelator [inline, virtual]
commandlisteneractivemq::transport::TransportFilter [protected]
exceptionListeneractivemq::transport::TransportFilter [protected]
fire(const exceptions::ActiveMQException &ex)activemq::transport::TransportFilter [inline, protected]
fire(Command *command)activemq::transport::TransportFilter [inline, protected]
getMaxResponseWaitTime() const activemq::transport::ResponseCorrelator [inline, virtual]
nextactivemq::transport::TransportFilter [protected]
onCommand(Command *command)activemq::transport::ResponseCorrelator [inline, virtual]
oneway(Command *command)activemq::transport::ResponseCorrelator [inline, virtual]
onTransportException(Transport *source, const exceptions::ActiveMQException &ex)activemq::transport::TransportFilter [inline, virtual]
ownactivemq::transport::TransportFilter [protected]
request(Command *command)activemq::transport::ResponseCorrelator [inline, virtual]
ResponseCorrelator(Transport *next, const bool own=true)activemq::transport::ResponseCorrelator [inline]
setCommandListener(CommandListener *listener)activemq::transport::ResponseCorrelator [inline, virtual]
setCommandReader(CommandReader *reader)activemq::transport::TransportFilter [inline, virtual]
setCommandWriter(CommandWriter *writer)activemq::transport::TransportFilter [inline, virtual]
setMaxResponseWaitTime(const unsigned long milliseconds)activemq::transport::ResponseCorrelator [inline, virtual]
setTransportExceptionListener(TransportExceptionListener *listener)activemq::transport::ResponseCorrelator [inline, virtual]
start()activemq::transport::ResponseCorrelator [inline, virtual]
TransportFilter(Transport *next, const bool own=true)activemq::transport::TransportFilter [inline]


Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.html URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.html?rev=428212&view=auto ============================================================================== --- incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.html (added) +++ incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.html Wed Aug 2 19:24:43 2006 @@ -0,0 +1,350 @@ + + +activemq-cpp: activemq::transport::ResponseCorrelator Class Reference + + + + +
+
+
+
+ +

activemq::transport::ResponseCorrelator Class Reference

#include <ResponseCorrelator.h> +

+

Inheritance diagram for activemq::transport::ResponseCorrelator: +

+ +activemq::transport::TransportFilter +activemq::transport::Transport +activemq::transport::CommandListener +activemq::transport::TransportExceptionListener +cms::Startable +cms::Closeable + +List of all members. + + + + + + + + + + + + + + + + + + + + + + +

Public Member Functions

 ResponseCorrelator (Transport *next, const bool own=true)
virtual unsigned long getMaxResponseWaitTime () const
virtual void setMaxResponseWaitTime (const unsigned long milliseconds)
virtual void oneway (Command *command) throw ( CommandIOException, exceptions::UnsupportedOperationException )
virtual Response * request (Command *command) throw ( CommandIOException, exceptions::UnsupportedOperationException )
virtual void onCommand (Command *command)
virtual void setCommandListener (CommandListener *listener)
virtual void setTransportExceptionListener (TransportExceptionListener *listener)
virtual void start () throw ( cms::CMSException )
virtual void close () throw ( cms::CMSException )
+

Detailed Description

+This type of transport filter is responsible for correlating asynchronous responses with requests. Non-response messages are simply sent directly to the CommandListener. It owns the transport that it +

+


Constructor & Destructor Documentation

+ +
+
+ + + + + + + + + + + + + + + + + + +
activemq::transport::ResponseCorrelator::ResponseCorrelator (Transport next,
const bool  own = true 
) [inline]
+
+
+ +

+Constructor.

Parameters:
+ + + +
next the next transport in the chain
own indicates if this transport owns the next
+
+ +
+

+


Member Function Documentation

+ +
+
+ + + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::close (void   )  throw ( cms::CMSException ) [inline, virtual]
+
+
+ +

+Stops the polling thread and closes the streams. This can be called explicitly, but is also called in the destructor. Once this object has been closed, it cannot be restarted.

Exceptions:
+ + +
CMSException if errors occur.
+
+ +

+Reimplemented from activemq::transport::TransportFilter. +

+

+ +

+
+ + + + + + + + +
virtual unsigned long activemq::transport::ResponseCorrelator::getMaxResponseWaitTime (  )  const [inline, virtual]
+
+
+ +

+Gets the maximum wait time for a response in milliseconds.

Returns:
max time that a response can take
+ +
+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::onCommand (Command *  command  )  [inline, virtual]
+
+
+ +

+This is called in the context of the nested transport's reading thread. In the case of a response object, updates the request map and notifies those waiting on the response. Non-response messages are just delegated to the command listener.

Parameters:
+ + +
command the received from the nested transport.
+
+ +

+Reimplemented from activemq::transport::TransportFilter. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::oneway (Command *  command  )  throw ( CommandIOException, exceptions::UnsupportedOperationException ) [inline, virtual]
+
+
+ +

+Sends a one-way command. Does not wait for any response from the broker.

Parameters:
+ + +
command the command to be sent.
+
+
Exceptions:
+ + + +
CommandIOException 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 Response* activemq::transport::ResponseCorrelator::request (Command *  command  )  throw ( CommandIOException, exceptions::UnsupportedOperationException ) [inline, virtual]
+
+
+ +

+Sends the given request to the server and waits for the response.

Parameters:
+ + +
command The request to send.
+
+
Returns:
the response from the server. This may be of type ExceptionResponse in the case of a distributed error that occurs at the broker.
+
Exceptions:
+ + +
CommandIOException if an error occurs with the request.
+
+ +

+Reimplemented from activemq::transport::TransportFilter. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::setCommandListener (CommandListener listener  )  [inline, virtual]
+
+
+ +

+Assigns the command listener for non-response commands.

Parameters:
+ + +
listener the listener.
+
+ +

+Reimplemented from activemq::transport::TransportFilter. +

+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::setMaxResponseWaitTime (const unsigned long  milliseconds  )  [inline, virtual]
+
+
+ +

+Sets the maximum wait time for a response in milliseconds.

Parameters:
+ + +
milliseconds the max time that a response can take.
+
+ +
+

+ +

+
+ + + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::setTransportExceptionListener (TransportExceptionListener listener  )  [inline, virtual]
+
+
+ +

+Sets the observer of asynchronous exceptions from this transport.

Parameters:
+ + +
listener the listener of transport exceptions.
+
+ +

+Reimplemented from activemq::transport::TransportFilter. +

+

+ +

+
+ + + + + + + + +
virtual void activemq::transport::ResponseCorrelator::start (  )  throw ( cms::CMSException ) [inline, virtual]
+
+
+ +

+Starts this transport object and creates the thread for polling on the input stream for commands. If this object has been closed, throws an exception. Before calling start, the caller must set the IO streams and the reader and writer objects.

Exceptions:
+ + +
CMSException if an error occurs or if this transport has already been closed.
+
+ +

+We're already started. +

+Reimplemented from activemq::transport::TransportFilter. +

+

+


The documentation for this class was generated from the following file: +
Generated on Tue Aug 1 09:18:15 2006 for activemq-cpp by  + +doxygen 1.4.7
+ + Added: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.png URL: http://svn.apache.org/viewvc/incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.png?rev=428212&view=auto ============================================================================== Binary file - no diff available. Propchange: incubator/activemq/site/cms/html/classactivemq_1_1transport_1_1_response_correlator.png ------------------------------------------------------------------------------ svn:mime-type = application/octet-stream