activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r835895 - /activemq/activemq-cpp/trunk/activemq-cpp/src/main/activemq/transport/inactivity/InactivityMonitor.cpp
Date Fri, 13 Nov 2009 16:08:23 GMT
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:
 



Mime
View raw message