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 2016/09/09 15:43:20 UTC
svn commit: r1760040 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
Author: cwiklik
Date: Fri Sep 9 15:43:20 2016
New Revision: 1760040
URL: http://svn.apache.org/viewvc?rev=1760040&view=rev
Log:
UIMA-5105 Add debug level msg
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java?rev=1760040&r1=1760039&r2=1760040&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsInputChannel.java Fri Sep 9 15:43:20 2016
@@ -968,6 +968,7 @@ public class JmsInputChannel implements
List<UimaDefaultMessageListenerContainer> ll = getListeners();
for (UimaDefaultMessageListenerContainer listenerObject : ll) {
listenerObject.closeConnection();
+ System.out.println("................. JmsInputChannel.terminate() - Listener -"+listenerObject.getDestinationName());
}
} catch( Exception e) {
@@ -980,7 +981,13 @@ public class JmsInputChannel implements
public synchronized void stop(int channelsToClose, boolean shutdownNow) throws Exception {
List<UimaDefaultMessageListenerContainer> listenersToRemove = new ArrayList<UimaDefaultMessageListenerContainer>();
List<UimaDefaultMessageListenerContainer> ll = getListeners();
-
+ String msg = ">>>>>>>>>>>> JmsInputChannel. stop() - Controller:"+controller.getComponentName()+ " Listener Count:"+ll.size();
+ if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.FINEST)) {
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.FINEST, CLASS_NAME.getName(), "stop",
+ JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_debug_msg__FINEST",
+ new Object[] { msg });
+ }
+
for (UimaDefaultMessageListenerContainer listenerObject : ll) {
if (listenerObject != null && doCloseChannel(listenerObject, channelsToClose)) {