raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Use a cached JMS ConnectionFactory.

Browse source
This commit is contained in:
Martin Krasser 2010-10-24 18:47:28 +02:00
parent dee1743cb9
commit dcde8373b2
2 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-samples/akka-sample-camel/src/main/resources/context-jms.xml
View file

@ -13,7 +13,11 @@ http://www.springframework.org/schema/beans/spring-beans-2.5.xsd">
</bean>
<bean id="jmsConfig" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory" ref="jmsConnectionFactory"/>
<property name="connectionFactory" ref="singleConnectionFactory"/>
</bean>
<bean id="singleConnectionFactory" class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory" ref="jmsConnectionFactory"/>
</bean>
<bean id="jmsConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">

3
akka-samples/akka-sample-camel/src/main/scala/StandaloneApplication.scala
View file

@ -99,6 +99,9 @@ object StandaloneJmsApplication extends Application {
CamelContextManager.mandatoryTemplate.sendBody(jmsUri, "Camel rocks (%d)" format i)
}
// Wait a bit for subscribes to receive messages
Thread.sleep(1000)
stopCamelService
ActorRegistry.shutdownAll
}