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/12/20 17:48:28 UTC
svn commit: r1051203 -
/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
Author: cwiklik
Date: Mon Dec 20 16:48:28 2010
New Revision: 1051203
URL: http://svn.apache.org/viewvc?rev=1051203&view=rev
Log:
UIMA-1936 Discontinued use of System.out.println
Modified:
uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
Modified: uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java
URL: http://svn.apache.org/viewvc/uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java?rev=1051203&r1=1051202&r2=1051203&view=diff
==============================================================================
--- uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java (original)
+++ uima/uima-as/trunk/uimaj-as-activemq/src/main/java/org/apache/uima/adapter/jms/activemq/SpringContainerDeployer.java Mon Dec 20 16:48:28 2010
@@ -85,6 +85,8 @@ public class SpringContainerDeployer imp
connector.setDestinationResolver(resolver);
connector.initializeContainer();
+
+ connector.start();
synchronized (mux) {
while (connector.getListenerEndpoint() == null) {
try {
@@ -94,8 +96,6 @@ public class SpringContainerDeployer imp
}
}
- // connector.afterPropertiesSet();
- connector.start();
return connector;
}
@@ -185,9 +185,6 @@ public class SpringContainerDeployer imp
cf.setPrefetchPolicy(prefetchPolicy);
// Create a listener and a temp queue for Free CAS notifications.
UimaDefaultMessageListenerContainer connector = produceListenerConnector(cf);
- System.out.println(">>>> Cas Multiplier Controller:" + cntlr.getComponentName()
- + " Activated Listener to Receive Free CAS Notifications - Temp Queue Name:"
- + connector.getEndpointName());
// Direct all messages to the InputChannel
connector.setMessageListener(((JmsInputChannel) cntlr.getInputChannel()));
((JmsInputChannel) cntlr.getInputChannel()).setListenerContainer(connector);
@@ -240,14 +237,10 @@ public class SpringContainerDeployer imp
if (delegate != null) {
cc = delegate.getEndpoint().getConcurrentReplyConsumers();
}
- System.out.println("Remote Delegate " + endpoint.getDelegateKey() + " Reply Queue:"
- + endpoint.getDestination()
- + " Reply Listener Configured With " + cc
- + " Concurrent Consumer(s)");
- if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.CONFIG)) {
- UIMAFramework.getLogger(CLASS_NAME).logrb(Level.CONFIG, CLASS_NAME.getName(),
+ if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(),
"initializeTopLevelController", JmsConstants.JMS_LOG_RESOURCE_BUNDLE,
- "UIMAJMS_replyq__CONFIG",
+ "UIMAJMS_replyq__INFO",
new Object[] { endpoint.getDelegateKey(), endpoint.getDestination(), cc });
}
}
@@ -363,7 +356,12 @@ public class SpringContainerDeployer imp
// Only start those listeners that are not running yet.
if ( listener != null && !listener.isRunning()) {
if ( topLevelController != null ) {
- System.out.println("Controller:"+topLevelController.getComponentName()+" Activating Listener on Queue:"+listener.getDestination()+" Selector:"+listener.getMessageSelector()+" Broker:"+listener.getBrokerUrl());
+
+ if (UIMAFramework.getLogger(CLASS_NAME).isLoggable(Level.INFO)) {
+ UIMAFramework.getLogger(CLASS_NAME).logrb(Level.INFO, CLASS_NAME.getName(), "doStartListeners",
+ JmsConstants.JMS_LOG_RESOURCE_BUNDLE, "UIMAJMS_starting_listener__INFO",
+ new Object[] { topLevelController.getComponentName(), listener.getDestination(), listener.getMessageSelector(), listener.getBrokerUrl() });
+ }
topLevelController.changeState(ServiceState.RUNNING);
}
listener.start();
@@ -534,7 +532,6 @@ public class SpringContainerDeployer imp
}
public void notifyOnTermination(String message) {
- System.out.println("-------------------> Container Terminated");
}
public FileSystemXmlApplicationContext getSpringContext() {