Author: tabish
Date: Fri Nov 13 16:08:23 2009
New Revision: 835895
URL: http://svn.apache.org/viewvc?rev=835895&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQCPP-250
Implement a Thread factory for use in the Task execution of Read / Write checks.
Modified:
activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
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=835895&r1=835894&r2=835895&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
Fri Nov 13 16:08:23 2009
@@ -22,7 +22,11 @@
#include <activemq/commands/WireFormatInfo.h>
#include <activemq/commands/KeepAliveInfo.h>
+
#include <decaf/lang/Math.h>
+#include <decaf/lang/Thread.h>
+#include <decaf/lang/Runnable.h>
+#include <decaf/util/concurrent/ThreadFactory.h>
using namespace std;
using namespace activemq;
@@ -44,6 +48,14 @@
namespace transport{
namespace inactivity{
+ class InactivityThreadFactory : public ThreadFactory {
+ public:
+
+ virtual Thread* newThread( Runnable* runnable ) {
+ return new Thread( runnable, "Inactivity Monitor Async Task." );
+ }
+ };
+
class AsyncException : decaf::lang::Runnable {
private:
