4:11 a.m.
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#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...