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/22 18:48:18 UTC
svn commit: r433686 -
/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java
Author: gnodet
Date: Tue Aug 22 09:48:18 2006
New Revision: 433686
URL: http://svn.apache.org/viewvc?rev=433686&view=rev
Log:
Fix JCA flow due to jencks 1.3 upgrade
Modified:
incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/jbi/nmr/flow/jca/JCAFlow.java
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=433686&r1=433685&r2=433686&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 Tue Aug 22 09:48:18 2006
@@ -268,7 +268,7 @@
containerConnector.setActivationSpec(ac);
containerConnector.setResourceAdapter(resourceAdapter);
containerConnector.setEndpointFactory(new SingletonEndpointFactory(this, getTransactionManager()));
- containerConnector.afterPropertiesSet();
+ containerConnector.start();
// Outbound connector
ActiveMQManagedConnectionFactory mcf = new ActiveMQManagedConnectionFactory();
@@ -327,7 +327,7 @@
}
}
}));
- broadcastConnector.afterPropertiesSet();
+ broadcastConnector.start();
advisoryConsumer = broadcastSession.createConsumer(advisoryTopic);
advisoryConsumer.setMessageListener(new MessageListener() {
@@ -436,7 +436,7 @@
connector.setActivationSpec(ac);
connector.setResourceAdapter(resourceAdapter);
connector.setEndpointFactory(new SingletonEndpointFactory(this, getTransactionManager()));
- connector.afterPropertiesSet();
+ connector.start();
connectorMap.put(key, connector);
}
// broadcast change to the network
@@ -481,7 +481,7 @@
connector.setActivationSpec(ac);
connector.setResourceAdapter(resourceAdapter);
connector.setEndpointFactory(new SingletonEndpointFactory(this, getTransactionManager()));
- connector.afterPropertiesSet();
+ connector.start();
connectorMap.put(key, connector);
}
} catch (Exception e) {