Background:

I'm using spring + camel + activemq in boths sender and receiver.

Relevant receiver spring's cfg:

<amq:broker useJmx="false" persistent="false">
        <amq:transportConnectors>
                <amq:transportConnector uri="tcp://localhost:15000" />
        </amq:transportConnectors>
</amq:broker>

<bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:15000"/>
</bean>

<bean id="abstractJmsComponent"
class="org.apache.camel.component.jms.JmsComponent" abstract="true">
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
</bean>

<bean id="jmsGP" parent="abstractJmsComponent">
        <property name="taskExecutor">
                <bean 
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
                </bean>
        </property>
</bean>

<camel:camelContext id="camelContext">
        <camel:route>
                <camel:from uri="jmsGP:queue:someQueue"/>
                <camel:bean ref="someBean" method="someMethod"/>
        </camel:route>
</camel:camelContext>

Relevant sender spring's cfg:

<bean id="jmsConnectionFactoryGP"
class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:15000"/>
</bean>

<bean id="jmsGP" class="org.apache.camel.component.jms.JmsComponent">
        <property name="connectionFactory" ref="jmsConnectionFactoryGP"/>
        <property name="taskExecutor">
                <bean 
class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
                </bean>
        </property>
</bean>

I run both apps (sender & receiver) under Tomcat

The sender app send the message via a
org.apache.camel.ProducerTemplate.sendBody call to the uri
jmsGP:queue:someQueue. No exception or error

I have a breakpoint in the server app (at the begining of someMethod
code) but it is never reached. Nothing happens (no exception, no
error)

If I run only the receiver app I see (netstat) a LISTENING entry (on
port 15000) and two ESTABLISHED entries (two "views" of the same
connection: 15000 -> some random port and same random port -> 15000).
when I run both apps no additional connection appear.

I'm sure that the problem is not a ActiveMQ issue but a "layer 8" one
(ergo "me"). Someone can kick me in the right direction?

Thank you very much!

Best regards

Reply via email to