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) {
