Skip to main content
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index] [List Home]
[smila-user] JMS broker configuration for multiple machines 
Hello everyone.
I'm doing academic work which involves the usage of SMILA. In
particular, I'm trying to get the Connectivity and Processing/Data
Flow components to run on two different machines. In my configuration,
this means the JMS broker on node Marty should be configured to
receive from node Indy (Marty and Indy are the hostnames.)
I configured the jms.properties on Marty like this:

java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory^M
java.naming.provider.url=vm:(broker:(tcp://Marty:61616?jms.useAsyncSend=true)?persistent=true)?marshal=false

And on Indy like this:

java.naming.factory.initial=org.apache.activemq.jndi.ActiveMQInitialContextFactory^M
java.naming.provider.url=vm:(broker:(tcp://Marty:61616?jms.useAsyncSend=true)?persistent=true)?marshal=false^M

The QueueWorkerConnectionConfig.xml on Indy is:
<QueueWorkerConnectionsConfig xmlns="http://www.eclipse.org/smila/queue";
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
>
  <ConnectionConfig Id="broker1">
    <URL>tcp://Marty:61616</URL>
    <!--<URL>vm://localhost</URL>-->
    <User>any</User>
    <Password>any</Password>
    <ConnectionFactory>org.apache.activemq.ActiveMQConnectionFactory</ConnectionFactory>
  </ConnectionConfig>
</QueueWorkerConnectionsConfig>

while the one on Marty keeps pointing to localhost (it's the same?)

However, I cannot get this to work and I feel the Listener on Indy is
stealing the messages for Marty since in JMS Queues only one worker
can acknowledge a message. How can I disactivate the Listener on Indy
and get the messages delivered to Marty? Am I also doing something
else wrong?

Regards,
-- 
Giorgio Sironi
Piccolo Principe & Web Engineer
http://giorgiosironi.blogspot.com
http://twitter.com/giorgiosironi

Back to the top