You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@servicemix.apache.org by Charles Souillard <Ch...@ext.bull.net> on 2006/03/07 13:44:24 UTC
ActiveMQ
Hi all,
I want to know what I have to do with Active MQ to make my SM running as
a webapp.
I am using SM through the available web app. I have deployed it into a
J2EE app server.
I am able to install my component and to deploy SAs to my component.
What I am trying to do now is :
1) understanding how ActiveMQ and SM are correlated
2) what I have to do to make them running together
3) launching a client which send a JMS message to a Topic on which a
component is waiting for
When I try to launch my client, I get the following exception :
Can you please help me ?
Thanks
Charles
Exception in thread "main" javax.jms.JMSException: Could not connect to
broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
Connection refused
[java] at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:32)
[java] at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:244)
[java] at
org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(ActiveMQConnectionFactory.java:186)
[java] at JMSClient.main(Unknown Source)
[java] Caused by: java.net.ConnectException: Connection refused
[java] at java.net.PlainSocketImpl.socketConnect(Native Method)
[java] at
java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
[java] at
java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
[java] at
java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
[java] at
java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
[java] at java.net.Socket.connect(Socket.java:507)
[java] at java.net.Socket.connect(Socket.java:457)
[java] at
org.apache.activemq.transport.tcp.TcpTransport.createSocket(TcpTransport.java:204)
[java] at
org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java:79)
[java] at
org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(TcpTransportFactory.java:115)
[java] at
org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:115)
[java] at
org.apache.activemq.transport.TransportFactory.doConnect(TransportFactory.java:42)
[java] at
org.apache.activemq.transport.TransportFactory.connect(TransportFactory.java:76)
[java] at
org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(ActiveMQConnectionFactory.java:216)
[java] ... 2 more
[java] Java Result: 1
test
Posted by Sandhu <ka...@gmail.com>.
test
Re: ActiveMQ
Posted by Charles Souillard <Ch...@ext.bull.net>.
I can give additional infos :
when I start my J2EE app server, I get an error concerning the embeded
example :
AbstractRefreshableApplicationContext.refreshBeanFactory : Bean factory
for application context [Root WebApplicationContext]:
org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans [jbi,jencks,broker,transactionManager,jmsFactory]; root
of BeanFactory hierarchy
2006-03-07 16:09:03,126 : AbstractApplicationContext.refresh : 5 beans
defined in application context [Root WebApplicationContext]
2006-03-07 16:09:03,150 : AbstractApplicationContext.initMessageSource :
Unable to locate MessageSource with name 'messageSource': using default
[org.springframework.context.support.DelegatingMessageSource@10064a4]
2006-03-07 16:09:03,162 :
AbstractApplicationContext.initApplicationEventMulticaster : Unable to
locate ApplicationEventMulticaster with name
'applicationEventMulticaster': using default
[org.springframework.context.event.SimpleApplicationEventMulticaster@39826]
2006-03-07 16:09:03,181 : UiApplicationContextUtils.initThemeSource :
Unable to locate ThemeSource with name 'themeSource': using default
[org.springframework.ui.context.support.ResourceBundleThemeSource@1386751]
2006-03-07 16:09:03,190 :
DefaultListableBeanFactory.preInstantiateSingletons : Pre-instantiating
singletons in factory
[org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans [jbi,jencks,broker,transactionManager,jmsFactory]; root
of BeanFactory hierarchy]
2006-03-07 16:09:03,584 : XmlBeanDefinitionReader.loadBeanDefinitions :
Loading XML bean definitions from ServletContext resource
[/WEB-INF/activemq.xml]
2006-03-07 16:09:03,771 :
AbstractRefreshableApplicationContext.refreshBeanFactory : Bean factory
for application context
[org.apache.xbean.spring.context.ResourceXmlApplicationContext;hashCode=1344853]:
org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans [org.apache.activemq.xbean.XBeanBrokerService]; root of
BeanFactory hierarchy
2006-03-07 16:09:03,774 : AbstractApplicationContext.refresh : 1 beans
defined in application context
[org.apache.xbean.spring.context.ResourceXmlApplicationContext;hashCode=1344853]
2006-03-07 16:09:03,786 : AbstractApplicationContext.initMessageSource :
Unable to locate MessageSource with name 'messageSource': using default
[org.springframework.context.support.DelegatingMessageSource@175ace6]
2006-03-07 16:09:03,788 :
AbstractApplicationContext.initApplicationEventMulticaster : Unable to
locate ApplicationEventMulticaster with name
'applicationEventMulticaster': using default
[org.springframework.context.event.SimpleApplicationEventMulticaster@aa4c7c]
2006-03-07 16:09:03,791 :
DefaultListableBeanFactory.preInstantiateSingletons : Pre-instantiating
singletons in factory
[org.springframework.beans.factory.support.DefaultListableBeanFactory
defining beans [org.apache.activemq.xbean.XBeanBrokerService]; root of
BeanFactory hierarchy]
2006-03-07 16:09:04,196 : BrokerService.getBroker : ActiveMQ
4.0-SNAPSHOT JMS Message Broker (localhost) is starting
2006-03-07 16:09:04,199 : BrokerService.getBroker : For help or more
information please see: http://www.logicblaze.com
2006-03-07 16:09:07,279 : JDBCPersistenceAdapter.createAdapter :
Database driver recognized: [apache_derby_embedded_jdbc_driver]
2006-03-07 16:09:08,927 : JournalPersistenceAdapter.recover : Journal
Recovery Started from: Active Journal: using 5 x 20.0 Megs at:
/home/souillac/serviceMix/data/journal
2006-03-07 16:09:08,982 : JournalPersistenceAdapter.recover : Journal
Recovered: 0 message(s) in transactions recovered.
2006-03-07 16:09:09,157 : TransportServerThreadSupport.start : Listening
for connections at: tcp://frec445363:61636
2006-03-07 16:09:09,160 : TransportConnector.start : Accepting
connection on: tcp://frec445363:61636
2006-03-07 16:09:09,169 : MulticastDiscoveryAgent.start : brokerName not set
2006-03-07 16:09:09,215 : BrokerService.start : ActiveMQ JMS Message
Broker (localhost) started
2006-03-07 16:09:09,252 : JCAContainer.afterPropertiesSet : Jencks JCA
Container (http://jencks.org/) has started running version: 1.1.2
2006-03-07 16:09:09,396 : JBIContainer.activateComponent : Activating
component for:
[container=defaultJBI,name=#SubscriptionManager#,id=#SubscriptionManager#]
with service: null component:
org.apache.servicemix.jbi.nmr.SubscriptionManager@585f2a
2006-03-07 16:09:09,491 : JBIContainer.init : ServiceMix JBI Container
(http://servicemix.org/) name: defaultJBI running version: 3.0-SNAPSHOT
2006-03-07 16:09:09,493 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=httpBinding,id=httpBinding]
with service: {http://servicemix.apache.org/demo/}httpBinding component:
org.apache.servicemix.components.http.HttpInOutBinding@1dd8136
2006-03-07 16:09:09,500 : ComponentContextImpl.activateEndpoint :
Component: httpBinding activated endpoint:
{http://servicemix.apache.org/demo/}httpBinding : httpBinding
2006-03-07 16:09:09,520 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=echo,id=echo] with service:
{http://servicemix.apache.org/demo/}echo component:
org.apache.servicemix.components.HelloWorldComponent@113b44d
2006-03-07 16:09:09,522 : ComponentContextImpl.activateEndpoint :
Component: echo activated endpoint:
{http://servicemix.apache.org/demo/}echo : echo
2006-03-07 16:09:09,540 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=timer,id=timer] with service:
{http://servicemix.apache.org/demo/}timer component:
org.apache.servicemix.components.quartz.QuartzComponent@1615a1f
2006-03-07 16:09:09,642 : SimpleThreadPool.initialize : Job execution
threads will use class loader of thread: main
2006-03-07 16:09:09,683 : QuartzScheduler.<init> : Quartz Scheduler
v.null.null.null created.
2006-03-07 16:09:09,695 : NetworkConnector.onServiceAdd : Establishing
network connection between vm://localhost?network=true and null at
failover:tcp://frec445363:61636
2006-03-07 16:09:09,707 : VMTransportFactory.bind : binding to broker:
localhost
2006-03-07 16:09:09,714 : TransportConnector.start : Accepting
connection on: vm://localhost
2006-03-07 16:09:09,784 : DemandForwardingBridge.start : Starting a
network connection between vm://localhost#0 and unconnected has been
established.
2006-03-07 16:09:09,826 : DemandForwardingBridge.serviceRemoteCommand :
Disconnecting loop back connection.
2006-03-07 16:09:09,838 : VMTransportFactory.stopped : Shutting down VM
connectors for broker: localhost
2006-03-07 16:09:09,839 : VMTransportFactory.stopped : Shutting down VM
connectors for broker: localhost
2006-03-07 16:09:09,848 : RAMJobStore.initialize : RAMJobStore initialized.
2006-03-07 16:09:09,850 : StdSchedulerFactory.instantiate : Quartz
scheduler 'DefaultQuartzScheduler' initialized from default resource
file in Quartz package: 'quartz.properties'
2006-03-07 16:09:09,858 : StdSchedulerFactory.instantiate : Quartz
scheduler version: null.null.null
2006-03-07 16:09:09,866 : QuartzScheduler.start : Scheduler
DefaultQuartzScheduler_$_NON_CLUSTERED started.
2006-03-07 16:09:09,911 : ComponentContextImpl.activateEndpoint :
Component: timer activated endpoint:
{http://servicemix.apache.org/demo/}timer : timer
2006-03-07 16:09:09,962 : Broker.resolveAddress : ServiceName
({http://servicemix.apache.org/demo/}inputSender) specified for routing,
but can't find it registered
2006-03-07 16:09:09,980 : JobRunShell.run : Job ServiceMix.My Example
Job threw a JobExecutionException:
org.quartz.JobExecutionException:
javax.jbi.messaging.MessagingException: Failed to resolve endpoint:
org.apache.servicemix.jbi.NoServiceAvailableException: Cannot find an
instance of the service: {http://servicemix.apache.org/demo/}inputSender
[See nested exception: javax.jbi.messaging.MessagingException: Failed to
resolve endpoint: org.apache.servicemix.jbi.NoServiceAvailableException:
Cannot find an instance of the service:
{http://servicemix.apache.org/demo/}inputSender]
at
org.apache.servicemix.components.quartz.QuartzComponent.onJobExecute(QuartzComponent.java:125)
at
org.apache.servicemix.components.quartz.ServiceMixJob.execute(ServiceMixJob.java:33)
at org.quartz.core.JobRunShell.run(JobRunShell.java:195)
at
org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:520)
* Nested Exception (Underlying Cause) ---------------
javax.jbi.messaging.MessagingException: Failed to resolve endpoint:
org.apache.servicemix.jbi.NoServiceAvailableException: Cannot find an
instance of the service: {http://servicemix.apache.org/demo/}inputSender
at
org.apache.servicemix.jbi.nmr.Broker.resolveAddress(Broker.java:367)
at
org.apache.servicemix.jbi.nmr.Broker.sendExchangePacket(Broker.java:283)
at
org.apache.servicemix.jbi.container.JBIContainer.sendExchange(JBIContainer.java:679)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.doSend(DeliveryChannelImpl.java:451)
at
org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.send(DeliveryChannelImpl.java:491)
at
org.apache.servicemix.components.util.PojoSupport.send(PojoSupport.java:211)
at
org.apache.servicemix.components.quartz.QuartzComponent.onJobExecute(QuartzComponent.java:122)
at
org.apache.servicemix.components.quartz.ServiceMixJob.execute(ServiceMixJob.java:33)
at org.quartz.core.JobRunShell.run(JobRunShell.java:195)
at
org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:520)
Caused by: org.apache.servicemix.jbi.NoServiceAvailableException: Cannot
find an instance of the service:
{http://servicemix.apache.org/demo/}inputSender
at
org.apache.servicemix.jbi.resolver.ServiceNameEndpointResolver.createServiceUnavailableException(ServiceNameEndpointResolver.java:60)
at
org.apache.servicemix.jbi.resolver.EndpointResolverSupport.resolveEndpoint(EndpointResolverSupport.java:39)
at
org.apache.servicemix.jbi.nmr.Broker.resolveAddress(Broker.java:364)
... 9 more
2006-03-07 16:09:09,914 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=inputSender,id=inputSender]
with service: {http://servicemix.apache.org/demo/}inputSender component:
org.apache.servicemix.components.jms.JmsSenderComponent@1e1df6e
2006-03-07 16:09:09,983 : ComponentContextImpl.activateEndpoint :
Component: inputSender activated endpoint:
{http://servicemix.apache.org/demo/}inputSender : inputSender
2006-03-07 16:09:10,067 : JBIContainer.activateComponent : Activating
component for:
[container=defaultJBI,name=inputReceiver,id=inputReceiver] with service:
{http://servicemix.apache.org/demo/}inputReceiver component:
org.apache.servicemix.components.jms.JmsInUsingJCABinding@6646fc
2006-03-07 16:09:10,095 : JCAConnector.afterPropertiesSet : Activating
endpoint for activationSpec:
ActiveMQActivationSpec{acknowledgeMode='Auto-acknowledge',
destinationType='javax.jms.Topic', messageSelector='null',
destination='demo.org.apache.servicemix.source', clientId='null',
subscriptionName='null', subscriptionDurability='NonDurable'} using
endpointFactory:
org.jencks.SingletonEndpointFactory@7348e[transactionManager=org.apache.geronimo.transaction.manager.TransactionManagerImpl@10b8d03]
2006-03-07 16:09:10,146 : ComponentContextImpl.activateEndpoint :
Component: inputReceiver activated endpoint:
{http://servicemix.apache.org/demo/}inputReceiver : inputReceiver
2006-03-07 16:09:10,155 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=outputSender,id=outputSender]
with service: {http://servicemix.apache.org/demo/}outputSender
component: org.apache.servicemix.components.jms.JmsSenderComponent@1a42824
2006-03-07 16:09:10,157 : ComponentContextImpl.activateEndpoint :
Component: outputSender activated endpoint:
{http://servicemix.apache.org/demo/}outputSender : outputSender
2006-03-07 16:09:10,172 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=jmsTrace,id=jmsTrace] with
service: {http://servicemix.apache.org/demo/}jmsTrace component:
org.apache.servicemix.components.jms.JmsInUsingJCABinding@f0691c
2006-03-07 16:09:10,182 : JCAConnector.afterPropertiesSet : Activating
endpoint for activationSpec:
ActiveMQActivationSpec{acknowledgeMode='Auto-acknowledge',
destinationType='javax.jms.Topic', messageSelector='null',
destination='demo.org.apache.servicemix.result', clientId='null',
subscriptionName='null', subscriptionDurability='NonDurable'} using
endpointFactory:
org.jencks.SingletonEndpointFactory@120e750[transactionManager=org.apache.geronimo.transaction.manager.TransactionManagerImpl@10b8d03]
2006-03-07 16:09:10,220 : ComponentContextImpl.activateEndpoint :
Component: jmsTrace activated endpoint:
{http://servicemix.apache.org/demo/}jmsTrace : jmsTrace
2006-03-07 16:09:10,224 : JBIContainer.activateComponent : Activating
component for: [container=defaultJBI,name=trace,id=trace] with service:
{http://servicemix.apache.org/demo/}trace component:
org.apache.servicemix.components.util.TraceComponent@7800e9
2006-03-07 16:09:10,232 : ComponentContextImpl.activateEndpoint :
Component: trace activated endpoint:
{http://servicemix.apache.org/demo/}trace : trace
2006-03-07 16:09:10,353 : ContextLoader.initWebApplicationContext :
Using context class
[org.apache.xbean.spring.context.XmlWebApplicationContext] for root
WebApplicationContext
Regards,
Charles
Charles Souillard wrote:
> Guillaume,
>
> There is already an applicationcontext.xml file and an activemq.xml
> embeded in the web app.
> I am sure they are used as I updated them to modify target directories
> (install, deploy, wdir and data).
> I can verify the directories are created.
>
> So why my broker is not started ?
> Do I have to do something else ?
>
> You can find hereafter my activemq and applicationcontext xml files :
>
>
> ACTIVEMQ :
>
> <!-- START SNIPPET: xbean -->
> <beans xmlns="http://activemq.org/config/1.0">
>
> <broker useJmx="false">
>
> <persistenceAdapter>
> <journaledJDBC journalLogFiles="5"
> dataDirectory="/home/souillac/serviceMix/data"/>
> <!-- To use a different datasource, use th following syntax : -->
> <!--
> <journaledJDBC journalLogFiles="5" dataDirectory="../data"
> dataSource="#postgres-ds"/>
> -->
> </persistenceAdapter>
>
> <transportConnectors>
> <transportConnector uri="tcp://localhost:61636"
> discoveryUri="multicast://default"/>
> </transportConnectors>
>
> <networkConnectors>
> <!-- by default just auto discover the other brokers -->
> <networkConnector uri="multicast://default"/>
> <!--
> <networkConnector
> uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
> -->
> </networkConnectors>
>
> </broker>
>
> <!-- This xbean configuration file supports all the standard spring
> xml configuration options -->
>
> <!-- Postgres DataSource Sample Setup -->
> <!--
> <bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource">
> <property name="serverName" value="localhost"/>
> <property name="databaseName" value="activemq"/>
> <property name="portNumber" value="0"/>
> <property name="user" value="activemq"/>
> <property name="password" value="activemq"/>
> <property name="dataSourceName" value="postgres"/>
> <property name="initialConnections" value="1"/>
> <property name="maxConnections" value="10"/>
> </bean>
> -->
>
> <!-- MySql DataSource Sample Setup -->
> <!--
> <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
> destroy-method="close">
> <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
> <property name="url" value="jdbc:mysql://localhost/activemq"/>
> <property name="username" value="activemq"/>
> <property name="password" value="activemq"/>
> <property name="poolPreparedStatements" value="true"/>
> </bean>
> -->
>
> <!-- Embedded Derby DataSource Sample Setup -->
> <!--
> <bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
> <property name="databaseName" value="derbydb"/>
> <property name="createDatabase" value="create"/>
> </bean>
> -->
>
> </beans>
> <!-- END SNIPPET: xbean -->
>
>
>
>
> APPLICATIONCONTEXT :
>
> <?xml version="1.0" encoding="UTF-8"?>
> <beans xmlns="http://xbean.org/schemas/spring/1.0"
> xmlns:sm="http://servicemix.apache.org/config/1.0"
> xmlns:my="http://servicemix.apache.org/demo/"
> xmlns:foo="http://servicemix.apache.org/demo/">
>
> <!-- the JBI container -->
> <sm:container id="jbi"
> rootDir="/home/souillac/serviceMix/wdir"
> useMBeanServer="true"
> createMBeanServer="true"
> installationDirPath="/home/souillac/serviceMix/install"
> deploymentDirPath="/home/souillac/serviceMix/deploy"
> monitorInstallationDirectory="true"
> dumpStats="true"
> statsInterval="10"
> transactionManager="#transactionManager">
>
> <sm:activationSpecs>
>
> <!-- an example HTTP binding for use by the
> SpringBindingServlet -->
> <!-- START SNIPPET: http -->
> <sm:activationSpec componentName="httpBinding"
> service="foo:httpBinding" destinationService="foo:echo">
> <sm:component><bean
> class="org.apache.servicemix.components.http.HttpInOutBinding"
> /></sm:component>
> </sm:activationSpec>
> <!-- END SNIPPET: http -->
>
> <!-- a simple Echo service to test InOut message exchanges using
> HTTP-->
> <sm:activationSpec componentName="echo" service="foo:echo" >
> <sm:component>
> <bean
> class="org.apache.servicemix.components.HelloWorldComponent">
> <property name="property" value="name"/>
> </bean>
> </sm:component>
> </sm:activationSpec>
>
> <!-- lets kick off a timer to send messages on an input
> destination topic -->
> <sm:activationSpec componentName="timer" service="my:timer"
> destinationService="my:inputSender">
> <sm:component>
> <bean
> class="org.apache.servicemix.components.quartz.QuartzComponent">
> <property name="triggers">
> <map>
> <entry>
> <key>
> <bean class="org.quartz.SimpleTrigger">
> <property name="repeatInterval" value="10000"/>
> <property name="repeatCount" value="2"/>
> </bean>
> </key>
> <bean class="org.quartz.JobDetail">
> <property name="name" value="My Example Job"/>
> <property name="group" value="ServiceMix"/>
> </bean>
> </entry>
> </map>
> </property>
> </bean>
> </sm:component>
> </sm:activationSpec>
>
> <sm:activationSpec componentName="inputSender"
> service="my:inputSender">
> <sm:component>
> <bean
> class="org.apache.servicemix.components.jms.JmsSenderComponent">
> <property name="template">
> <bean class="org.springframework.jms.core.JmsTemplate">
> <property name="connectionFactory">
> <ref local="jmsFactory"/>
> </property>
> <property name="defaultDestinationName"
> value="demo.org.apache.servicemix.source"/>
> <property name="pubSubDomain" value="true"/>
> </bean>
> </property>
> </bean>
> </sm:component>
> </sm:activationSpec>
>
>
> <!-- lets subscribe and republish on a different JMS destination
> - i.e. make a JMS bridge -->
> <sm:activationSpec componentName="inputReceiver"
> service="my:inputReceiver" destinationService="my:outputSender">
> <sm:component>
> <bean
> class="org.apache.servicemix.components.jms.JmsInUsingJCABinding">
> <property name="jcaContainer" ref="jencks"/>
> <property name="activationSpec">
> <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
> <property name="destination"
> value="demo.org.apache.servicemix.source"/>
> <property name="destinationType" value="javax.jms.Topic"/>
> </bean>
> </property>
> </bean>
> </sm:component>
> </sm:activationSpec>
>
>
> <sm:activationSpec componentName="outputSender"
> service="my:outputSender">
> <sm:component>
> <bean
> class="org.apache.servicemix.components.jms.JmsSenderComponent">
> <property name="template">
> <bean class="org.springframework.jms.core.JmsTemplate">
> <property name="connectionFactory">
> <ref local="jmsFactory"/>
> </property>
> <property name="defaultDestinationName"
> value="demo.org.apache.servicemix.result"/>
> <property name="pubSubDomain" value="true"/>
> </bean>
> </property>
> </bean>
> </sm:component>
> </sm:activationSpec>
>
>
> <!-- just to demonstrate that we are sending messages, lets trace
> the messages we receive -->
> <sm:activationSpec componentName="jmsTrace" service="my:jmsTrace"
> destinationService="my:trace">
> <sm:component>
> <bean
> class="org.apache.servicemix.components.jms.JmsInUsingJCABinding">
> <property name="jcaContainer" ref="jencks"/>
> <property name="activationSpec">
> <bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
> <property name="destination"
> value="demo.org.apache.servicemix.result"/>
> <property name="destinationType" value="javax.jms.Topic"/>
> </bean>
> </property>
> </bean>
> </sm:component>
> </sm:activationSpec>
>
> <sm:activationSpec componentName="trace" service="my:trace">
> <sm:component>
> <bean
> class="org.apache.servicemix.components.util.TraceComponent"/>
> </sm:component>
> </sm:activationSpec>
> </sm:activationSpecs>
> </sm:container>
>
>
> <!-- the JCA container -->
> <bean id="jencks" class="org.jencks.JCAContainer" singleton="true">
>
> <!-- lets use the default configuration of work manager and
> transaction manager-->
> <property name="bootstrapContext">
> <bean class="org.jencks.factory.BootstrapContextFactoryBean">
> <property name="threadPoolSize" value="25"/>
> </bean>
> </property>
>
> <!-- the JCA Resource Adapter -->
> <property name="resourceAdapter">
> <bean id="activeMQResourceAdapter"
> class="org.apache.activemq.ra.ActiveMQResourceAdapter" singleton="true">
> <property name="serverUrl" value="tcp://localhost:61636"/>
> </bean>
> </property>
> </bean>
>
> <!-- message broker -->
>
> <!-- ActiveMQ 3.x -->
> <bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
> <property name="config" value="/WEB-INF/activemq.xml"/>
> </bean>
>
> <!-- ActiveMQ 4.x -->
> <!--
> <bean id="broker" class="org.apache.activemq.broker.BrokerService"
> init-method="start">
> <property name="transportConnectorURIs"
> value="tcp://localhost:61636"/>
> </bean>
> -->
>
> <bean id="transactionManager"
> class="org.jencks.factory.TransactionManagerFactoryBean"/>
>
> <bean id="jmsFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory">
> <property name="connectionFactory">
> <bean class="org.apache.activemq.ActiveMQConnectionFactory">
> <constructor-arg value="tcp://localhost:61636"/>
> </bean>
> </property>
> </bean>
>
> </beans>
>
>
>
> Regards,
> Charles
>
> Guillaume Nodet wrote:
>
>> Take a look at
>> http://activemq.org/How+do+I+embed+a+Broker+inside+a+Connection
>> and at the servicemix main configuration files (servicemix.xml and
>> activemq.xml).
>>
>> Guillaume
>>
>> On 3/7/06, *Charles Souillard* <Charles.Souillard@ext.bull.net
>> <ma...@ext.bull.net> > wrote:
>>
>> Guillaume,
>>
>> I am able to start an ActiveMQ from the snapshot.
>> What do I have to do to start a broker from spring ?
>> Now I am not using the servicemix script to start as it is
>> encapsulated
>> in the webapp.
>> Perhaps these questions are ery easy but I am not very friendly with
>> Spring...
>> Thanks
>> Charles
>>
>> Guillaume Nodet wrote:
>>
>> > You can either start a broker from spring, as it is done in the
>> standalone
>> > distribution of ServiceMix, or use a standalone ActiveMQ broker
>> > (you will have to download and install it), or use any other jms
>> provider
>> > and configure you jms binding components to use it.
>> > ServiceMix clustering can only be done with ActiveMQ however.
>> >
>> > Guillaume
>> >
>> > On 3/7/06, *Charles Souillard * < Charles.Souillard@ext.bull.net
>> <ma...@ext.bull.net>
>> > <mailto:Charles.Souillard@ext.bull.net
>> <ma...@ext.bull.net>>> wrote:
>> >
>> > Guillaume,
>> >
>> > when I was using SM standalone, I didn't have to do anything
>> for using
>> > ActiveMQ.
>> > In the AMQ web site, it is written I have to go to AMQ
>> install dir..
>> > Where is it ?
>> > Do I have to download the latest snapshot of AMQ and
>> install it
>> > independantly ?
>> > Why it is not the same use as SM standalone ?
>> >
>> > Is it possible for me to use another JMS implementation ?
>> JORAM ?
>> >
>> > Thanks
>> > Charles
>> >
>> > Guillaume Nodet wrote:
>> >
>> > >On 3/7/06, Charles Souillard <
>> Charles.Souillard@ext.bull.net
>> <ma...@ext.bull.net>
>> > <mailto:Charles.Souillard@ext.bull.net
>> <ma...@ext.bull.net>>> wrote:
>> > >
>> > >
>> > >>Hi all,
>> > >>
>> > >>I want to know what I have to do with Active MQ to make
>> my SM
>> > running as
>> > >>a webapp.
>> > >>I am using SM through the available web app. I have
>> deployed it
>> > into a
>> > >>J2EE app server.
>> > >>I am able to install my component and to deploy SAs to my
>> component.
>> > >>
>> > >>What I am trying to do now is :
>> > >>
>> > >>1) understanding how ActiveMQ and SM are correlated
>> > >>
>> > >>
>> > >
>> > >
>> > >SM uses ActiveMQ for clustering and also support standard JMS
>> > brokers
>> > >as JMS binding components.
>> > >
>> > >2) what I have to do to make them running together
>> > >
>> > >
>> > >The distribution is full of examples using jms ...
>> > >
>> > >3) launching a client which send a JMS message to a Topic
>> on which a
>> > >
>> > >
>> > >>component is waiting for
>> > >>
>> > >>
>> > >
>> > >
>> > >You need to start an ActiveMQ broker :)
>> > >You want to take a look at http://activemq.org/
>> > <http://activemq.org/> for more infos.
>> > >
>> > >Guillaume Nodet
>> > >
>> > >When I try to launch my client, I get the following
>> exception :
>> > >
>> > >
>> > >>Can you please help me ?
>> > >>
>> > >>Thanks
>> > >>Charles
>> > >>
>> > >>
>> > >>Exception in thread "main" javax.jms.JMSException: Could not
>> > connect to
>> > >>broker URL: tcp://localhost:61616. Reason:
>> > java.net.ConnectException:
>> > >>Connection refused
>> > >> [java] at
>> > >>org.apache.activemq.util.JMSExceptionSupport.create(
>> > >>JMSExceptionSupport.java:32)
>> > >> [java] at
>> >
>> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
>>
>> > (
>> > >>ActiveMQConnectionFactory.java:244)
>> > >> [java] at
>> >
>> >>org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(
>> > >>ActiveMQConnectionFactory.java :186)
>> > >> [java] at JMSClient.main(Unknown Source)
>> > >> [java] Caused by: java.net.ConnectException:
>> Connection refused
>> > >> [java] at java.net.PlainSocketImpl.socketConnect
>> (Native
>> > Method)
>> > >> [java] at
>> > >>java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
>> > >> [java] at
>> > >>java.net.PlainSocketImpl.connectToAddress
>> (PlainSocketImpl.java:195)
>> > >> [java] at
>> > >> java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
>> > >> [java] at
>> > >>java.net.SocksSocketImpl.connect (SocksSocketImpl.java:366)
>> > >> [java] at java.net.Socket.connect(Socket.java :507)
>> > >> [java] at java.net.Socket.connect(Socket.java:457)
>> > >> [java] at
>> > >>org.apache.activemq.transport.tcp.TcpTransport.createSocket(
>> > >>TcpTransport.java:204)
>> > >> [java] at
>> > >>org.apache.activemq.transport.tcp.TcpTransport
>> .<init>(TcpTransport.java
>> > >>:79)
>> > >> [java] at
>> >
>> >>org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(
>> > >>TcpTransportFactory.java :115)
>> > >> [java] at
>> > >>org.apache.activemq.transport.TransportFactory.doConnect(
>> > >>TransportFactory.java:115)
>> > >> [java] at
>> > >> org.apache.activemq.transport.TransportFactory.doConnect (
>> > >>TransportFactory.java:42)
>> > >> [java] at
>> > >>org.apache.activemq.transport.TransportFactory.connect(
>> > >>TransportFactory.java:76)
>> > >> [java] at
>> >
>> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
>> > (
>> > >>ActiveMQConnectionFactory.java :216)
>> > >> [java] ... 2 more
>> > >> [java] Java Result: 1
>> > >>
>> > >>
>> > >>
>> > >>
>> > >>
>> > >>
>> > >>
>> > >>
>> > >
>> > >
>> > >
>> >
>> >
>>
>>
>
Re: ActiveMQ
Posted by Charles Souillard <Ch...@ext.bull.net>.
Guillaume,
There is already an applicationcontext.xml file and an activemq.xml
embeded in the web app.
I am sure they are used as I updated them to modify target directories
(install, deploy, wdir and data).
I can verify the directories are created.
So why my broker is not started ?
Do I have to do something else ?
You can find hereafter my activemq and applicationcontext xml files :
ACTIVEMQ :
<!-- START SNIPPET: xbean -->
<beans xmlns="http://activemq.org/config/1.0">
<broker useJmx="false">
<persistenceAdapter>
<journaledJDBC journalLogFiles="5"
dataDirectory="/home/souillac/serviceMix/data"/>
<!-- To use a different datasource, use th following syntax : -->
<!--
<journaledJDBC journalLogFiles="5" dataDirectory="../data"
dataSource="#postgres-ds"/>
-->
</persistenceAdapter>
<transportConnectors>
<transportConnector uri="tcp://localhost:61636"
discoveryUri="multicast://default"/>
</transportConnectors>
<networkConnectors>
<!-- by default just auto discover the other brokers -->
<networkConnector uri="multicast://default"/>
<!--
<networkConnector
uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
-->
</networkConnectors>
</broker>
<!-- This xbean configuration file supports all the standard spring
xml configuration options -->
<!-- Postgres DataSource Sample Setup -->
<!--
<bean id="postgres-ds" class="org.postgresql.ds.PGPoolingDataSource">
<property name="serverName" value="localhost"/>
<property name="databaseName" value="activemq"/>
<property name="portNumber" value="0"/>
<property name="user" value="activemq"/>
<property name="password" value="activemq"/>
<property name="dataSourceName" value="postgres"/>
<property name="initialConnections" value="1"/>
<property name="maxConnections" value="10"/>
</bean>
-->
<!-- MySql DataSource Sample Setup -->
<!--
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost/activemq"/>
<property name="username" value="activemq"/>
<property name="password" value="activemq"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
-->
<!-- Embedded Derby DataSource Sample Setup -->
<!--
<bean id="derby-ds" class="org.apache.derby.jdbc.EmbeddedDataSource">
<property name="databaseName" value="derbydb"/>
<property name="createDatabase" value="create"/>
</bean>
-->
</beans>
<!-- END SNIPPET: xbean -->
APPLICATIONCONTEXT :
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://xbean.org/schemas/spring/1.0"
xmlns:sm="http://servicemix.apache.org/config/1.0"
xmlns:my="http://servicemix.apache.org/demo/"
xmlns:foo="http://servicemix.apache.org/demo/">
<!-- the JBI container -->
<sm:container id="jbi"
rootDir="/home/souillac/serviceMix/wdir"
useMBeanServer="true"
createMBeanServer="true"
installationDirPath="/home/souillac/serviceMix/install"
deploymentDirPath="/home/souillac/serviceMix/deploy"
monitorInstallationDirectory="true"
dumpStats="true"
statsInterval="10"
transactionManager="#transactionManager">
<sm:activationSpecs>
<!-- an example HTTP binding for use by the SpringBindingServlet -->
<!-- START SNIPPET: http -->
<sm:activationSpec componentName="httpBinding"
service="foo:httpBinding" destinationService="foo:echo">
<sm:component><bean
class="org.apache.servicemix.components.http.HttpInOutBinding"
/></sm:component>
</sm:activationSpec>
<!-- END SNIPPET: http -->
<!-- a simple Echo service to test InOut message exchanges using
HTTP-->
<sm:activationSpec componentName="echo" service="foo:echo" >
<sm:component>
<bean
class="org.apache.servicemix.components.HelloWorldComponent">
<property name="property" value="name"/>
</bean>
</sm:component>
</sm:activationSpec>
<!-- lets kick off a timer to send messages on an input
destination topic -->
<sm:activationSpec componentName="timer" service="my:timer"
destinationService="my:inputSender">
<sm:component>
<bean
class="org.apache.servicemix.components.quartz.QuartzComponent">
<property name="triggers">
<map>
<entry>
<key>
<bean class="org.quartz.SimpleTrigger">
<property name="repeatInterval" value="10000"/>
<property name="repeatCount" value="2"/>
</bean>
</key>
<bean class="org.quartz.JobDetail">
<property name="name" value="My Example Job"/>
<property name="group" value="ServiceMix"/>
</bean>
</entry>
</map>
</property>
</bean>
</sm:component>
</sm:activationSpec>
<sm:activationSpec componentName="inputSender"
service="my:inputSender">
<sm:component>
<bean
class="org.apache.servicemix.components.jms.JmsSenderComponent">
<property name="template">
<bean class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<ref local="jmsFactory"/>
</property>
<property name="defaultDestinationName"
value="demo.org.apache.servicemix.source"/>
<property name="pubSubDomain" value="true"/>
</bean>
</property>
</bean>
</sm:component>
</sm:activationSpec>
<!-- lets subscribe and republish on a different JMS destination -
i.e. make a JMS bridge -->
<sm:activationSpec componentName="inputReceiver"
service="my:inputReceiver" destinationService="my:outputSender">
<sm:component>
<bean
class="org.apache.servicemix.components.jms.JmsInUsingJCABinding">
<property name="jcaContainer" ref="jencks"/>
<property name="activationSpec">
<bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
<property name="destination"
value="demo.org.apache.servicemix.source"/>
<property name="destinationType" value="javax.jms.Topic"/>
</bean>
</property>
</bean>
</sm:component>
</sm:activationSpec>
<sm:activationSpec componentName="outputSender"
service="my:outputSender">
<sm:component>
<bean
class="org.apache.servicemix.components.jms.JmsSenderComponent">
<property name="template">
<bean class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<ref local="jmsFactory"/>
</property>
<property name="defaultDestinationName"
value="demo.org.apache.servicemix.result"/>
<property name="pubSubDomain" value="true"/>
</bean>
</property>
</bean>
</sm:component>
</sm:activationSpec>
<!-- just to demonstrate that we are sending messages, lets trace
the messages we receive -->
<sm:activationSpec componentName="jmsTrace" service="my:jmsTrace"
destinationService="my:trace">
<sm:component>
<bean
class="org.apache.servicemix.components.jms.JmsInUsingJCABinding">
<property name="jcaContainer" ref="jencks"/>
<property name="activationSpec">
<bean class="org.apache.activemq.ra.ActiveMQActivationSpec">
<property name="destination"
value="demo.org.apache.servicemix.result"/>
<property name="destinationType" value="javax.jms.Topic"/>
</bean>
</property>
</bean>
</sm:component>
</sm:activationSpec>
<sm:activationSpec componentName="trace" service="my:trace">
<sm:component>
<bean
class="org.apache.servicemix.components.util.TraceComponent"/>
</sm:component>
</sm:activationSpec>
</sm:activationSpecs>
</sm:container>
<!-- the JCA container -->
<bean id="jencks" class="org.jencks.JCAContainer" singleton="true">
<!-- lets use the default configuration of work manager and
transaction manager-->
<property name="bootstrapContext">
<bean class="org.jencks.factory.BootstrapContextFactoryBean">
<property name="threadPoolSize" value="25"/>
</bean>
</property>
<!-- the JCA Resource Adapter -->
<property name="resourceAdapter">
<bean id="activeMQResourceAdapter"
class="org.apache.activemq.ra.ActiveMQResourceAdapter" singleton="true">
<property name="serverUrl" value="tcp://localhost:61636"/>
</bean>
</property>
</bean>
<!-- message broker -->
<!-- ActiveMQ 3.x -->
<bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
<property name="config" value="/WEB-INF/activemq.xml"/>
</bean>
<!-- ActiveMQ 4.x -->
<!--
<bean id="broker" class="org.apache.activemq.broker.BrokerService"
init-method="start">
<property name="transportConnectorURIs" value="tcp://localhost:61636"/>
</bean>
-->
<bean id="transactionManager"
class="org.jencks.factory.TransactionManagerFactoryBean"/>
<bean id="jmsFactory"
class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<constructor-arg value="tcp://localhost:61636"/>
</bean>
</property>
</bean>
</beans>
Regards,
Charles
Guillaume Nodet wrote:
> Take a look at
> http://activemq.org/How+do+I+embed+a+Broker+inside+a+Connection
> and at the servicemix main configuration files (servicemix.xml and
> activemq.xml).
>
> Guillaume
>
> On 3/7/06, *Charles Souillard* <Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net> > wrote:
>
> Guillaume,
>
> I am able to start an ActiveMQ from the snapshot.
> What do I have to do to start a broker from spring ?
> Now I am not using the servicemix script to start as it is
> encapsulated
> in the webapp.
> Perhaps these questions are ery easy but I am not very friendly with
> Spring...
> Thanks
> Charles
>
> Guillaume Nodet wrote:
>
> > You can either start a broker from spring, as it is done in the
> standalone
> > distribution of ServiceMix, or use a standalone ActiveMQ broker
> > (you will have to download and install it), or use any other jms
> provider
> > and configure you jms binding components to use it.
> > ServiceMix clustering can only be done with ActiveMQ however.
> >
> > Guillaume
> >
> > On 3/7/06, *Charles Souillard * < Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>
> > <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>>> wrote:
> >
> > Guillaume,
> >
> > when I was using SM standalone, I didn't have to do anything
> for using
> > ActiveMQ.
> > In the AMQ web site, it is written I have to go to AMQ
> install dir..
> > Where is it ?
> > Do I have to download the latest snapshot of AMQ and install it
> > independantly ?
> > Why it is not the same use as SM standalone ?
> >
> > Is it possible for me to use another JMS implementation ?
> JORAM ?
> >
> > Thanks
> > Charles
> >
> > Guillaume Nodet wrote:
> >
> > >On 3/7/06, Charles Souillard <
> Charles.Souillard@ext.bull.net <ma...@ext.bull.net>
> > <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>>> wrote:
> > >
> > >
> > >>Hi all,
> > >>
> > >>I want to know what I have to do with Active MQ to make my SM
> > running as
> > >>a webapp.
> > >>I am using SM through the available web app. I have
> deployed it
> > into a
> > >>J2EE app server.
> > >>I am able to install my component and to deploy SAs to my
> component.
> > >>
> > >>What I am trying to do now is :
> > >>
> > >>1) understanding how ActiveMQ and SM are correlated
> > >>
> > >>
> > >
> > >
> > >SM uses ActiveMQ for clustering and also support standard JMS
> > brokers
> > >as JMS binding components.
> > >
> > >2) what I have to do to make them running together
> > >
> > >
> > >The distribution is full of examples using jms ...
> > >
> > >3) launching a client which send a JMS message to a Topic
> on which a
> > >
> > >
> > >>component is waiting for
> > >>
> > >>
> > >
> > >
> > >You need to start an ActiveMQ broker :)
> > >You want to take a look at http://activemq.org/
> > <http://activemq.org/> for more infos.
> > >
> > >Guillaume Nodet
> > >
> > >When I try to launch my client, I get the following
> exception :
> > >
> > >
> > >>Can you please help me ?
> > >>
> > >>Thanks
> > >>Charles
> > >>
> > >>
> > >>Exception in thread "main" javax.jms.JMSException: Could not
> > connect to
> > >>broker URL: tcp://localhost:61616. Reason:
> > java.net.ConnectException:
> > >>Connection refused
> > >> [java] at
> > >>org.apache.activemq.util.JMSExceptionSupport.create(
> > >>JMSExceptionSupport.java:32)
> > >> [java] at
> >
> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
>
> > (
> > >>ActiveMQConnectionFactory.java:244)
> > >> [java] at
> >
> >>org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(
> > >>ActiveMQConnectionFactory.java :186)
> > >> [java] at JMSClient.main(Unknown Source)
> > >> [java] Caused by: java.net.ConnectException:
> Connection refused
> > >> [java] at java.net.PlainSocketImpl.socketConnect
> (Native
> > Method)
> > >> [java] at
> > >>java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
> > >> [java] at
> > >>java.net.PlainSocketImpl.connectToAddress
> (PlainSocketImpl.java:195)
> > >> [java] at
> > >> java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
> > >> [java] at
> > >>java.net.SocksSocketImpl.connect (SocksSocketImpl.java:366)
> > >> [java] at java.net.Socket.connect(Socket.java :507)
> > >> [java] at java.net.Socket.connect(Socket.java:457)
> > >> [java] at
> > >>org.apache.activemq.transport.tcp.TcpTransport.createSocket(
> > >>TcpTransport.java:204)
> > >> [java] at
> > >>org.apache.activemq.transport.tcp.TcpTransport
> .<init>(TcpTransport.java
> > >>:79)
> > >> [java] at
> >
> >>org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(
> > >>TcpTransportFactory.java :115)
> > >> [java] at
> > >>org.apache.activemq.transport.TransportFactory.doConnect(
> > >>TransportFactory.java:115)
> > >> [java] at
> > >> org.apache.activemq.transport.TransportFactory.doConnect (
> > >>TransportFactory.java:42)
> > >> [java] at
> > >>org.apache.activemq.transport.TransportFactory.connect(
> > >>TransportFactory.java:76)
> > >> [java] at
> >
> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
> > (
> > >>ActiveMQConnectionFactory.java :216)
> > >> [java] ... 2 more
> > >> [java] Java Result: 1
> > >>
> > >>
> > >>
> > >>
> > >>
> > >>
> > >>
> > >>
> > >
> > >
> > >
> >
> >
>
>
Re: ActiveMQ
Posted by Charles Souillard <Ch...@ext.bull.net>.
It is running for that point on my side now.
Thanks
Charles
Guillaume Nodet wrote:
>
>
> On 3/9/06, *Charles Souillard* <Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>> wrote:
>
> Guillaume,
>
> I had a look at the links you send me. I am not sure to understand
> which
> lines must be added or removes from xml files.
> My undestanding is :
>
> When SM is used standalone, the servicemix.xml (1) files are
> configuring
> the activeMQ server.
> When SM is used as a webapp, applicationContext.xml and
> activeMQ.xml (2)
> files are used.
>
>
> Both are spring configuration files, so this is not specific to the
> fact that
> SM is standalone or embedded in a web app.
> This is only a spring configuration problem...
> But there are multiple ways do achieve the same result.
>
> I am trying to see which lines are written in (1) and not in (2)
> to have
> my activeMQ server started...
>
> Is it correct to remove from (1) :
> <bean id="jmsFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory ">
> <property name="connectionFactory">
> <bean class="org.apache.activemq.ActiveMQConnectionFactory">
> <constructor-arg value="tcp://localhost:61636"/>
> </bean>
> </property>
> </bean>
>
> And add to (1) :
>
> <bean id="broker" class="org.apache.activemq.xbean.BrokerFactoryBean">
> <property name="config" value="classpath: activemq.xml" />
> <property name="start" value="true" />
> </bean>
>
> <bean id="jmsFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory ">
> <property name="connectionFactory">
> <bean
> class="org.apache.activemq.ActiveMQConnectionFactory">
> <property name="brokerURL">
> <value>tcp://localhost:61616</value>
> </property>
> </bean>
> </property>
> </bean>
>
> The problem is that I will have to beans with id=broker...
>
>
> The jmsFactory usually does not create the broker, it is used to access
> it using the specified url (tcp://...).
> To create the broker, you can have a
> org.apache.activemq.xbean.BrokerFactoryBean
> that will use spring to parse an external file (see standalone SM
> config), or just load the specified configuration file (as done in the
> webapp).
>
> Guillaume
>
> Can you tell me what is the correct way ?
>
> Thanks
> Charles
>
> Guillaume Nodet wrote:
>
> > Take a look at
> > http://activemq.org/How+do+I+embed+a+Broker+inside+a+Connection
> <http://activemq.org/How+do+I+embed+a+Broker+inside+a+Connection>
> > and at the servicemix main configuration files (servicemix.xml and
> > activemq.xml).
> >
> > Guillaume
> >
> > On 3/7/06, *Charles Souillard* < Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>
> > <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>> > wrote:
> >
> > Guillaume,
> >
> > I am able to start an ActiveMQ from the snapshot.
> > What do I have to do to start a broker from spring ?
> > Now I am not using the servicemix script to start as it is
> > encapsulated
> > in the webapp.
> > Perhaps these questions are ery easy but I am not very
> friendly with
> > Spring...
> > Thanks
> > Charles
> >
> > Guillaume Nodet wrote:
> >
> > > You can either start a broker from spring, as it is done
> in the
> > standalone
> > > distribution of ServiceMix, or use a standalone ActiveMQ
> broker
> > > (you will have to download and install it), or use any
> other jms
> > provider
> > > and configure you jms binding components to use it.
> > > ServiceMix clustering can only be done with ActiveMQ however.
> > >
> > > Guillaume
> > >
> > > On 3/7/06, *Charles Souillard * <
> Charles.Souillard@ext.bull.net <ma...@ext.bull.net>
> > <mailto: Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>>
> > > <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>
> > <mailto: Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>>>> wrote:
> > >
> > > Guillaume,
> > >
> > > when I was using SM standalone, I didn't have to do
> anything
> > for using
> > > ActiveMQ.
> > > In the AMQ web site, it is written I have to go to AMQ
> > install dir..
> > > Where is it ?
> > > Do I have to download the latest snapshot of AMQ and
> install it
> > > independantly ?
> > > Why it is not the same use as SM standalone ?
> > >
> > > Is it possible for me to use another JMS implementation ?
> > JORAM ?
> > >
> > > Thanks
> > > Charles
> > >
> > > Guillaume Nodet wrote:
> > >
> > > >On 3/7/06, Charles Souillard <
> > Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>
> <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>>
> > > <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>
> > <mailto:Charles.Souillard@ext.bull.net
> <ma...@ext.bull.net>>>> wrote:
> > > >
> > > >
> > > >>Hi all,
> > > >>
> > > >>I want to know what I have to do with Active MQ to
> make my SM
> > > running as
> > > >>a webapp.
> > > >>I am using SM through the available web app. I have
> > deployed it
> > > into a
> > > >>J2EE app server.
> > > >>I am able to install my component and to deploy SAs
> to my
> > component.
> > > >>
> > > >>What I am trying to do now is :
> > > >>
> > > >>1) understanding how ActiveMQ and SM are correlated
> > > >>
> > > >>
> > > >
> > > >
> > > >SM uses ActiveMQ for clustering and also support
> standard JMS
> > > brokers
> > > >as JMS binding components.
> > > >
> > > >2) what I have to do to make them running together
> > > >
> > > >
> > > >The distribution is full of examples using jms ...
> > > >
> > > >3) launching a client which send a JMS message to a Topic
> > on which a
> > > >
> > > >
> > > >>component is waiting for
> > > >>
> > > >>
> > > >
> > > >
> > > >You need to start an ActiveMQ broker :)
> > > >You want to take a look at http://activemq.org/
> > > <http://activemq.org/> for more infos.
> > > >
> > > >Guillaume Nodet
> > > >
> > > >When I try to launch my client, I get the following
> > exception :
> > > >
> > > >
> > > >>Can you please help me ?
> > > >>
> > > >>Thanks
> > > >>Charles
> > > >>
> > > >>
> > > >>Exception in thread "main" javax.jms.JMSException:
> Could not
> > > connect to
> > > >>broker URL: tcp://localhost:61616. Reason:
> > > java.net.ConnectException:
> > > >>Connection refused
> > > >> [java] at
> > > >>org.apache.activemq.util.JMSExceptionSupport.create(
> > > >>JMSExceptionSupport.java:32)
> > > >> [java] at
> > >
> >
> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
> >
> > > (
> > > >>ActiveMQConnectionFactory.java:244)
> > > >> [java] at
> > >
> >
> >>org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(
> > > >>ActiveMQConnectionFactory.java :186)
> > > >> [java] at JMSClient.main(Unknown Source)
> > > >> [java] Caused by: java.net.ConnectException:
> > Connection refused
> > > >> [java] at
> java.net.PlainSocketImpl.socketConnect
> > (Native
> > > Method)
> > > >> [java] at
> > >
> >>java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
> > > >> [java] at
> > > >>java.net.PlainSocketImpl.connectToAddress
> > (PlainSocketImpl.java:195)
> > > >> [java] at
> > > >> java.net.PlainSocketImpl.connect
> (PlainSocketImpl.java:182)
> > > >> [java] at
> > > >>java.net.SocksSocketImpl.connect
> (SocksSocketImpl.java:366)
> > > >> [java] at java.net.Socket.connect
> (Socket.java :507)
> > > >> [java] at
> java.net.Socket.connect(Socket.java:457)
> > > >> [java] at
> > >
> >>org.apache.activemq.transport.tcp.TcpTransport.createSocket (
> > > >>TcpTransport.java:204)
> > > >> [java] at
> > > >>org.apache.activemq.transport.tcp.TcpTransport
> > .<init>(TcpTransport.java
> > > >>:79)
> > > >> [java] at
> > >
> >
> >>org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(
> > > >>TcpTransportFactory.java :115)
> > > >> [java] at
> > >
> >>org.apache.activemq.transport.TransportFactory.doConnect(
> > > >>TransportFactory.java:115)
> > > >> [java] at
> > > >>
> org.apache.activemq.transport.TransportFactory.doConnect (
> > > >>TransportFactory.java:42)
> > > >> [java] at
> > > >> org.apache.activemq.transport.TransportFactory.connect(
> > > >>TransportFactory.java:76)
> > > >> [java] at
> > >
> >
> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection
>
> > > (
> > > >>ActiveMQConnectionFactory.java :216)
> > > >> [java] ... 2 more
> > > >> [java] Java Result: 1
> > > >>
> > > >>
> > > >>
> > > >>
> > > >>
> > > >>
> > > >>
> > > >>
> > > >
> > > >
> > > >
> > >
> > >
> >
> >
>
>
Re: ActiveMQ
Posted by Guillaume Nodet <gn...@gmail.com>.
You can either start a broker from spring, as it is done in the standalone
distribution of ServiceMix, or use a standalone ActiveMQ broker
(you will have to download and install it), or use any other jms provider
and configure you jms binding components to use it.
ServiceMix clustering can only be done with ActiveMQ however.
Guillaume
On 3/7/06, Charles Souillard <Ch...@ext.bull.net> wrote:
>
> Guillaume,
>
> when I was using SM standalone, I didn't have to do anything for using
> ActiveMQ.
> In the AMQ web site, it is written I have to go to AMQ install dir..
> Where is it ?
> Do I have to download the latest snapshot of AMQ and install it
> independantly ?
> Why it is not the same use as SM standalone ?
>
> Is it possible for me to use another JMS implementation ? JORAM ?
>
> Thanks
> Charles
>
> Guillaume Nodet wrote:
>
> >On 3/7/06, Charles Souillard <Ch...@ext.bull.net> wrote:
> >
> >
> >>Hi all,
> >>
> >>I want to know what I have to do with Active MQ to make my SM running as
> >>a webapp.
> >>I am using SM through the available web app. I have deployed it into a
> >>J2EE app server.
> >>I am able to install my component and to deploy SAs to my component.
> >>
> >>What I am trying to do now is :
> >>
> >>1) understanding how ActiveMQ and SM are correlated
> >>
> >>
> >
> >
> >SM uses ActiveMQ for clustering and also support standard JMS brokers
> >as JMS binding components.
> >
> >2) what I have to do to make them running together
> >
> >
> >The distribution is full of examples using jms ...
> >
> >3) launching a client which send a JMS message to a Topic on which a
> >
> >
> >>component is waiting for
> >>
> >>
> >
> >
> >You need to start an ActiveMQ broker :)
> >You want to take a look at http://activemq.org/ for more infos.
> >
> >Guillaume Nodet
> >
> >When I try to launch my client, I get the following exception :
> >
> >
> >>Can you please help me ?
> >>
> >>Thanks
> >>Charles
> >>
> >>
> >>Exception in thread "main" javax.jms.JMSException: Could not connect to
> >>broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
> >>Connection refused
> >> [java] at
> >>org.apache.activemq.util.JMSExceptionSupport.create(
> >>JMSExceptionSupport.java:32)
> >> [java] at
> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
> >>ActiveMQConnectionFactory.java:244)
> >> [java] at
> >>org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(
> >>ActiveMQConnectionFactory.java:186)
> >> [java] at JMSClient.main(Unknown Source)
> >> [java] Caused by: java.net.ConnectException: Connection refused
> >> [java] at java.net.PlainSocketImpl.socketConnect(Native Method)
> >> [java] at
> >>java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
> >> [java] at
> >>java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
> >> [java] at
> >>java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
> >> [java] at
> >>java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
> >> [java] at java.net.Socket.connect(Socket.java:507)
> >> [java] at java.net.Socket.connect(Socket.java:457)
> >> [java] at
> >>org.apache.activemq.transport.tcp.TcpTransport.createSocket(
> >>TcpTransport.java:204)
> >> [java] at
> >>org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java
> >>:79)
> >> [java] at
> >>org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(
> >>TcpTransportFactory.java:115)
> >> [java] at
> >>org.apache.activemq.transport.TransportFactory.doConnect(
> >>TransportFactory.java:115)
> >> [java] at
> >>org.apache.activemq.transport.TransportFactory.doConnect(
> >>TransportFactory.java:42)
> >> [java] at
> >>org.apache.activemq.transport.TransportFactory.connect(
> >>TransportFactory.java:76)
> >> [java] at
> >>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
> >>ActiveMQConnectionFactory.java:216)
> >> [java] ... 2 more
> >> [java] Java Result: 1
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >>
> >
> >
> >
>
Re: ActiveMQ
Posted by Charles Souillard <Ch...@ext.bull.net>.
Guillaume,
when I was using SM standalone, I didn't have to do anything for using
ActiveMQ.
In the AMQ web site, it is written I have to go to AMQ install dir..
Where is it ?
Do I have to download the latest snapshot of AMQ and install it
independantly ?
Why it is not the same use as SM standalone ?
Is it possible for me to use another JMS implementation ? JORAM ?
Thanks
Charles
Guillaume Nodet wrote:
>On 3/7/06, Charles Souillard <Ch...@ext.bull.net> wrote:
>
>
>>Hi all,
>>
>>I want to know what I have to do with Active MQ to make my SM running as
>>a webapp.
>>I am using SM through the available web app. I have deployed it into a
>>J2EE app server.
>>I am able to install my component and to deploy SAs to my component.
>>
>>What I am trying to do now is :
>>
>>1) understanding how ActiveMQ and SM are correlated
>>
>>
>
>
>SM uses ActiveMQ for clustering and also support standard JMS brokers
>as JMS binding components.
>
>2) what I have to do to make them running together
>
>
>The distribution is full of examples using jms ...
>
>3) launching a client which send a JMS message to a Topic on which a
>
>
>>component is waiting for
>>
>>
>
>
>You need to start an ActiveMQ broker :)
>You want to take a look at http://activemq.org/ for more infos.
>
>Guillaume Nodet
>
>When I try to launch my client, I get the following exception :
>
>
>>Can you please help me ?
>>
>>Thanks
>>Charles
>>
>>
>>Exception in thread "main" javax.jms.JMSException: Could not connect to
>>broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
>>Connection refused
>> [java] at
>>org.apache.activemq.util.JMSExceptionSupport.create(
>>JMSExceptionSupport.java:32)
>> [java] at
>>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
>>ActiveMQConnectionFactory.java:244)
>> [java] at
>>org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(
>>ActiveMQConnectionFactory.java:186)
>> [java] at JMSClient.main(Unknown Source)
>> [java] Caused by: java.net.ConnectException: Connection refused
>> [java] at java.net.PlainSocketImpl.socketConnect(Native Method)
>> [java] at
>>java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
>> [java] at
>>java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
>> [java] at
>>java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
>> [java] at
>>java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
>> [java] at java.net.Socket.connect(Socket.java:507)
>> [java] at java.net.Socket.connect(Socket.java:457)
>> [java] at
>>org.apache.activemq.transport.tcp.TcpTransport.createSocket(
>>TcpTransport.java:204)
>> [java] at
>>org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java
>>:79)
>> [java] at
>>org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(
>>TcpTransportFactory.java:115)
>> [java] at
>>org.apache.activemq.transport.TransportFactory.doConnect(
>>TransportFactory.java:115)
>> [java] at
>>org.apache.activemq.transport.TransportFactory.doConnect(
>>TransportFactory.java:42)
>> [java] at
>>org.apache.activemq.transport.TransportFactory.connect(
>>TransportFactory.java:76)
>> [java] at
>>org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
>>ActiveMQConnectionFactory.java:216)
>> [java] ... 2 more
>> [java] Java Result: 1
>>
>>
>>
>>
>>
>>
>>
>>
>
>
>
Re: ActiveMQ
Posted by Guillaume Nodet <gn...@gmail.com>.
On 3/7/06, Charles Souillard <Ch...@ext.bull.net> wrote:
>
> Hi all,
>
> I want to know what I have to do with Active MQ to make my SM running as
> a webapp.
> I am using SM through the available web app. I have deployed it into a
> J2EE app server.
> I am able to install my component and to deploy SAs to my component.
>
> What I am trying to do now is :
>
> 1) understanding how ActiveMQ and SM are correlated
SM uses ActiveMQ for clustering and also support standard JMS brokers
as JMS binding components.
2) what I have to do to make them running together
The distribution is full of examples using jms ...
3) launching a client which send a JMS message to a Topic on which a
> component is waiting for
You need to start an ActiveMQ broker :)
You want to take a look at http://activemq.org/ for more infos.
Guillaume Nodet
When I try to launch my client, I get the following exception :
>
> Can you please help me ?
>
> Thanks
> Charles
>
>
> Exception in thread "main" javax.jms.JMSException: Could not connect to
> broker URL: tcp://localhost:61616. Reason: java.net.ConnectException:
> Connection refused
> [java] at
> org.apache.activemq.util.JMSExceptionSupport.create(
> JMSExceptionSupport.java:32)
> [java] at
> org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
> ActiveMQConnectionFactory.java:244)
> [java] at
> org.apache.activemq.ActiveMQConnectionFactory.createTopicConnection(
> ActiveMQConnectionFactory.java:186)
> [java] at JMSClient.main(Unknown Source)
> [java] Caused by: java.net.ConnectException: Connection refused
> [java] at java.net.PlainSocketImpl.socketConnect(Native Method)
> [java] at
> java.net.PlainSocketImpl.doConnect(PlainSocketImpl.java:333)
> [java] at
> java.net.PlainSocketImpl.connectToAddress(PlainSocketImpl.java:195)
> [java] at
> java.net.PlainSocketImpl.connect(PlainSocketImpl.java:182)
> [java] at
> java.net.SocksSocketImpl.connect(SocksSocketImpl.java:366)
> [java] at java.net.Socket.connect(Socket.java:507)
> [java] at java.net.Socket.connect(Socket.java:457)
> [java] at
> org.apache.activemq.transport.tcp.TcpTransport.createSocket(
> TcpTransport.java:204)
> [java] at
> org.apache.activemq.transport.tcp.TcpTransport.<init>(TcpTransport.java
> :79)
> [java] at
> org.apache.activemq.transport.tcp.TcpTransportFactory.createTransport(
> TcpTransportFactory.java:115)
> [java] at
> org.apache.activemq.transport.TransportFactory.doConnect(
> TransportFactory.java:115)
> [java] at
> org.apache.activemq.transport.TransportFactory.doConnect(
> TransportFactory.java:42)
> [java] at
> org.apache.activemq.transport.TransportFactory.connect(
> TransportFactory.java:76)
> [java] at
> org.apache.activemq.ActiveMQConnectionFactory.createActiveMQConnection(
> ActiveMQConnectionFactory.java:216)
> [java] ... 2 more
> [java] Java Result: 1
>
>
>
>
>
>