activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: activemq in servicemix
Date Thu, 24 Jan 2013 15:45:55 GMT
I just tried this on my side with the following Camel route, everything
seemed to work just fine.
What are you seeing in the logs? When you startup servicemix can you
connect to the broker at tcp://localhost:61616 using an external JMS
client? If you run 'netstat -a | grep LISTEN' do you see the broker
listening on port 61616? I can send you my sample project that I used to
deploy the route below if that's of interest to you...


    <bean id="activeMQConnectionFactory"
          class="org.apache.activemq.ActiveMQXAConnectionFactory"
          lazy-init="false" scope="singleton">
        <property name="brokerURL" value="tcp://localhost:61616" />
    </bean>

    <bean id="jms"
class="org.apache.activemq.camel.component.ActiveMQComponent">
        <property name="connectionFactory" ref="activeMQConnectionFactory"/>
    </bean>

    <camelContext xmlns="http://camel.apache.org/schema/spring">
        <route id="sampleJmsRoute">
            <from uri="timer:myTimer?period=5000"/>
            <transform>
                <constant>Hi</constant>
            </transform>
            <to uri="jms:outgoingQueue" />
        </route>
    </camelContext>


On Wed, Jan 23, 2013 at 7:19 AM, jainmanglesh
<jainmanglesh@rediffmail.com>wrote:

> Thank you very much for your quick reply.
> Yes I do have activemq-broker.xml file under ${servicemix_home}\etc.
>
> following are the contents of this file:
> <blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
>
> xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
>
> xmlns:ext="http://aries.apache.org/blueprint/xmlns/blueprint-ext/v1.0.0"
>            xmlns:amq="http://activemq.apache.org/schema/core">
>
>     <manifest>
>       Export-Service = javax.jms.ConnectionFactory
>     </manifest>
>
>
>     <ext:property-placeholder />
>
>     <broker xmlns="http://activemq.apache.org/schema/core"
> brokerName="default" dataDirectory="${karaf.data}/activemq/default"
> useShutdownHook="false">
>
>
>
>         <destinationPolicy>
>             <policyMap>
>               <policyEntries>
>                 <policyEntry topic=">" producerFlowControl="true"
> memoryLimit="1mb">
>                   <pendingSubscriberPolicy>
>                     <vmCursor />
>                   </pendingSubscriberPolicy>
>                 </policyEntry>
>                 <policyEntry queue=">" producerFlowControl="true"
> memoryLimit="1mb">
>
>                 </policyEntry>
>               </policyEntries>
>             </policyMap>
>         </destinationPolicy>
>
>
>         <managementContext>
>             <managementContext createConnector="false"/>
>         </managementContext>
>
>
>         <persistenceAdapter>
>             <kahaDB directory="${karaf.data}/activemq/default/kahadb"/>
>         </persistenceAdapter>
>
>
>
>
>         <amq:transportConnectors>
>             <amq:transportConnector name="openwire"
> uri="tcp://localhost:61616"/>
>             <amq:transportConnector name="stomp"
> uri="stomp://localhost:61613"/>
>         </amq:transportConnectors>
>
>     </broker>
>
>     <bean id="activemqConnectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory">
>
>         <property name="brokerURL" value="tcp://localhost:61616" />
>     </bean>
>
>     <bean id="pooledConnectionFactory"
> class="org.apache.activemq.pool.PooledConnectionFactory">
>         <property name="maxConnections" value="8" />
>         <property name="connectionFactory" ref="activemqConnectionFactory"
> />
>     </bean>
>
>     <bean id="resourceManager"
> class="org.apache.activemq.pool.ActiveMQResourceManager"
> init-method="recoverResource">
>           <property name="transactionManager" ref="transactionManager" />
>           <property name="connectionFactory"
> ref="activemqConnectionFactory"
> />
>           <property name="resourceName" value="activemq.default" />
>     </bean>
>
>     <reference id="transactionManager"
> interface="javax.transaction.TransactionManager" />
>
>     <service ref="pooledConnectionFactory"
> interface="javax.jms.ConnectionFactory">
>         <service-properties>
>             <entry key="name" value="localhost"/>
>         </service-properties>
>     </service>
>
> </blueprint>
>
>
> I tried with both localhost and 0.0.0.0 in trasportConnector. I also tried
> with using only transportConnector (instead of amq:transportconnector).
>
> in the java code while creating connection from connectionFactory, I am
> passing following through spring injection:
>         <bean id="activeMQConnectionFactory"
> class="org.apache.activemq.ActiveMQXAConnectionFactory"
>                 lazy-init="false" scope="singleton">
>                 <property name="brokerURL" value="tcp://localhost:61616" />
>         </bean>
>
> here also I tried with both localhost and 0.0.0.0.
>
> I already have activemq on karaf(servicemix) server, as can be seen from
> following command run on server:
>
> karaf@root> list | grep activemq
> [ 285] [Active     ] [            ] [       ] [   60] activemq-ra
> (5.5.1.fuse-01-06)
> [ 286] [Active     ] [            ] [       ] [   60] activemq-core
> (5.5.1.fuse-01-06)
> [ 287] [Active     ] [Created     ] [       ] [   60] activemq-karaf
> (5.5.1.fuse-01-06)
> [ 288] [Active     ] [            ] [       ] [   60] activemq-pool
> (5.5.1.fuse-01-06)
> [ 289] [Active     ] [            ] [       ] [   60] activemq-console
> (5.5.1.fuse-01-06)
> [ 309] [Active     ] [            ] [       ] [   60] activemq-spring
> (5.5.1.fuse-01-06)
> karaf@root> features:list | grep activemq
> [installed  ] [5.5.1-fuse-01-06    ] activemq
> activemq-5.5.1-fuse-01-06
> [installed  ] [5.5.1-fuse-01-06    ] activemq-spring
> activemq-5.5.1-fuse-01-06
> [installed  ] [5.5.1-fuse-01-06    ] activemq-blueprint
> activemq-5.5.1-fuse-01-06
> [uninstalled] [5.5.1-fuse-01-06    ] activemq-web-console
> activemq-5.5.1-fuse-01-06
> [installed  ] [4.4.1-fuse-01-06    ] camel-activemq
> repo-0
> [installed  ] [4.4.1-fuse-01-06    ] activemq-broker
> repo-0
>
>
> Please let me know if more details are required. I already have spent long
> time to find this out on google however could not find anything fruitful.
>
> Help much appreciated.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/activemq-in-servicemix-tp4662070p4662077.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message