> I think I see now, but I want to confirm since I've not seen this kind of
> configuration before. You've intentionally configured 2 federation
> connections in a redundant fashion so that each connection is sending the
> same message resulting in duplicates on the target. Is that correct?
Yes. That is correct.
> Are you using pub/sub in your OpenWire use-case?
No, the producer sends messages to a queue "cms.test.c.client.queue", the
consumer reads from that queue.
> Also, can you share your federation config from broker.xml?
Sure. Here it is:
On Machine A (edeop2)
-------------------
...
<name>edeop2</name>
...
<connectors>
<connector name="artemis-connector">tcp://0.0.0.0:61616</connector>
<connector
name="ebp-ede-connector-1">tcp://192.168.101.203:61616</connector>
<connector
name="ebp-ede-connector-2">tcp://192.168.102.203:61616</connector>
<connector
name="edeop2-connector-1">tcp://192.168.101.204:61616</connector>
<connector
name="edeop2-connector-2">tcp://192.168.102.204:61616</connector>
</connectors>
...
<federations>
<federation name="ebpop2-federation">
<upstream name="ebp-ede-upstream-1">
<circuit-breaker-timeout>1000</circuit-breaker-timeout>
<static-connectors>
<connector-ref>ebp-ede-connector-1</connector-ref>
</static-connectors>
<policy ref="policySetA"/>
</upstream>
<upstream name="ebp-ede-upstream-2">
<circuit-breaker-timeout>1000</circuit-breaker-timeout>
<static-connectors>
<connector-ref>ebp-ede-connector-2</connector-ref>
</static-connectors>
<policy ref="policySetA"/>
</upstream>
<policy-set name="policySetA">
<policy ref="address-federation" />
</policy-set>
<address-policy name="address-federation">
<include address-match="cms.#" />
</address-policy>
</federation>
</federations>
On machine B (ebp-ede)
------------------
...
<name>ebp-ede</name>
...
<connectors>
<connector name="artemis-connector">tcp://0.0.0.0:61616</connector>
<connector
name="ebp-ede-connector-1">tcp://192.168.101.203:61616</connector>
<connector
name="ebp-ede-connector-2">tcp://192.168.102.203:61616</connector>
<connector
name="edeop2-connector-1">tcp://192.168.101.204:61616</connector>
<connector
name="edeop2-connector-2">tcp://192.168.102.204:61616</connector>
</connectors>
...
<federations>
<federation name="ebp-ede-federation">
<upstream name="edeop2-upstream-1">
<circuit-breaker-timeout>1000</circuit-breaker-timeout>
<static-connectors>
<connector-ref>edeop2-connector-1</connector-ref>
</static-connectors>
<policy ref="policySetA"/>
</upstream>
<upstream name="edeop2-upstream-2">
<circuit-breaker-timeout>1000</circuit-breaker-timeout>
<static-connectors>
<connector-ref>edeop2-connector-2</connector-ref>
</static-connectors>
<policy ref="policySetA"/>
</upstream>
<policy-set name="policySetA">
<policy ref="address-federation" />
</policy-set>
<address-policy name="address-federation" >
<include address-match="cms.#" />
</address-policy>
</federation>
</federations>
---------------------------------------------------------------------
To unsubscribe, e-mail: users-unsubscr...@activemq.apache.org
For additional commands, e-mail: users-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
