Author: tabish
Date: Sun Jan 25 15:29:58 2009
New Revision: 737522
URL: http://svn.apache.org/viewvc?rev=737522&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-100
More work on the Failover bits.
Modified:
activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.cpp
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.h
Modified:
activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.cpp
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.cpp?rev=737522&r1=737521&r2=737522&view=diff
==============================================================================
--- activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.cpp
(original)
+++ activemq/activemq-cpp/trunk/src/test/activemq/transport/IOTransportTest.cpp
Sun Jan 25 15:29:58 2009
@@ -198,6 +198,16 @@
mutex.notify();
}
}
+
+ /**
+ * The transport has suffered an interruption from which it hopes to
recover
+ */
+ virtual void transportInterrupted() {}
+
+ /**
+ * The transport has resumed after an interruption
+ */
+ virtual void transportResumed() {}
};
////////////////////////////////////////////////////////////////////////////////
Modified:
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.h
URL:
http://svn.apache.org/viewvc/activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.h?rev=737522&r1=737521&r2=737522&view=diff
==============================================================================
---
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.h
(original)
+++
activemq/activemq-cpp/trunk/src/test/activemq/transport/correlator/ResponseCorrelatorTest.h
Sun Jan 25 15:29:58 2009
@@ -326,6 +326,17 @@
exCount++;
}
}
+
+ /**
+ * The transport has suffered an interruption from which it hopes
to recover
+ */
+ virtual void transportInterrupted() {}
+
+ /**
+ * The transport has resumed after an interruption
+ */
+ virtual void transportResumed() {}
+
};
class RequestThread : public decaf::lang::Thread{
