Databases
StackOverflow2013
Postsdbo
PORouting queues with Service Mix
Body
 

Note that there are some explanatory texts on larger screens.

plurals
  1. PORouting queues with Service Mix
    text
    copied!<p>I'm trying to configure Apache ServiceMix to implement the network topology below:</p> <p><img src="https://i.stack.imgur.com/gIcYZ.jpg" alt="enter image description here"></p> <p>I'm very new in Service Mix, Camel, ActiveMq etc. stuff and the main issue I'm trying to solve is to route messages from Output queue of DC1.ActiveMqBroker to the Input queue of DC2.ActiveMqBroker.</p> <p>I'm sure this should be easy. Could someone point me to the good article or write rough snippet of configuration (in Spring/Blueprint, doesn't matter)?</p> <p><strong>UPDATE:</strong></p> <p>Sorry for long text but I don't see other way to tell my problem.</p> <p>My sample configuration: </p> <pre><code>&lt;broker xmlns="http://activemq.apache.org/schema/core" brokerName="dc2" dataDirectory="${karaf.data}/activemq/dc2" useShutdownHook="false"&gt; &lt;destinationPolicy&gt; &lt;policyMap&gt; &lt;policyEntries&gt; &lt;policyEntry queue="input" producerFlowControl="true" memoryLimit="1mb"/&gt; &lt;policyEntry queue="output" producerFlowControl="true" memoryLimit="1mb"/&gt; &lt;/policyEntries&gt; &lt;/policyMap&gt; &lt;/destinationPolicy&gt; &lt;managementContext&gt; &lt;managementContext createConnector="false"/&gt; &lt;/managementContext&gt; &lt;persistenceAdapter&gt; &lt;kahaDB directory="${karaf.data}/activemq/dc2/kahadb"/&gt; &lt;/persistenceAdapter&gt; &lt;transportConnectors&gt; &lt;transportConnector name="openwire" uri="tcp://localhost:61619"/&gt; &lt;/transportConnectors&gt; &lt;/broker&gt; &lt;bean id="dc1activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"&gt; &lt;property name="brokerURL" value="tcp://localhost:61619" /&gt; &lt;/bean&gt; &lt;bean id="dc2activemq" class="org.apache.activemq.camel.component.ActiveMQComponent"&gt; &lt;property name="brokerURL" value="tcp://localhost:61618" /&gt; &lt;/bean&gt; &lt;camelContext xmlns="http://camel.apache.org/schema/blueprint"&gt; &lt;route&gt; &lt;from uri="dc1activemq:queue:output"/&gt; &lt;log message="Took message from dc1 to dc2"/&gt; &lt;to uri="dc2activemq:queue:input"/&gt; &lt;/route&gt; &lt;/camelContext&gt; </code></pre> <p></p> <p>And I constantly get following error:</p> <pre><code>08:06:40,739 | INFO | rint Extender: 3 | Activator | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Found 1 @Converter classes to load 08:06:40,740 | INFO | rint Extender: 3 | Activator | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Found 1 @Converter classes to load 08:06:40,741 | INFO | rint Extender: 3 | Activator | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Found 1 @Converter classes to load 08:06:40,741 | INFO | rint Extender: 3 | Activator | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Found 2 @Converter classes to load 08:06:40,749 | INFO | rint Extender: 3 | Activator | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Found 13 @Converter classes to load 08:06:40,754 | INFO | rint Extender: 3 | BlueprintCamelContext | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | JMX enabled. Using ManagedManagementStrategy. 08:06:40,758 | INFO | rint Extender: 3 | BlueprintCamelContext | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Apache Camel 2.6.0 (CamelContext: 211-camel-165) is starting 08:06:42,364 | INFO | rint Extender: 3 | BlueprintCamelContext | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Route: route55 started and consuming from: Endpoint[dc1activemq://queue:output] 08:06:42,364 | INFO | rint Extender: 3 | BlueprintCamelContext | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Total 1 routes, of which 1 is started. 08:06:42,365 | INFO | rint Extender: 3 | BlueprintCamelContext | ? ? | 68 - or g.apache.camel.camel-core - 2.6.0 | Apache Camel 2.6.0 (CamelContext: 211-camel-165) started in 1.606 seconds 08:06:48,379 | WARN | tenerContainer-1 | DefaultMessageListenerContainer | ? ? | 77 - or g.springframework.jms - 3.0.5.RELEASE | Could not refresh JMS Connection for destination 'output' - retrying in 5000 ms. Cau se: Could not connect to broker URL: tcp://localhost:61619. Reason: java.net.ConnectException: Connection refused: connect 08:06:54,381 | WARN | tenerContainer-1 | DefaultMessageListenerContainer | ? ? | 77 - or g.springframework.jms - 3.0.5.RELEASE | Could not refresh JMS Connection for destination 'output' - retrying in 5000 ms. Cau se: Could not connect to broker URL: tcp://localhost:61619. Reason: java.net.ConnectException: Connection refused: connect </code></pre>
 

Querying!

 
Guidance
An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload