You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/08/31 00:40:42 UTC
svn commit: r438691 - in
/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix:
Main.java jbi/nmr/flow/jca/JCAFlow.java jbi/nmr/flow/jms/JMSFlow.java
Author: gnodet
Date: Wed Aug 30 15:40:42 2006
New Revision: 438691
URL: http://svn.apache.org/viewvc?rev=438691&view=rev
Log:
Decrease jca/jms flow verbosity
Remove unused import
Modified:
incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/Main.java
incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java
incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/Main.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/Main.java?rev=438691&r1=438690&r2=438691&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/Main.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/Main.java Wed Aug 30 15:40:42 2006
@@ -18,7 +18,6 @@
import java.io.File;
import java.util.ArrayList;
-import java.util.Collections;
import java.util.List;
import org.apache.servicemix.jbi.config.spring.XBeanProcessor;
Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java?rev=438691&r1=438690&r2=438691&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java Wed Aug 30 15:40:42 2006
@@ -233,7 +233,7 @@
* @throws JBIException
*/
public void init(Broker broker) throws JBIException {
- log.info(broker.getContainer().getName() + ": Initializing jca flow");
+ log.debug(broker.getContainer().getName() + ": Initializing jca flow");
super.init(broker);
// Create and register endpoint listener
endpointListener = new EndpointAdapter() {
@@ -441,7 +441,7 @@
}
// broadcast change to the network
if (broadcast) {
- log.info(broker.getContainer().getName() + ": broadcasting info for " + event);
+ log.debug(broker.getContainer().getName() + ": broadcasting info for " + event);
sendJmsMessage(broadcastTopic, event, false, false);
}
} catch (Exception e) {
@@ -458,7 +458,7 @@
}
// broadcast change to the network
if (broadcast) {
- log.info(broker.getContainer().getName() + ": broadcasting info for " + event);
+ log.debug(broker.getContainer().getName() + ": broadcasting info for " + event);
sendJmsMessage(broadcastTopic, event, false, false);
}
} catch (Exception e) {
Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java?rev=438691&r1=438690&r2=438691&view=diff
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jms/JMSFlow.java Wed Aug 30 15:40:42 2006
@@ -208,7 +208,7 @@
* @throws JBIException
*/
public void init(Broker broker) throws JBIException {
- log.info(broker.getContainer().getName() + ": Initializing jms flow");
+ log.debug(broker.getContainer().getName() + ": Initializing jms flow");
super.init(broker);
// Create and register endpoint listener
endpointListener = new EndpointAdapter() {
@@ -268,7 +268,7 @@
*/
public void start() throws JBIException {
if (started.compareAndSet(false, true)) {
- log.info(broker.getContainer().getName() + ": Starting jms flow");
+ log.debug(broker.getContainer().getName() + ": Starting jms flow");
super.start();
try {
broadcastConsumer = broadcastSession.createConsumer(broadcastTopic, null, true);
@@ -331,7 +331,7 @@
*/
public void stop() throws JBIException {
if (started.compareAndSet(true, false)) {
- log.info(broker.getContainer().getName() + ": Stopping jms flow");
+ log.debug(broker.getContainer().getName() + ": Stopping jms flow");
super.stop();
for (Iterator it = subscriberSet.iterator(); it.hasNext();) {
String id = (String) it.next();
@@ -386,7 +386,7 @@
consumerMap.put(key, consumer);
}
if (broadcast) {
- log.info(broker.getContainer().getName() + ": broadcasting info for " + event);
+ log.debug(broker.getContainer().getName() + ": broadcasting info for " + event);
ObjectMessage msg = broadcastSession.createObjectMessage(event);
topicProducer.send(msg);
}
@@ -404,7 +404,7 @@
}
if (broadcast) {
ObjectMessage msg = broadcastSession.createObjectMessage(event);
- log.info(broker.getContainer().getName() + ": broadcasting info for " + event);
+ log.debug(broker.getContainer().getName() + ": broadcasting info for " + event);
topicProducer.send(msg);
}
} catch (Exception e) {
@@ -442,12 +442,12 @@
}
public void onRemoteEndpointRegistered(EndpointEvent event) {
- log.info(broker.getContainer().getName() + ": adding remote endpoint: " + event.getEndpoint());
+ log.debug(broker.getContainer().getName() + ": adding remote endpoint: " + event.getEndpoint());
broker.getContainer().getRegistry().registerRemoteEndpoint(event.getEndpoint());
}
public void onRemoteEndpointUnregistered(EndpointEvent event) {
- log.info(broker.getContainer().getName() + ": removing remote endpoint: " + event.getEndpoint());
+ log.debug(broker.getContainer().getName() + ": removing remote endpoint: " + event.getEndpoint());
broker.getContainer().getRegistry().unregisterRemoteEndpoint(event.getEndpoint());
}