[jboss-user] [JBoss Messaging] - Urgent! Clustered-queue on 2 nodes failed
glenwood
do-not-reply at jboss.com
Wed Jul 22 05:11:54 EDT 2009
My company would like to update our jms implementation from jbossmq to JBM2,I configured a simple cluster environment on 2 nodes with jboss5.1,and followed the instructions of JBM2 to create all-with-jbm2 configuration on 2 nodes,I created 2 queue consumers on 2 nodes and created one queue producer on one node,after starting the jboss on both servers,one server which have both consumer and producer can receive the messages sent by producer,but another server was not able to get any messages,can't figure out why,maybe the cluster configuration of jboss5 has conflict with messaging cluster configuration?
Following are the configuration files on server1,
jbm-configuration.xml
<configuration xmlns="urn:jboss:messaging"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:jboss:messaging /schema/jbm-configuration.xsd">
true
<factory-class>org.jboss.messaging.integration.transports.netty.NettyConnectorFactory</factory-class>
<factory-class>org.jboss.messaging.integration.transports.netty.NettyAcceptorFactory</factory-class>
<broadcast-groups>
<broadcast-group name="hebei-broadcast-group1">
<group-address>231.7.7.7</group-address>
<group-port>9876</group-port>
<broadcast-period>2000</broadcast-period>
<connector-ref connector-name="netty-connector1"/>
</broadcast-group>
</broadcast-groups>
<discovery-groups>
<discovery-group name="hebei-discovery-group1">
<group-address>231.7.7.7</group-address>
<group-port>9876</group-port>
<refresh-timeout>10000</refresh-timeout>
</discovery-group>
</discovery-groups>
<cluster-connections>
<cluster-connection name="hebei-cluster">
jms
<forward-when-no-consumers>true</forward-when-no-consumers>
<discovery-group-ref discovery-group-name="hebei-discovery-group1"/>
</cluster-connection>
</cluster-connections>
<security-settings>
<security-setting match="#">
</security-setting>
</security-settings>
<address-settings>
<!--default for catch all-->
<address-setting match="#">
false
<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>
<distribution-policy-class>org.jboss.messaging.core.server.impl.RoundRobinDistributor</distribution-policy-class>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<redistribution-delay>0</redistribution-delay>
</address-setting>
</address-settings>
--------------------------------------------------
jbm-jboss-bean.xml
<?xml version="1.0" encoding="UTF-8"?>
<!-- JNDI server. Disable this if you don't want JNDI -->
1099
192.168.110.16
1098
192.168.110.16
<!-- MBean server -->
<!-- The core configuration -->
<!-- The security manager -->
<!-- The core server -->
<!-- The JMS server -->
------------------------------------------------------------------
jbm-jms.xml
<configuration xmlns="urn:jboss:messaging"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:jboss:messaging /schema/jbm-jms.xsd">
<connection-factory name="ConnectionFactory">
<connector-ref connector-name="netty-connector1"/>
</connection-factory>
<connection-factory name="ClusteredConnectionFactory">
<connector-ref connector-name="netty" backup-connector-name="netty-backup"/>
</connection-factory>
------------------------------------------------
jbm-user.xml
<configuration xmlns="urn:jboss:messaging" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:jboss:messaging /schema/jbm-users.xsd">
<!-- the default user. this is used where username is null-->
---------------------------------------------------
Following are the configuration file on server2,
jbm-configuration.xml
<configuration xmlns="urn:jboss:messaging"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:jboss:messaging /schema/jbm-configuration.xsd">
true
<factory-class>org.jboss.messaging.integration.transports.netty.NettyConnectorFactory</factory-class>
<factory-class>org.jboss.messaging.integration.transports.netty.NettyAcceptorFactory</factory-class>
<broadcast-groups>
<broadcast-group name="hebei-broadcast-group1">
<group-address>231.7.7.7</group-address>
<group-port>9876</group-port>
<broadcast-period>2000</broadcast-period>
<connector-ref connector-name="netty-connector2"/>
</broadcast-group>
</broadcast-groups>
<discovery-groups>
<discovery-group name="hebei-discovery-group1">
<group-address>231.7.7.7</group-address>
<group-port>9876</group-port>
<refresh-timeout>10000</refresh-timeout>
</discovery-group>
</discovery-groups>
<cluster-connections>
<cluster-connection name="hebei-cluster">
jms
<forward-when-no-consumers>true</forward-when-no-consumers>
<discovery-group-ref discovery-group-name="hebei-discovery-group1"/>
</cluster-connection>
</cluster-connections>
<security-settings>
<security-setting match="#">
</security-setting>
</security-settings>
<address-settings>
<!--default for catch all-->
<address-setting match="#">
false
<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>
<distribution-policy-class>org.jboss.messaging.core.server.impl.RoundRobinDistributor</distribution-policy-class>
<message-counter-history-day-limit>10</message-counter-history-day-limit>
<redistribution-delay>0</redistribution-delay>
</address-setting>
</address-settings>
-------------------------------------------------------
jbm-jboss-bean.xml
<?xml version="1.0" encoding="UTF-8"?>
<!-- JNDI server. Disable this if you don't want JNDI -->
2099
192.168.110.19
2098
192.168.110.19
<!-- MBean server -->
<!-- The core configuration -->
<!-- The security manager -->
<!-- The core server -->
<!-- The JMS server -->
-------------------------------------------
jbm-jms.xml
<configuration xmlns="urn:jboss:messaging"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:jboss:messaging /schema/jbm-jms.xsd">
<connection-factory name="ConnectionFactory">
<connector-ref connector-name="netty-connector2"/>
</connection-factory>
<connection-factory name="ClusteredConnectionFactory">
<connector-ref connector-name="netty" backup-connector-name="netty-backup"/>
</connection-factory>
---------------------------------------------------------
jbm-user.xml
<configuration xmlns="urn:jboss:messaging" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="urn:jboss:messaging /schema/jbm-users.xsd">
<!-- the default user. this is used where username is null-->
Could anyone can find what's going on,I really need to make it work ASAP as I spent too much time on this ,my boss push me too hard :(
View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4245245#4245245
Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=4245245
More information about the jboss-user
mailing list