activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r959111 [1/2] - in /activemq/activemq-cpp/trunk/activemq-cpp/src/main: activemq/transport/ activemq/transport/correlator/ activemq/transport/failover/ activemq/transport/inactivity/ activemq/transport/logging/ activemq/transport/mock/ activ...
Date Tue, 29 Jun 2010 21:26:08 GMT
Author: tabish
Date: Tue Jun 29 21:26:06 2010
New Revision: 959111

URL: http://svn.apache.org/viewvc?rev=959111&view=rev
Log:
Remove throw specifier from the classes in the library

Modified:
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/DefaultTransportListener.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/Transport.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFactory.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportListener.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/InternalCommandListener.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransportFactory.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransportFactory.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/Closeable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/io/Flushable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/Appendable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/CharSequence.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/Number.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/Readable.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/String.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/lang/String.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/Date.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/Properties.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/Properties.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/StringTokenizer.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/StringTokenizer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/Timer.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/Timer.h
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/UUID.cpp
    activemq/activemq-cpp/trunk/activemq-cpp/src/main/decaf/util/UUID.h

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.cpp Tue Jun 29 21:26:06 2010
@@ -38,8 +38,7 @@ using namespace decaf::util;
 
 ////////////////////////////////////////////////////////////////////////////////
 Pointer<WireFormat> AbstractTransportFactory::createWireFormat(
-    const decaf::util::Properties& properties )
-        throw( decaf::lang::exceptions::NoSuchElementException ) {
+    const decaf::util::Properties& properties ) {
 
     try{
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/AbstractTransportFactory.h Tue Jun 29 21:26:06 2010
@@ -57,8 +57,7 @@ namespace transport {
          * @throws NoSuchElementException if the configured WireFormat is not found.
          */
         virtual Pointer<wireformat::WireFormat> createWireFormat(
-            const decaf::util::Properties& properties )
-                throw( decaf::lang::exceptions::NoSuchElementException );
+            const decaf::util::Properties& properties );
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/DefaultTransportListener.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/DefaultTransportListener.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/DefaultTransportListener.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/DefaultTransportListener.h Tue Jun 29 21:26:06 2010
@@ -29,6 +29,10 @@ namespace transport {
     using decaf::lang::Pointer;
     using activemq::commands::Command;
 
+    /**
+     * A Utility class that create empty implementations for the TransportListener interface
+     * so that a subclass only needs to override the one's its interested.
+     */
     class AMQCPP_API DefaultTransportListener : public TransportListener {
     public:
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.cpp Tue Jun 29 21:26:06 2010
@@ -94,8 +94,7 @@ void IOTransport::fire( const Pointer<Co
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void IOTransport::oneway( const Pointer<Command>& command )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ) {
+void IOTransport::oneway( const Pointer<Command>& command ) {
 
     try{
 
@@ -137,7 +136,7 @@ void IOTransport::oneway( const Pointer<
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void IOTransport::start() throw( decaf::io::IOException ){
+void IOTransport::start() {
 
     try{
 
@@ -171,7 +170,7 @@ void IOTransport::start() throw( decaf::
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void IOTransport::stop() throw( decaf::io::IOException ){
+void IOTransport::stop() {
 
     try{
     }
@@ -181,7 +180,7 @@ void IOTransport::stop() throw( decaf::i
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void IOTransport::close() throw( decaf::io::IOException ){
+void IOTransport::close() {
 
     try{
 
@@ -223,7 +222,7 @@ void IOTransport::close() throw( decaf::
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void IOTransport::run(){
+void IOTransport::run() {
 
     try{
 
@@ -258,8 +257,7 @@ void IOTransport::run(){
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> IOTransport::request( const Pointer<Command>& command AMQCPP_UNUSED )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ){
+Pointer<Response> IOTransport::request( const Pointer<Command>& command AMQCPP_UNUSED ) {
 
     throw decaf::lang::exceptions::UnsupportedOperationException(
         __FILE__, __LINE__,
@@ -267,8 +265,7 @@ Pointer<Response> IOTransport::request( 
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> IOTransport::request( const Pointer<Command>& command AMQCPP_UNUSED, unsigned int timeout AMQCPP_UNUSED )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ){
+Pointer<Response> IOTransport::request( const Pointer<Command>& command AMQCPP_UNUSED, unsigned int timeout AMQCPP_UNUSED ) {
 
     throw decaf::lang::exceptions::UnsupportedOperationException(
         __FILE__, __LINE__,

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/IOTransport.h Tue Jun 29 21:26:06 2010
@@ -113,6 +113,7 @@ namespace transport{
         /**
          * Create an instance of this Transport and assign its WireFormat instance
          * at creation time.
+         *
          * @param wireFormat
          *        Data encoder / decoder to use when reading and writing.
          */
@@ -121,119 +122,61 @@ namespace transport{
         virtual ~IOTransport();
 
         /**
-         * Sends a one-way command.  Does not wait for any response from the
-         * broker.
-         * @param command the command to be sent.
-         * @throws IOException if an exception occurs during writing of
-         * the command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
+         * Sets the stream from which this Transport implementation will read its data.
+         *
+         * @param is
+         *      The InputStream that will be read from by this object.
          */
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException );
+        virtual void setInputStream( decaf::io::DataInputStream* is ) {
+            this->inputStream = is;
+        }
 
         /**
-         * Not supported by this class - throws an exception.
-         * @param command the command to be sent.
-         * @returns the response to the command sent.
-         * @throws UnsupportedOperationException.
+         * Sets the stream to which this Transport implementation will write its data.
+         *
+         * @param os
+         *      The OuputStream that will be written to by this object.
          */
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException );
+        virtual void setOutputStream( decaf::io::DataOutputStream* os ) {
+            this->outputStream = os;
+        }
+
+    public:  //Transport methods
+
+        virtual void oneway( const Pointer<Command>& command );
 
         /**
-         * Not supported by this class - throws an exception.
-         * @param command the command to be sent.
-         * @param timeout the time to wait for a response.
-         * @returns the response to the command sent.
-         * @throws UnsupportedOperationException.
+         * {@inheritDoc}
+         *
+         * This method always thrown an UnsupportedOperationException.
          */
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException );
+        virtual Pointer<Response> request( const Pointer<Command>& command );
 
         /**
-         * Sets the WireFormat instance to use.
+         * {@inheritDoc}
          *
-         * @param wireFormat
-         *      The WireFormat the object used to encode / decode commands.
+         * This method always thrown an UnsupportedOperationException.
          */
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout );
+
         virtual void setWireFormat( const Pointer<wireformat::WireFormat>& wireFormat ){
             this->wireFormat = wireFormat;
         }
 
-        /**
-         * Sets the observer of asynchronous exceptions from this transport.
-         * @param listener the listener of transport events.
-         */
         virtual void setTransportListener( TransportListener* listener ){
             this->listener = listener;
         }
 
-        /**
-         * Gets the observer of asynchronous exceptions from this transport.
-         * @return The listener of transport events.
-         */
         virtual TransportListener* getTransportListener() const {
             return this->listener;
         }
 
-        /**
-         * Sets the input stream for in-coming commands.
-         * @param is The input stream.
-         */
-        virtual void setInputStream( decaf::io::DataInputStream* is ){
-            this->inputStream = is;
-        }
-
-        /**
-         * Sets the output stream for out-going commands.
-         * @param os The output stream.
-         */
-        virtual void setOutputStream( decaf::io::DataOutputStream* os ){
-            this->outputStream = os;
-        }
-
-        /**
-         * 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.
-         * @throws CMSException if an error occurs or if this transport
-         * has already been closed.
-         */
-        virtual void start() throw( decaf::io::IOException );
-
-        /**
-         * Stops the Transport, terminating any threads and stopping all read
-         * and write operations.
-         *
-         * @throw IOException if an error occurs while stopping the Transport.
-         */
-        virtual void stop() throw( decaf::io::IOException );
+        virtual void start();
 
-        /**
-         * 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.
-         * @throws IOException if errors occur.
-         */
-        virtual void close() throw( decaf::io::IOException );
+        virtual void stop();
 
-        /**
-         * Runs the polling thread.
-         */
-        virtual void run();
+        virtual void close();
 
-        /**
-         * Narrows down a Chain of Transports to a specific Transport to allow a
-         * higher level transport to skip intermediate Transports in certain
-         * circumstances.
-         *
-         * @param typeId - The type_info of the Object we are searching for.
-         *
-         * @return the requested Object. or NULL if its not in this chain.
-         */
         virtual Transport* narrow( const std::type_info& typeId ) {
             if( typeid( *this ) == typeId ) {
                 return this;
@@ -242,48 +185,35 @@ namespace transport{
             return NULL;
         }
 
-        /**
-         * Is this Transport fault tolerant, meaning that it will reconnect to
-         * a broker on disconnect.
-         *
-         * @returns true if the Transport is fault tolerant.
-         */
         virtual bool isFaultTolerant() const {
             return false;
         }
 
-        /**
-         * Is the Transport Connected to its Broker.
-         *
-         * @returns true if a connection has been made.
-         */
         virtual bool isConnected() const {
             return !this->closed;
         }
 
-        /**
-         * Has the Transport been shutdown and no longer usable.
-         *
-         * @returns true if the Transport
-         */
         virtual bool isClosed() const {
             return this->closed;
         }
 
-        /**
-         * @return the remote address for this connection
-         */
         virtual std::string getRemoteAddress() const {
             return "";
         }
 
         /**
-         * reconnect to another location
-         * @param uri
-         * @throws IOException on failure of if not supported
+         * {@inheritDoc}
+         *
+         * This method does nothing in this subclass.
          */
-        virtual void reconnect( const decaf::net::URI& uri AMQCPP_UNUSED )
-            throw( decaf::io::IOException ) {}
+        virtual void reconnect( const decaf::net::URI& uri AMQCPP_UNUSED ) {}
+
+    public:  // Runnable methods.
+
+        /**
+         * Runs the polling thread.
+         */
+        virtual void run();
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/Transport.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/Transport.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/Transport.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/Transport.h Tue Jun 29 21:26:06 2010
@@ -64,54 +64,56 @@ namespace transport{
          *
          * @throw IOException if and error occurs while starting the Transport.
          */
-        virtual void start() throw( decaf::io::IOException ) = 0;
+        virtual void start() = 0;
 
         /**
          * Stops the Transport.
          *
          * @throw IOException if an error occurs while stopping the transport.
          */
-        virtual void stop() throw( decaf::io::IOException ) = 0;
+        virtual void stop() = 0;
 
         /**
          * Sends a one-way command.  Does not wait for any response from the
          * broker.
-         * @param command the command to be sent.
-         * @throws IOException if an exception occurs during writing of
-         * the command.
+         *
+         * @param command
+         *      The command to be sent.
+         *
+         * @throws IOException if an exception occurs during writing of the command.
          * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
+         *         by this transport.
          */
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException ) = 0;
+        virtual void oneway( const Pointer<Command>& command ) = 0;
 
         /**
          * Sends the given command to the broker and then waits for the response.
+         *
          * @param command the command to be sent.
+         *
          * @return the response from the broker.
-         * @throws IOException if an exception occurs during the read of the
-         * command.
+         *
+         * @throws IOException if an exception occurs during the read of the command.
          * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
+         *         by this transport.
          */
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException ) = 0;
+        virtual Pointer<Response> request( const Pointer<Command>& command ) = 0;
 
         /**
          * Sends the given command to the broker and then waits for the response.
-         * @param command - The command to be sent.
-         * @param timeout - The time to wait for this response.
+         *
+         * @param command
+         *      The command to be sent.
+         * @param timeout
+         *      The time to wait for this response.
+         *
          * @return the response from the broker.
-         * @throws IOException if an exception occurs during the read of the
-         * command.
+         *
+         * @throws IOException if an exception occurs during the read of the command.
          * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
+         *         by this transport.
          */
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException ) = 0;
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout ) = 0;
 
         /**
          * Sets the WireFormat instance to use.
@@ -172,11 +174,13 @@ namespace transport{
 
         /**
          * reconnect to another location
+         *
          * @param uri
-         * @throws IOException on failure of if not supported
+         *      The new URI to connect this Transport to.
+         *
+         * @throws IOException on failure or if reconnect is not supported.
          */
-        virtual void reconnect( const decaf::net::URI& uri )
-            throw( decaf::io::IOException ) = 0;
+        virtual void reconnect( const decaf::net::URI& uri ) = 0;
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFactory.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFactory.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFactory.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFactory.h Tue Jun 29 21:26:06 2010
@@ -50,8 +50,7 @@ namespace transport{
          * @param location - URI location to connect to plus any properties to assign.
          * @throws ActiveMQexception if an error occurs
          */
-        virtual Pointer<Transport> create( const decaf::net::URI& location )
-            throw ( exceptions::ActiveMQException ) = 0;
+        virtual Pointer<Transport> create( const decaf::net::URI& location ) = 0;
 
         /**
          * Creates a slimed down Transport instance which can be used in composite
@@ -59,8 +58,7 @@ namespace transport{
          * @param location - URI location to connect to plus any properties to assign.
          * @throws ActiveMQexception if an error occurs
          */
-        virtual Pointer<Transport> createComposite( const decaf::net::URI& location )
-            throw ( exceptions::ActiveMQException ) = 0;
+        virtual Pointer<Transport> createComposite( const decaf::net::URI& location ) = 0;
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.cpp Tue Jun 29 21:26:06 2010
@@ -32,6 +32,11 @@ TransportFilter::TransportFilter( const 
 }
 
 ////////////////////////////////////////////////////////////////////////////////
+TransportFilter::~TransportFilter() {
+
+}
+
+////////////////////////////////////////////////////////////////////////////////
 void TransportFilter::onCommand( const Pointer<Command>& command ){
     fire( command );
 }
@@ -42,7 +47,7 @@ void TransportFilter::onException( const
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportFilter::fire( const decaf::lang::Exception& ex ){
+void TransportFilter::fire( const decaf::lang::Exception& ex ) {
 
     if( listener != NULL ){
         try{
@@ -52,7 +57,7 @@ void TransportFilter::fire( const decaf:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportFilter::fire( const Pointer<Command>& command ){
+void TransportFilter::fire( const Pointer<Command>& command ) {
     try{
         if( listener != NULL ){
             listener->onCommand( command );
@@ -79,7 +84,7 @@ void TransportFilter::transportResumed()
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportFilter::start() throw( decaf::io::IOException ) {
+void TransportFilter::start() {
 
     if( listener == NULL ){
         throw decaf::io::IOException( __FILE__, __LINE__, "exceptionListener is invalid" );
@@ -90,12 +95,12 @@ void TransportFilter::start() throw( dec
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportFilter::stop() throw( decaf::io::IOException ) {
+void TransportFilter::stop() {
     next->stop();
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportFilter::close() throw( decaf::io::IOException ) {
+void TransportFilter::close() {
 
     if( next != NULL ) {
         next->close();
@@ -115,8 +120,7 @@ Transport* TransportFilter::narrow( cons
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportFilter::reconnect( const decaf::net::URI& uri )
-    throw( decaf::io::IOException ) {
+void TransportFilter::reconnect( const decaf::net::URI& uri ) {
 
     try{
         next->reconnect( uri );

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportFilter.h Tue Jun 29 21:26:06 2010
@@ -80,7 +80,9 @@ namespace transport{
          */
         TransportFilter( const Pointer<Transport>& next );
 
-        virtual ~TransportFilter() {}
+        virtual ~TransportFilter();
+
+    public:  // TransportListener methods
 
         /**
          * Event handler for the receipt of a command.
@@ -105,151 +107,57 @@ namespace transport{
          */
         virtual void transportResumed();
 
-        /**
-         * Sends a one-way command.  Does not wait for any response from the
-         * broker.
-         * @param command the command to be sent.
-         * @throws IOException if an exception occurs during writing of
-         * the command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
-         */
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException ){
+    public:  // Transport Methods.
 
+        virtual void oneway( const Pointer<Command>& command ) {
             next->oneway( command );
         }
 
-        /**
-         * Not supported by this class - throws an exception.
-         * @param command the command that is sent as a request
-         * @throws IOException
-         * @throws UnsupportedOperationException.
-         */
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException ){
-
+        virtual Pointer<Response> request( const Pointer<Command>& command ) {
             return next->request( command );
         }
 
-        /**
-         * Not supported by this class - throws an exception.
-         * @param command - The command that is sent as a request
-         * @param timeout - The the time to wait for a response.
-         * @throws IOException
-         * @throws UnsupportedOperationException.
-         */
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException ){
-
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout ) {
             return next->request( command, timeout );
         }
 
-        /**
-         * Sets the observer of asynchronous exceptions from this transport.
-         * @param listener the listener of transport events.
-         */
-        virtual void setTransportListener( TransportListener* listener ){
+        virtual void setTransportListener( TransportListener* listener ) {
             this->listener = listener;
         }
 
-        /**
-         * Gets the observer of asynchronous exceptions from this transport.
-         * @return The listener of transport events.
-         */
         virtual TransportListener* getTransportListener() const {
             return this->listener;
         }
 
-        /**
-         * Sets the WireFormat instance to use.
-         * @param wireFormat
-         *      The WireFormat the object used to encode / decode commands.
-         */
         virtual void setWireFormat( const Pointer<wireformat::WireFormat>& wireFormat ) {
             next->setWireFormat( wireFormat );
         }
 
-        /**
-         * 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.
-         * @throws IOException if an error occurs or if this transport
-         * has already been closed.
-         */
-        virtual void start() throw( decaf::io::IOException );
+        virtual void start();
 
-        /**
-         * Stops the Transport.
-         *
-         * @throws IOException if an error occurs while stopping the Transport.
-         */
-        virtual void stop() throw( decaf::io::IOException );
+        virtual void stop();
 
-        /**
-         * 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.
-         *
-         * @throws IOException if an error occurs while closing the Transport.
-         */
-        virtual void close() throw( decaf::io::IOException );
+        virtual void close();
 
-        /**
-         * Narrows down a Chain of Transports to a specific Transport to allow a
-         * higher level transport to skip intermediate Transports in certain
-         * circumstances.
-         *
-         * @param typeId - The type_info of the Object we are searching for.
-         *
-         * @return the requested Object. or NULL if its not in this chain.
-         */
         virtual Transport* narrow( const std::type_info& typeId );
 
-        /**
-         * Is this Transport fault tolerant, meaning that it will reconnect to
-         * a broker on disconnect.
-         *
-         * @returns true if the Transport is fault tolerant.
-         */
         virtual bool isFaultTolerant() const {
             return next->isFaultTolerant();
         }
 
-        /**
-         * Is the Transport Connected to its Broker.
-         *
-         * @returns true if a connection has been made.
-         */
         virtual bool isConnected() const {
             return next->isConnected();
         }
 
-        /**
-         * Has the Transport been shutdown and no longer usable.
-         *
-         * @returns true if the Transport
-         */
         virtual bool isClosed() const {
             return next->isClosed();
         }
 
-        /**
-         * @return the remote address for this connection
-         */
         virtual std::string getRemoteAddress() const {
             return next->getRemoteAddress();
         }
 
-        /**
-         * reconnect to another location
-         * @param uri
-         * @throws IOException on failure of if not supported
-         */
-        virtual void reconnect( const decaf::net::URI& uri )
-            throw( decaf::io::IOException );
+        virtual void reconnect( const decaf::net::URI& uri );
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportListener.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportListener.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportListener.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportListener.h Tue Jun 29 21:26:06 2010
@@ -46,7 +46,8 @@ namespace transport{
          * the Object.  If there is no registered listener the Transport deletes
          * the command upon receipt.
          *
-         * @param command the received command object.
+         * @param command
+         *      The received command object.
          */
         virtual void onCommand( const Pointer<Command>& command ) = 0;
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.cpp Tue Jun 29 21:26:06 2010
@@ -43,8 +43,7 @@ TransportRegistry::~TransportRegistry() 
  }
 
 ////////////////////////////////////////////////////////////////////////////////
-TransportFactory* TransportRegistry::findFactory( const std::string& name ) const
-    throw( decaf::lang::exceptions::NoSuchElementException ) {
+TransportFactory* TransportRegistry::findFactory( const std::string& name ) const {
 
     if( !this->registry.containsKey( name ) ) {
         throw NoSuchElementException( __FILE__, __LINE__,
@@ -55,9 +54,7 @@ TransportFactory* TransportRegistry::fin
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TransportRegistry::registerFactory( const std::string& name, TransportFactory* factory )
-    throw( decaf::lang::exceptions::IllegalArgumentException,
-           decaf::lang::exceptions::NullPointerException ) {
+void TransportRegistry::registerFactory( const std::string& name, TransportFactory* factory ) {
 
     if( name == "" ) {
         throw IllegalArgumentException( __FILE__, __LINE__,

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/TransportRegistry.h Tue Jun 29 21:26:06 2010
@@ -71,8 +71,7 @@ namespace transport {
          *
          * @throws NoSuchElementException if no factory is registered with that name.
          */
-        TransportFactory* findFactory( const std::string& name ) const
-            throw( decaf::lang::exceptions::NoSuchElementException );
+        TransportFactory* findFactory( const std::string& name ) const;
 
         /**
          * Registers a new TransportFactory with this Registry.  If a Factory with the
@@ -88,9 +87,7 @@ namespace transport {
          * @throws IllegalArgumentException is name is the empty string.
          * @throws NullPointerException if the Factory is Null.
          */
-        void registerFactory( const std::string& name, TransportFactory* factory )
-            throw( decaf::lang::exceptions::IllegalArgumentException,
-                   decaf::lang::exceptions::NullPointerException );
+        void registerFactory( const std::string& name, TransportFactory* factory );
 
         /**
          * Unregisters the Factory with the given name and deletes that instance of the

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.cpp Tue Jun 29 21:26:06 2010
@@ -67,8 +67,7 @@ ResponseCorrelator::~ResponseCorrelator(
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void ResponseCorrelator::oneway( const Pointer<Command>& command )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ) {
+void ResponseCorrelator::oneway( const Pointer<Command>& command ) {
 
     try{
         command->setCommandId( nextCommandId.getAndIncrement() );
@@ -89,8 +88,7 @@ void ResponseCorrelator::oneway( const P
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> ResponseCorrelator::request( const Pointer<Command>& command )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ) {
+Pointer<Response> ResponseCorrelator::request( const Pointer<Command>& command ) {
 
     try{
 
@@ -135,8 +133,7 @@ Pointer<Response> ResponseCorrelator::re
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> ResponseCorrelator::request( const Pointer<Command>& command, unsigned int timeout )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ) {
+Pointer<Response> ResponseCorrelator::request( const Pointer<Command>& command, unsigned int timeout ) {
 
     try{
         command->setCommandId( nextCommandId.getAndIncrement() );
@@ -217,7 +214,7 @@ void ResponseCorrelator::onCommand( cons
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void ResponseCorrelator::start() throw( decaf::io::IOException ) {
+void ResponseCorrelator::start() {
 
     try{
 
@@ -248,7 +245,7 @@ void ResponseCorrelator::start() throw( 
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void ResponseCorrelator::close() throw( decaf::io::IOException ){
+void ResponseCorrelator::close() {
 
     try{
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/correlator/ResponseCorrelator.h Tue Jun 29 21:26:06 2010
@@ -76,39 +76,17 @@ namespace correlator{
 
         virtual ~ResponseCorrelator();
 
-        /**
-         * Sends a one-way command.  Does not wait for any response from the
-         * broker.
-         * @param command the command to be sent.
-         * @throws IOException if an exception occurs during writing of
-         * the command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
-         */
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+    public:  // Transport Methods
 
-        /**
-         * Sends the given request to the server and waits for the response.
-         * @param command The request to send.
-         * @return the response from the server.
-         * @throws IOException if an error occurs with the request.
-         */
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual void oneway( const Pointer<Command>& command );
 
-        /**
-         * Sends the given request to the server and waits for the response.
-         * @param command The request to send.
-         * @param timeout The time to wait for a response.
-         * @return the response from the server.
-         * @throws IOException if an error occurs with the request.
-         */
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual Pointer<Response> request( const Pointer<Command>& command );
+
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout );
+
+        virtual void start();
+
+        virtual void close();
 
         /**
          * This is called in the context of the nested transport's
@@ -116,36 +94,21 @@ namespace correlator{
          * updates the request map and notifies those waiting on the
          * response.  Non-response messages are just delegated to
          * the command listener.
-         * @param command the received from the nested transport.
+         *
+         * @param command
+         *      The received from the nested transport.
          */
         virtual void onCommand( const Pointer<Command>& command );
 
         /**
-         * 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.
-         * @throws IOException if an error occurs or if this transport
-         * has already been closed.
-         */
-        virtual void start() throw( decaf::io::IOException );
-
-        /**
-         * 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.
-         * @throws IOException if errors occur.
-         */
-        virtual void close() throw( decaf::io::IOException );
-
-        /**
          * Event handler for an exception from a command transport.
-         * @param source The source of the exception
-         * @param ex The exception.
+         *
+         * @param source
+         *      The source of the exception.
+         * @param ex
+         *      The exception that was caught.
          */
-        virtual void onTransportException( Transport* source,
-                                           const decaf::lang::Exception& ex );
+        virtual void onTransportException( Transport* source, const decaf::lang::Exception& ex );
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.cpp Tue Jun 29 21:26:06 2010
@@ -134,8 +134,7 @@ void FailoverTransport::removeURI( const
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::reconnect( const decaf::net::URI& uri )
-    throw( decaf::io::IOException ) {
+void FailoverTransport::reconnect( const decaf::net::URI& uri ) {
 
     try {
 
@@ -176,8 +175,7 @@ std::string FailoverTransport::getRemote
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::oneway( const Pointer<Command>& command )
-    throw( IOException, decaf::lang::exceptions::UnsupportedOperationException ) {
+void FailoverTransport::oneway( const Pointer<Command>& command ) {
 
     Pointer<Exception> error;
 
@@ -303,9 +301,7 @@ void FailoverTransport::oneway( const Po
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> FailoverTransport::request( const Pointer<Command>& command AMQCPP_UNUSED )
-    throw( IOException,
-           decaf::lang::exceptions::UnsupportedOperationException ) {
+Pointer<Response> FailoverTransport::request( const Pointer<Command>& command AMQCPP_UNUSED ) {
 
     throw decaf::lang::exceptions::UnsupportedOperationException(
         __FILE__, __LINE__, "FailoverTransport::request - Not Supported" );
@@ -313,16 +309,14 @@ Pointer<Response> FailoverTransport::req
 
 ////////////////////////////////////////////////////////////////////////////////
 Pointer<Response> FailoverTransport::request( const Pointer<Command>& command AMQCPP_UNUSED,
-                                                unsigned int timeout AMQCPP_UNUSED )
-    throw( IOException,
-           decaf::lang::exceptions::UnsupportedOperationException ) {
+                                                unsigned int timeout AMQCPP_UNUSED ) {
 
     throw decaf::lang::exceptions::UnsupportedOperationException(
         __FILE__, __LINE__, "FailoverTransport::request - Not Supported" );
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::start() throw( IOException ) {
+void FailoverTransport::start() {
 
     try{
 
@@ -351,7 +345,7 @@ void FailoverTransport::start() throw( I
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::stop() throw( IOException ) {
+void FailoverTransport::stop() {
 
     try{
     }
@@ -361,7 +355,7 @@ void FailoverTransport::stop() throw( IO
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::close() throw( IOException ) {
+void FailoverTransport::close() {
 
     try{
 
@@ -412,8 +406,7 @@ void FailoverTransport::reconnect() {
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::restoreTransport( const Pointer<Transport>& transport )
-    throw( IOException ) {
+void FailoverTransport::restoreTransport( const Pointer<Transport>& transport ) {
 
     try{
 
@@ -441,8 +434,7 @@ void FailoverTransport::restoreTransport
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void FailoverTransport::handleTransportFailure( const decaf::lang::Exception& error AMQCPP_UNUSED )
-    throw( decaf::lang::Exception ) {
+void FailoverTransport::handleTransportFailure( const decaf::lang::Exception& error AMQCPP_UNUSED ) {
 
     Pointer<Transport> transport;
     synchronized( &reconnectMutex ) {
@@ -702,8 +694,7 @@ bool FailoverTransport::iterate() {
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Transport> FailoverTransport::createTransport( const URI& location ) const
-    throw ( decaf::io::IOException ) {
+Pointer<Transport> FailoverTransport::createTransport( const URI& location ) const {
 
     try{
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransport.h Tue Jun 29 21:26:06 2010
@@ -143,144 +143,44 @@ namespace failover {
 
     public: // Transport Members
 
-        /**
-         * 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.
-         * @throws IOException if an error occurs or if this transport
-         * has already been closed.
-         */
-        virtual void start() throw( decaf::io::IOException );
+        virtual void start();
 
-        /**
-         * Stop the Transport.
-         *
-         * @throws IOException if an error occurs while stopping the Transport.
-         */
-        virtual void stop() throw( decaf::io::IOException );
+        virtual void stop();
 
-        /**
-         * 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.
-         * @throws IOException if errors occur.
-         */
-        virtual void close() throw( decaf::io::IOException );
+        virtual void close();
 
-        /**
-         * Sends a one-way command.  Does not wait for any response from the
-         * broker.
-         * @param command the command to be sent.
-         * @throws IOException if an exception occurs during writing of
-         * the command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
-         */
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual void oneway( const Pointer<Command>& command );
 
-        /**
-         * Sends the given command to the broker and then waits for the response.
-         * @param command the command to be sent.
-         * @return the response from the broker.
-         * @throws IOException if an exception occurs during the read of the
-         * command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
-         */
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual Pointer<Response> request( const Pointer<Command>& command );
 
-        /**
-         * Sends the given command to the broker and then waits for the response.
-         * @param command - The command to be sent.
-         * @param timeout - The time to wait for this response.
-         * @return the response from the broker.
-         * @throws IOException if an exception occurs during the read of the
-         * command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
-         */
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout );
 
-        /**
-         * Sets the WireFormat instance to use.
-         * @param wireFormat
-         *      The WireFormat the object used to encode / decode commands.
-         */
         virtual void setWireFormat( const Pointer<wireformat::WireFormat>& wireFormat AMQCPP_UNUSED ) {}
 
-        /**
-         * Sets the observer of asynchronous events from this transport.
-         * @param listener the listener of transport events.
-         */
         virtual void setTransportListener( TransportListener* listener );
 
-        /**
-         * Gets the observer of asynchronous exceptions from this transport.
-         * @return The listener of transport events.
-         */
         virtual TransportListener* getTransportListener() const;
 
-        /**
-         * Is this Transport fault tolerant, meaning that it will reconnect to
-         * a broker on disconnect.
-         *
-         * @returns true if the Transport is fault tolerant.
-         */
         virtual bool isFaultTolerant() const {
             return true;
         }
 
-        /**
-         * Is the Transport Connected to its Broker.
-         *
-         * @returns true if a connection has been made.
-         */
         virtual bool isConnected() const {
             return this->connected;
         }
 
-        /**
-         * Has the Transport been shutdown and no longer usable.
-         *
-         * @returns true if the Transport
-         */
         virtual bool isClosed() const {
             return this->closed;
         }
 
-        /**
-         * Returns true if the Transport has been initialized by a BrokerInfo command.
-         * @return true if the Transport has been initialized by a BrokerInfo command.
-         */
         bool isInitialized() const {
             return this->initialized;
         }
 
-        /**
-         * Sets the initialized state of this Transport to true.
-         * @param value - true if this Transport has been initialized.
-         */
         void setInitialized( bool value ) {
             this->initialized = value;
         }
 
-        /**
-         * Narrows down a Chain of Transports to a specific Transport to allow a
-         * higher level transport to skip intermediate Transports in certain
-         * circumstances.
-         *
-         * @param typeId - The type_info of the Object we are searching for.
-         *
-         * @return the requested Object. or NULL if its not in this chain.
-         */
         virtual Transport* narrow( const std::type_info& typeId ) {
             if( typeid( *this ) == typeId ) {
                 return this;
@@ -293,11 +193,12 @@ namespace failover {
             return NULL;
         }
 
-        /**
-         * @return the remote address for this connection
-         */
         virtual std::string getRemoteAddress() const;
 
+        virtual void reconnect( const decaf::net::URI& uri );
+
+    public:  // CompositeTask Methods.
+
         /**
          * @returns true if there is a need for the iterate method to be called by this
          *          classes task runner.
@@ -313,14 +214,6 @@ namespace failover {
          */
         virtual bool iterate();
 
-        /**
-         * reconnect to another location
-         * @param uri
-         * @throws IOException on failure of if not supported
-         */
-        virtual void reconnect( const decaf::net::URI& uri )
-            throw( decaf::io::IOException );
-
     public: // FailoverTransport Property Getters / Setters
 
         long long getTimeout() const {
@@ -448,22 +341,23 @@ namespace failover {
          *
          * @throw IOException if an errors occurs while restoring the old state.
          */
-        void restoreTransport( const Pointer<Transport>& transport )
-            throw( decaf::io::IOException );
+        void restoreTransport( const Pointer<Transport>& transport );
 
         /**
          * Called when this class' TransportListener is notified of a Failure.
          * @param error - The CMS Exception that was thrown.
          * @throw Exception if an error occurs.
          */
-        void handleTransportFailure( const decaf::lang::Exception& error )
-            throw( decaf::lang::Exception );
+        void handleTransportFailure( const decaf::lang::Exception& error );
 
     private:
 
         /**
+         * @param command
+         *      The Command object to check.
+         *
          * @return Returns true if the command is one sent when a connection
-         * is being closed.
+         *         is being closed.
          */
         bool isShutdownCommand( const Pointer<Command>& command ) const;
 
@@ -472,9 +366,10 @@ namespace failover {
          * Transport requested.
          *
          * @param uri - The URI to connect to
+         *
+         * @throw IOException if an I/O error occurs while creating the new Transport.
          */
-        Pointer<Transport> createTransport( const URI& location ) const
-            throw ( decaf::io::IOException );
+        Pointer<Transport> createTransport( const URI& location ) const;
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.cpp Tue Jun 29 21:26:06 2010
@@ -38,8 +38,7 @@ using namespace decaf::util;
 using namespace decaf::lang;
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Transport> FailoverTransportFactory::create( const decaf::net::URI& location )
-throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Transport> FailoverTransportFactory::create( const decaf::net::URI& location ) {
 
     try{
 
@@ -60,8 +59,7 @@ throw ( activemq::exceptions::ActiveMQEx
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Transport> FailoverTransportFactory::createComposite( const decaf::net::URI& location )
-    throw ( activemq::exceptions::ActiveMQException ) {
+Pointer<Transport> FailoverTransportFactory::createComposite( const decaf::net::URI& location ) {
 
     try{
 
@@ -79,8 +77,7 @@ Pointer<Transport> FailoverTransportFact
 ////////////////////////////////////////////////////////////////////////////////
 Pointer<Transport> FailoverTransportFactory::doCreateComposite(
     const decaf::net::URI& location,
-    const decaf::util::Properties& properties )
-        throw ( activemq::exceptions::ActiveMQException ) {
+    const decaf::util::Properties& properties ) {
 
     try {
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/FailoverTransportFactory.h Tue Jun 29 21:26:06 2010
@@ -43,23 +43,9 @@ namespace failover {
 
         virtual ~FailoverTransportFactory() {}
 
-        /**
-         * Creates a fully configured Transport instance which could be a chain
-         * of filters and transports.
-         * @param location - URI location to connect to plus any properties to assign.
-         * @throws ActiveMQexception if an error occurs
-         */
-        virtual Pointer<Transport> create( const decaf::net::URI& location )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Transport> create( const decaf::net::URI& location );
 
-        /**
-         * Creates a slimed down Transport instance which can be used in composite
-         * transport instances.
-         * @param location - URI location to connect to plus any properties to assign.
-         * @throws ActiveMQexception if an error occurs
-         */
-        virtual Pointer<Transport> createComposite( const decaf::net::URI& location )
-            throw ( exceptions::ActiveMQException );
+        virtual Pointer<Transport> createComposite( const decaf::net::URI& location );
 
     protected:
 
@@ -74,8 +60,7 @@ namespace failover {
          * @throws ActiveMQexception if an error occurs
          */
         virtual Pointer<Transport> doCreateComposite( const decaf::net::URI& location,
-                                                      const decaf::util::Properties& properties )
-            throw ( exceptions::ActiveMQException );
+                                                      const decaf::util::Properties& properties );
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.cpp Tue Jun 29 21:26:06 2010
@@ -44,7 +44,7 @@ URIPool::~URIPool() {
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-URI URIPool::getURI() throw ( decaf::lang::exceptions::NoSuchElementException ) {
+URI URIPool::getURI() {
 
     synchronized( &uriPool ) {
         if( !uriPool.isEmpty() ) {

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/failover/URIPool.h Tue Jun 29 21:26:06 2010
@@ -60,9 +60,10 @@ namespace failover {
          * in the future, the caller should react accordingly.
          *
          * @return the next free URI in the Pool.
+         *
          * @throw NoSuchElementException if there are none free currently.
          */
-        URI getURI() throw ( decaf::lang::exceptions::NoSuchElementException );
+        URI getURI();
 
         /**
          * Adds a URI to the free list, callers that have previously taken one using

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp Tue Jun 29 21:26:06 2010
@@ -256,7 +256,7 @@ void InactivityMonitor::setKeepAliveResp
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void InactivityMonitor::close() throw( decaf::io::IOException ) {
+void InactivityMonitor::close() {
     try{
         stopMonitorThreads();
         TransportFilter::close();
@@ -307,8 +307,7 @@ void InactivityMonitor::onCommand( const
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void InactivityMonitor::oneway( const Pointer<Command>& command )
-    throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException ) {
+void InactivityMonitor::oneway( const Pointer<Command>& command ) {
 
     try{
         // Disable inactivity monitoring while processing a command.  Synchronize this

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.h Tue Jun 29 21:26:06 2010
@@ -65,14 +65,17 @@ namespace inactivity {
 
         virtual ~InactivityMonitor();
 
-        virtual void close() throw( decaf::io::IOException );
+    public:  // TransportFilter Methods
+
+        virtual void close();
 
         virtual void onException( const decaf::lang::Exception& ex );
 
         virtual void onCommand( const Pointer<Command>& command );
 
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException );
+        virtual void oneway( const Pointer<Command>& command );
+
+    public:
 
         bool isKeepAliveResponseRequired() const;
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.cpp Tue Jun 29 21:26:06 2010
@@ -41,8 +41,7 @@ void LoggingTransport::onCommand( const 
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void LoggingTransport::oneway( const Pointer<Command>& command )
-    throw(IOException, decaf::lang::exceptions::UnsupportedOperationException) {
+void LoggingTransport::oneway( const Pointer<Command>& command ) {
 
     try {
 
@@ -58,8 +57,7 @@ void LoggingTransport::oneway( const Poi
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> LoggingTransport::request( const Pointer<Command>& command )
-    throw(IOException, decaf::lang::exceptions::UnsupportedOperationException) {
+Pointer<Response> LoggingTransport::request( const Pointer<Command>& command ) {
 
     try {
 
@@ -77,8 +75,7 @@ Pointer<Response> LoggingTransport::requ
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> LoggingTransport::request( const Pointer<Command>& command, unsigned int timeout )
-    throw(IOException, decaf::lang::exceptions::UnsupportedOperationException) {
+Pointer<Response> LoggingTransport::request( const Pointer<Command>& command, unsigned int timeout ) {
 
     try {
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/logging/LoggingTransport.h Tue Jun 29 21:26:06 2010
@@ -42,43 +42,27 @@ namespace logging{
 
         virtual ~LoggingTransport() {}
 
-        /**
-         * Event handler for the receipt of a command.
-         * @param command - the received command object.
-         */
+    public:  // TransportFilter methods.
+
         virtual void onCommand( const Pointer<Command>& command );
 
-        /**
-         * Sends a one-way command.  Does not wait for any response from the
-         * broker.
-         * @param command the command to be sent.
-         * @throws IOException if an exception occurs during writing of
-         * the command.
-         * @throws UnsupportedOperationException if this method is not implemented
-         * by this transport.
-         */
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+    public:  // TransportFilter methods.
+
+        virtual void oneway( const Pointer<Command>& command );
 
         /**
+         * {@inheritDoc}
+         *
          * Not supported by this class - throws an exception.
-         * @param command the command that is sent as a request
-         * @throws UnsupportedOperationException.
          */
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual Pointer<Response> request( const Pointer<Command>& command );
 
         /**
+         * {@inheritDoc}
+         *
          * Not supported by this class - throws an exception.
-         * @param command the command that is sent as a request
-         * @param timeout the time to wait for a response.
-         * @throws UnsupportedOperationException.
          */
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException );
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout );
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/InternalCommandListener.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/InternalCommandListener.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/InternalCommandListener.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/InternalCommandListener.h Tue Jun 29 21:26:06 2010
@@ -58,7 +58,7 @@ namespace mock {
 
         virtual ~InternalCommandListener();
 
-        void setTransport( MockTransport* transport ){
+        void setTransport( MockTransport* transport ) {
             this->transport = transport;
         }
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.cpp Tue Jun 29 21:26:06 2010
@@ -32,7 +32,7 @@ MockTransport* MockTransport::instance =
 
 ////////////////////////////////////////////////////////////////////////////////
 MockTransport::MockTransport( const Pointer<WireFormat>& wireFormat,
-                              const Pointer<ResponseBuilder>& responseBuilder ){
+                              const Pointer<ResponseBuilder>& responseBuilder ) {
 
     this->wireFormat = wireFormat;
     this->outgoingListener = NULL;
@@ -61,9 +61,7 @@ MockTransport::MockTransport( const Poin
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void MockTransport::oneway( const Pointer<Command>& command )
-        throw( IOException,
-               decaf::lang::exceptions::UnsupportedOperationException) {
+void MockTransport::oneway( const Pointer<Command>& command ) {
 
     try{
 
@@ -102,10 +100,8 @@ void MockTransport::oneway( const Pointe
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-Pointer<Response> MockTransport::request( const Pointer<Command>& command )
-    throw( IOException,
-           decaf::lang::exceptions::UnsupportedOperationException)
-{
+Pointer<Response> MockTransport::request( const Pointer<Command>& command ) {
+
     try{
 
         if( responseBuilder != NULL ){
@@ -142,10 +138,7 @@ Pointer<Response> MockTransport::request
 
 ////////////////////////////////////////////////////////////////////////////////
 Pointer<Response> MockTransport::request( const Pointer<Command>& command,
-                                          unsigned int timeout AMQCPP_UNUSED )
-    throw( IOException,
-           decaf::lang::exceptions::UnsupportedOperationException)
-{
+                                          unsigned int timeout AMQCPP_UNUSED ) {
     try{
         return this->request( command );
     }
@@ -157,7 +150,7 @@ Pointer<Response> MockTransport::request
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void MockTransport::start() throw( decaf::io::IOException ) {
+void MockTransport::start() {
 
     if( this->failOnStart ) {
         throw IOException( __FILE__, __LINE__, "Failed to Start MockTransport." );
@@ -165,7 +158,7 @@ void MockTransport::start() throw( decaf
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void MockTransport::stop() throw( decaf::io::IOException ) {
+void MockTransport::stop() {
 
     if( this->failOnStop ) {
         throw IOException( __FILE__, __LINE__, "Failed to Stop MockTransport." );
@@ -173,7 +166,7 @@ void MockTransport::stop() throw( decaf:
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void MockTransport::close() throw( decaf::io::IOException ) {
+void MockTransport::close() {
 
     if( this->failOnClose ) {
         throw IOException( __FILE__, __LINE__, "Failed to Close MockTransport." );

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/mock/MockTransport.h Tue Jun 29 21:26:06 2010
@@ -59,7 +59,7 @@ namespace mock{
      * up to the builder to create appropriate responses and schedule any asynchronous
      * messages that might result from a message sent to the Broker.
      */
-    class AMQCPP_API MockTransport : public Transport{
+    class AMQCPP_API MockTransport : public Transport {
     private:
 
         Pointer<ResponseBuilder> responseBuilder;
@@ -96,6 +96,30 @@ namespace mock{
         }
 
         /**
+         * Fires a Command back through this transport to its registered
+         * CommandListener if there is one.
+         * @param command - Command to send to the Listener.
+         */
+        virtual void fireCommand( const Pointer<Command>& command ){
+            if( listener != NULL ){
+                listener->onCommand( command );
+            }
+        }
+
+        /**
+         * Fires a Exception back through this transport to its registered
+         * ExceptionListener if there is one.
+         *
+         * @param ex
+         *      The Exception that will be passed on the the Transport listener.
+         */
+        virtual void fireException( const exceptions::ActiveMQException& ex ){
+            if( listener != NULL ){
+                listener->onException( ex );
+            }
+        }
+
+        /**
          * 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.
@@ -105,17 +129,6 @@ namespace mock{
             this->responseBuilder = responseBuilder;
         }
 
-        virtual void oneway( const Pointer<Command>& command )
-            throw( decaf::io::IOException, decaf::lang::exceptions::UnsupportedOperationException);
-
-        virtual Pointer<Response> request( const Pointer<Command>& command )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException);
-
-
-        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout )
-            throw( decaf::io::IOException,
-                   decaf::lang::exceptions::UnsupportedOperationException);
 
         /**
          * Sets a Listener that gets notified for every command that would
@@ -128,14 +141,6 @@ namespace mock{
         }
 
         /**
-         * Sets the WireFormat instance to use.
-         *
-         * @param wireFormat
-         *      WireFormat the object used to encode / decode commands.
-         */
-        virtual void setWireFormat( const Pointer<wireformat::WireFormat>& wireFormat AMQCPP_UNUSED ) {}
-
-        /**
          * Gets the currently set WireFormat
          *
          * @return the current WireFormat object.
@@ -144,61 +149,30 @@ namespace mock{
             return this->wireFormat;
         }
 
-        /**
-         * Sets the observer of asynchronous exceptions from this transport.
-         * @param listener the listener of transport events.
-         */
+    public:  // Transport Methods
+
+        virtual void oneway( const Pointer<Command>& command );
+
+        virtual Pointer<Response> request( const Pointer<Command>& command );
+
+        virtual Pointer<Response> request( const Pointer<Command>& command, unsigned int timeout );
+
+        virtual void setWireFormat( const Pointer<wireformat::WireFormat>& wireFormat AMQCPP_UNUSED ) {}
+
         virtual void setTransportListener( TransportListener* listener ){
             this->listener = listener;
         }
 
-        /**
-         * Gets the observer of asynchronous exceptions from this transport.
-         * @return The listener of transport events.
-         */
         virtual TransportListener* getTransportListener() const {
             return this->listener;
         }
 
-        /**
-         * Fires a Command back through this transport to its registered
-         * CommandListener if there is one.
-         * @param command - Command to send to the Listener.
-         */
-        virtual void fireCommand( const Pointer<Command>& command ){
-            if( listener != NULL ){
-                listener->onCommand( command );
-            }
-        }
+        virtual void start();
 
-        /**
-         * Fires a Exception back through this transport to its registered
-         * ExceptionListener if there is one.
-         *
-         * @param ex
-         *      The Exception that will be passed on the the Transport listener.
-         */
-        virtual void fireException( const exceptions::ActiveMQException& ex ){
-            if( listener != NULL ){
-                listener->onException( ex );
-            }
-        }
-
-        virtual void start() throw( decaf::io::IOException );
-
-        virtual void stop() throw( decaf::io::IOException );
+        virtual void stop();
 
-        virtual void close() throw( decaf::io::IOException );
+        virtual void close();
 
-        /**
-         * Narrows down a Chain of Transports to a specific Transport to allow a
-         * higher level transport to skip intermediate Transports in certain
-         * circumstances.
-         *
-         * @param typeId - The type_info of the Object we are searching for.
-         *
-         * @return the requested Object. or NULL if its not in this chain.
-         */
         virtual Transport* narrow( const std::type_info& typeId ) {
             if( typeid( *this ) == typeId ) {
                 return this;
@@ -207,48 +181,23 @@ namespace mock{
             return NULL;
         }
 
-        /**
-         * Is this Transport fault tolerant, meaning that it will reconnect to
-         * a broker on disconnect.
-         *
-         * @returns true if the Transport is fault tolerant.
-         */
         virtual bool isFaultTolerant() const {
             return false;
         }
 
-        /**
-         * Is the Transport Connected to its Broker.
-         *
-         * @returns true if a connection has been made.
-         */
         virtual bool isConnected() const {
             return true;
         }
 
-        /**
-         * Has the Transport been shutdown and no longer usable.
-         *
-         * @returns true if the Transport
-         */
         virtual bool isClosed() const {
             return false;
         }
 
-        /**
-         * @return the remote address for this connection
-         */
         virtual std::string getRemoteAddress() const {
             return "";
         }
 
-        /**
-         * reconnect to another location
-         * @param uri
-         * @throws IOException on failure of if not supported
-         */
-        virtual void reconnect( const decaf::net::URI& uri AMQCPP_UNUSED )
-            throw( decaf::io::IOException ) {}
+        virtual void reconnect( const decaf::net::URI& uri AMQCPP_UNUSED ) {}
 
     public:  // Property Getters and Setters
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.cpp Tue Jun 29 21:26:06 2010
@@ -46,8 +46,7 @@ SslTransportFactory::~SslTransportFactor
 ////////////////////////////////////////////////////////////////////////////////
 Pointer<Transport> SslTransportFactory::doCreateComposite( const decaf::net::URI& location,
                                                            const Pointer<wireformat::WireFormat>& wireFormat,
-                                                           const decaf::util::Properties& properties )
-    throw ( ActiveMQException ) {
+                                                           const decaf::util::Properties& properties ) {
 
     try {
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.h
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.h?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.h (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/SslTransportFactory.h Tue Jun 29 21:26:06 2010
@@ -35,21 +35,9 @@ namespace tcp {
 
     protected:
 
-        /**
-         * Creates a slimed down Transport instance which can be used in composite
-         * transport instances.
-         *
-         * @param location - URI location to connect to.
-         * @param wireFormat - the assigned WireFormat for the new Transport.
-         * @param properties - Properties to apply to the transport.
-         *
-         * @return new Pointer to a SslTransport.
-         * @throws ActiveMQexception if an error occurs
-         */
         virtual Pointer<Transport> doCreateComposite( const decaf::net::URI& location,
                                                       const Pointer<wireformat::WireFormat>& wireFormat,
-                                                      const decaf::util::Properties& properties )
-            throw ( exceptions::ActiveMQException );
+                                                      const decaf::util::Properties& properties );
 
     };
 

Modified: activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp
URL: http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp?rev=959111&r1=959110&r2=959111&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp (original)
+++ activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/tcp/TcpTransport.cpp Tue Jun 29 21:26:06 2010
@@ -59,7 +59,7 @@ TcpTransport::~TcpTransport() {
 }
 
 ////////////////////////////////////////////////////////////////////////////////
-void TcpTransport::close() throw( decaf::io::IOException ) {
+void TcpTransport::close() {
 
     try {
 



Mime
View raw message