Wildfly 10 - Messages distributed by clusters
paulocsouza1 May 9, 2017 2:53 PMHi!
I am trying to configure wildfly 10 to distribute messages between 2 clusters running as active-active. Can someone help me with the problem? Messages are being consumed by only one cluster. Here are the settings:
<subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0"> <server name="jms-master-live"> <security enabled="false"/> <cluster password="${jboss.messaging.cluster.password:pwd@2017}"/> <shared-store-master failover-on-server-shutdown="true"/> <bindings-directory path="${path-live}/bindings" relative-to="jms.path.live"/> <journal-directory path="${path-live}/journal" relative-to="jms.path.live"/> <large-messages-directory path="${path-live}/largemessages" relative-to="jms.path.live"/> <paging-directory path="${path-live}/paging" relative-to="jms.path.live"/> <security-setting name="#"> <role name="guest" send="true" consume="true" create-non-durable-queue="true" delete-non-durable-queue="true"/> </security-setting> <address-setting name="#" dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" page-size-bytes="2097152" message-counter-history-day-limit="10" redistribution-delay="0"/> <http-connector name="http-connector" socket-binding="http" endpoint="http-acceptor"/> <http-connector name="http-connector-throughput" socket-binding="http" endpoint="http-acceptor-throughput"> <param name="batch-delay" value="50"/> </http-connector> <remote-connector name="netty" socket-binding="messaging"> <param name="use-nio" value="true"/> <param name="use-nio-global-worker-pool" value="true"/> </remote-connector> <in-vm-connector name="in-vm" server-id="0"/> <http-acceptor name="http-acceptor" http-listener="default"/> <http-acceptor name="http-acceptor-throughput" http-listener="default"> <param name="batch-delay" value="50"/> <param name="direct-deliver" value="false"/> </http-acceptor> <in-vm-acceptor name="in-vm" server-id="0"/> <broadcast-group name="bg-desen-group" connectors="http-connector" socket-binding="messaging-group" broadcast-period="1000"/> <discovery-group name="dg-desen-group" socket-binding="messaging-group-disc" refresh-timeout="500"/> <cluster-connection name="desev-cluster" address="10,DEV,DES" connector-name="http-connector" confirmation-window-size="1" discovery-group="dg-desen-group"/> <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/> <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/> <jms-queue name="TSupervisorSupervisaoQueue" entries="java:/queue/tSupervisorSupervisaoQueue java:jboss/exported/jms/queue/tSupervisorSupervisaoQueue"/> <jms-queue name="TSupervisorAgenteQueue" entries="java:/queue/tSupervisorAgenteQueue java:jboss/exported/jms/queue/tSupervisorAgenteQueue"/> <jms-queue name="tSupervisorMonitoringScheduledQueue" entries="java:/queue/tSupervisorMonitoringScheduledQueue java:jboss/exported/jms/queue/tSupervisorMonitoringScheduledQueue"/> <connection-factory name="InVmConnectionFactory" entries="java:/ConnectionFactory" connectors="http-connector" consumer-window-size="0"/> <connection-factory name="RemoteConnectionFactory" entries="java:jboss/exported/jms/RemoteConnectionFactory" connectors="http-connector" ha="true" consumer-window-size="0" block-on-acknowledge="true" reconnect-attempts="-1"/> <pooled-connection-factory name="activemq-ra" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory" connectors="http-connector" transaction="xa" consumer-window-size="0"/> </server> <server name="jms-master-backup"> <security enabled="false"/> <cluster password="contax@2016"/> <shared-store-slave failover-on-server-shutdown="true"/> <bindings-directory path="${path-bkp}/bindings" relative-to="jms.path.live"/> <journal-directory path="${path-bkp}/journal" relative-to="jms.path.live"/> <large-messages-directory path="${path-bkp}/largemessages" relative-to="jms.path.live"/> <paging-directory path="${path-bkp}/paging" relative-to="jms.path.live"/> <security-setting name="#"> <role name="guest" send="true" consume="true" create-durable-queue="true" delete-durable-queue="true" create-non-durable-queue="true" delete-non-durable-queue="true" manage="true"/> </security-setting> <address-setting name="#" dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" page-size-bytes="2097152" message-counter-history-day-limit="10" redistribution-delay="0"/> <http-connector name="http-connector" socket-binding="http" endpoint="http-acceptor"/> <http-connector name="http-connector-throughput" socket-binding="http" endpoint="http-acceptor-throughput"> <param name="batch-delay" value="50"/> </http-connector> <remote-connector name="netty" socket-binding="messaging-backup"> <param name="use-nio" value="true"/> <param name="use-nio-global-worker-pool" value="true"/> </remote-connector> <remote-acceptor name="netty" socket-binding="messaging-backup"/> <broadcast-group name="bg-desen-group" broadcast-period="1000" connectors="netty" socket-binding="messaging-group-bkp"/> <discovery-group name="dg-desen-group" refresh-timeout="500" socket-binding="messaging-group-disc-bkp"/> <cluster-connection name="desev-cluster" address="10,DEV,DES" connector-name="netty" confirmation-window-size="1" discovery-group="dg-desen-group"/> </server> </subsystem> ... <interface name="messenger"> <any-address/> </interface> ... <socket-binding name="messaging-group" interface="messenger" port="5871" multicast-address="${jboss.messaging.group.address:230.0.0.4}" multicast-port="${jboss.messaging.group.port:5971}"/> <socket-binding name="messaging-group-disc" interface="messenger" port="5872" multicast-address="${jboss.messaging.group.address:230.0.0.4}" multicast-port="${jboss.messaging.group.port:5972}"/> <socket-binding name="messaging-group-bkp" interface="messenger" port="5873" multicast-address="${jboss.messaging.group.address:230.0.0.4}" multicast-port="${jboss.messaging.group.port:5973}"/> <socket-binding name="messaging-group-disc-bkp" interface="messenger" port="5874" multicast-address="${jboss.messaging.group.address:230.0.0.4}" multicast-port="${jboss.messaging.group.port:5974}"/> <socket-binding name="messaging" interface="messenger" port="5446"/> <socket-binding name="messaging-backup" interface="messenger" port="5447"/>