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 2013/08/06 21:30:54 UTC
svn commit: r1511088 - in
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq:
JmsEndpointConnection_impl.java JmsInputChannel.java
Author: cwiklik
Date: Tue Aug 6 19:30:54 2013
New Revision: 1511088
URL: http://svn.apache.org/r1511088
Log:
UIMA-2776 added additional logging
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java
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/JmsEndpointConnection_impl.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java?rev=1511088&r1=1511087&r2=1511088&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/JmsEndpointConnection_impl.java Tue Aug 6 19:30:54 2013
@@ -262,6 +262,10 @@ public class JmsEndpointConnection_impl
}
producerSession = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(),
+ "openChannel", JmsConstants.JMS_LOG_RESOURCE_BUNDLE,
+ "UIMAJMS_session_open__INFO",
+ new Object[] { aComponentName, anEndpointName, brokerUri });
if ((delegateEndpoint.getCommand() == AsynchAEMessage.Stop || isReplyEndpoint)
&& delegateEndpoint.getDestination() != null) {
@@ -615,7 +619,18 @@ public class JmsEndpointConnection_impl
// record the time when this dispatches sent a message. This time will be used
// to find inactive sessions.
lastDispatchTimestamp.set(System.currentTimeMillis());
+
+ if ( msgType == AsynchAEMessage.Response && command == AsynchAEMessage.GetMeta ) {
+ if (UIMAFramework.getLogger().isLoggable(Level.INFO)) {
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(), "send",
+ JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_dispatched_getmeta_reply__INFO",
+ new Object[] { controller.getComponentName(), destinationName });
+ }
+ }
+
+
+
// Succeeded sending the CAS
return true;
} catch (Exception e) {
@@ -708,7 +723,7 @@ public class JmsEndpointConnection_impl
}
}
- brokerDestinations.getConnectionTimer().stopTimer();
+ //brokerDestinations.getConnectionTimer().stopTimer();
// Failed here
return false;
}
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=1511088&r1=1511087&r2=1511088&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 Tue Aug 6 19:30:54 2013
@@ -638,6 +638,9 @@ public class JmsInputChannel implements
getController().getOutputChannel().sendReply(AsynchAEMessage.ServiceInfo,
messageContext.getEndpoint(), aMessage.getStringProperty(AsynchAEMessage.CasReference), true);
} catch( Exception ex) {
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.WARNING, CLASS_NAME.getName(),
+ "produceTextMessage", JmsConstants.JMS_LOG_RESOURCE_BUNDLE,
+ "UIMAJMS_exception__WARNING", ex);
// The exception has already been logged in sendReply() method
return; // DONT PROCESS
}