You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@uima.apache.org by cw...@apache.org on 2010/02/17 17:09:01 UTC
svn commit: r911039 -
/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
Author: cwiklik
Date: Wed Feb 17 16:09:01 2010
New Revision: 911039
URL: http://svn.apache.org/viewvc?rev=911039&view=rev
Log:
UIMA-1742 Modified to show number of threads processing replies on a temp reply queue
Modified:
incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
Modified: incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
URL: http://svn.apache.org/viewvc/incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java?rev=911039&r1=911038&r2=911039&view=diff
==============================================================================
--- incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java (original)
+++ incubator/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java Wed Feb 17 16:09:01 2010
@@ -38,6 +38,8 @@
import org.apache.uima.aae.controller.Endpoint;
import org.apache.uima.aae.controller.UimacppServiceController;
import org.apache.uima.aae.controller.BaseAnalysisEngineController.ServiceState;
+import org.apache.uima.aae.delegate.Delegate;
+import org.apache.uima.aae.jmx.ServicePerformance;
import org.apache.uima.adapter.jms.JmsConstants;
import org.apache.uima.resource.ResourceInitializationException;
import org.apache.uima.util.Level;
@@ -230,9 +232,18 @@
}
}
}
+
+ Delegate delegate = ((AggregateAnalysisEngineController) cntlr)
+ .lookupDelegate(endpoint.getDelegateKey());
+ int cc = 1;
+
+ if (delegate != null) {
+ cc = delegate.getEndpoint().getConcurrentReplyConsumers();
+ }
System.out.println("Remote Delegate " + endpoint.getDelegateKey() + " Reply Queue:"
- + endpoint.getDestination());
-
+ + endpoint.getDestination()
+ + " Reply Listener Configured With " + cc
+ + " Concurrent Consumer(s)");
}
}
int concurrentConsumerCountOnReplies = getConcurrentConsumerCount(ctx);