I'm using HornetQ in two JBoss 4.2.3 servers, HornetQ is configured as from the install, the "all-with-hornetq" (clustered) configuration.
I am posting a bunch of messages to a queue that's configured on both of the servers; but all of the messages are posted by one of the servers. I expected to see the messages being distributed to both the cluster servers, but what I'm seeing is that all of the messages are delivered to one server, the one where they were posted.
Is this what I should expect to see or is there some configuration I'm missing?
The relevant part of hornetq-configuration.xml is as follows:
<broadcast-groups> <broadcast-group name="bg-group1"> <group-address>18.104.22.168</group-address> <group-port>9876</group-port> <broadcast-period>5000</broadcast-period> <connector-ref connector-name="netty"/> </broadcast-group> </broadcast-groups> <discovery-groups> <discovery-group name="dg-group1"> <group-address>22.214.171.124</group-address> <group-port>9876</group-port> <refresh-timeout>10000</refresh-timeout> </discovery-group> </discovery-groups> <cluster-connections> <cluster-connection name="my-cluster"> <address>jms</address> <forward-when-no-consumers>true</forward-when-no-consumers> <discovery-group-ref discovery-group-name="dg-group1"/> </cluster-connection> </cluster-connections> <security-settings> <security-setting match="#"> <permission type="createTempQueue" roles="guest"/> <permission type="deleteTempQueue" roles="guest"/> <permission type="consume" roles="guest"/> <permission type="send" roles="guest"/> </security-setting> </security-settings> <address-settings> <!--default for catch all--> <address-setting match="#"> <dead-letter-address>jms.queue.DLQ</dead-letter-address> <expiry-address>jms.queue.ExpiryQueue</expiry-address> <redelivery-delay>0</redelivery-delay> <max-size-bytes>-1</max-size-bytes> <page-size-bytes>10485760</page-size-bytes> <message-counter-history-day-limit>10</message-counter-history-day-limit> </address-setting> </address-settings>