Title: [875] trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java: Debugging info added
- Revision
- 875
- Author
- gastaldi
- Date
- 2005-11-21 09:25:01 -0500 (Mon, 21 Nov 2005)
Log Message
Debugging info added
Modified Paths
Diff
Modified: trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java (874 => 875)
--- trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java 2005-11-21 14:18:00 UTC (rev 874)
+++ trunk/core/src/main/java/org/servicemix/jbi/nmr/flow/AbstractFlow.java 2005-11-21 14:25:01 UTC (rev 875)
@@ -87,7 +87,9 @@
* stop the flow
* @throws JBIException
*/
- public void stop() throws JBIException{
+ public void stop() throws JBIException{
+ if (log.isDebugEnabled())
+ log.debug("Called Flow stop");
if (suspendThread != null){
suspendThread.interrupt();
}
@@ -99,8 +101,9 @@
* @throws JBIException
*/
public void shutDown() throws JBIException{
+ if (log.isDebugEnabled())
+ log.debug("Called Flow shutdown");
super.shutDown();
-
}
/**
@@ -110,6 +113,8 @@
*/
public void send(MessageExchange me) throws JBIException{
// Check persistence
+ if (log.isDebugEnabled())
+ log.debug("Called Flow send");
if (!canPersist() && isPersistent(me)) {
throw new UnsupportedOperationException("persistence is not available on st flow");
}
@@ -126,6 +131,8 @@
* suspend the flow to prevent any message exchanges
*/
public synchronized void suspend(){
+ if (log.isDebugEnabled())
+ log.debug("Called Flow suspend");
lock.writeLock().lock();
suspendThread = Thread.currentThread();
}
@@ -135,6 +142,8 @@
* resume message exchange processing
*/
public synchronized void resume(){
+ if (log.isDebugEnabled())
+ log.debug("Called Flow resume");
lock.writeLock().unlock();
suspendThread = null;
}
@@ -162,6 +171,8 @@
* @throws MessagingException
*/
public void doRouting(MessageExchangeImpl me) throws MessagingException {
+ if (log.isDebugEnabled())
+ log.debug("Called Flow doRouting");
ComponentNameSpace id = me.getRole() == Role.PROVIDER ? me.getDestinationId() : me.getSourceId();
//As the MessageExchange could come from another container - ensure we get the local Component
ComponentNameSpace copy = id.copy();
