You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by blueear <bl...@gmail.com> on 2013/03/07 10:29:02 UTC

Could you read me my config and solve Consumer problem?

Hello.

I found this configuration on a testing system.
Many Producers with the same config.
Two Brokers. 
Two Consumer-Services (the same functional, and both are running)

Im not familiar with ActiveMQ and I'm not sure I undestand configuration
clearly.
There are configurations:

On Producers:
connectionString = failover:(tcp://GW01:61616,tcp://GW02:61616)

On Broker-GW01:

<networkConnectors> 
<networkConnector name="GW01-NC"
uri="static:(tcp://GW02:61616?soTimeout=60000)"/> 
</networkConnectors> 

<persistenceAdapter> 
<amqPersistenceAdapter/> 
</persistenceAdapter> 
 
<transportConnectors> 
<transportConnector name="GW01-TC" uri="tcp://0.0.0.0:61616"/> 
</transportConnectors> 

On Broker-GW02:

<persistenceAdapter> 
<amqPersistenceAdapter/> 
</persistenceAdapter> 
 
<transportConnectors> 
<transportConnector name="GW02-TC" uri="tcp://0.0.0.0:61616"/> 
</transportConnectors> 

On Consumer-Service01:
connectionString = failover:(tcp://GW01:61616,tcp://GW02:61616)

On Consumer-Service02:
connectionString = failover:(tcp://GW01:61616,tcp://GW02:61616)

Producers are randomly connected to Brokers - using statistics, half to
GW01, half of them to GW02.
I think there is Store and Forward configuration between GW01 and GW02 -
unidirectional, from GW01 to GW02.
This means GW01 has messages just from GW01-connected Producers. GW02 stores
messages from every producer.

In this configuration Consumer-Service01 and Consumer-Service02 do the same
actions with messages from GW01-connected Producers (Consumers are the same
app code).

Is it correct?

If yes, what to do, or how to a Consumer-Service0x can say to Broker, I
consume the message, delete message copies on other Brokers? We don't want
make duplicate action with a message.

Thank you for your help.









--
View this message in context: http://activemq.2283324.n4.nabble.com/Could-you-read-me-my-config-and-solve-Consumer-problem-tp4664459.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.