Before adding the trasaction configuraiton to activemq component, as below
<bean id="activemqTCP"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="brokerURL"
value="failover:(tcp:192.168.2.198:61616)" />
<property name="preserveMessageQos" value="true"></property>
<property name="userName" value="system" />
<property name="password" value="manager" />
</bean>
I can send msg to activemq which config by
<transportConnector name="openwire"
uri="tcp://192.168.2.198:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600"/>
---------------------------------------------------------------------------------------
After adding the trasaction configuraiton to activemq component, as below
<bean id="activemqTCP"
class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="preserveMessageQos" value="true"></property>
<property name="transacted" value="true" />
<property name="transactionManager" ref="txManager" />
<property name="userName" value="system" />
<property name="password" value="manager" />
</bean>
<bean id="txManager"
class="org.springframework.jms.connection.JmsTransactionManager">
<property name="connectionFactory" ref="jmsConnectionFactory" />
</bean>
<bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="failover:(tcp:192.168.2.198:61616)" />
</bean>
I can't send the message to amq which use the the configuration above, there
was no error reported, and there was no messge stored in amq.
---------------------------------------------------------------------------------------
I changed the amq config as below：
<transportConnector name="openwire"
uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireformat.maxFrameSize=104857600"/>
Then I can send message to amq.
---------------------------------------------------------------------------------------
But when I try to connect to my partner, the broker on other machine,e.g.
192.168.2.11 , the message was sent to my broker, not to my partner's.
---------------------------------------------------------------------------------------
1. Why the ip must be changed to use transaction
2 Must my application and amq in one machine. it may be seperated when
deploying.
Thanks.
--
View this message in context:
http://camel.465427.n5.nabble.com/Issue-after-config-activemq-component-transaction-tp5742768.html
Sent from the Camel - Users mailing list archive at Nabble.com.
