[jboss-user] [JBoss Messaging] - Message stranded in cluster

[chip_schoch]

JBoss As 4.2.1, JBM 1.4.0.CR2.

I have a two node cluster with distributed a queue.  Each node is running a service that is a consumer of the queue.   I have client applications that connect to the clustered queue and post messages.  The messages appear to be distributed between the [partial] queues on each node, however only the messages on one of the nodes are getting consumed.  From my logging I can see that the messages that are getting consumed are being consumed by the services running on both nodes.  Listing messages from jmx-console shows a bunch of unconsumed messages sitting in the queue on one of the nodes.

Is there some configuration that turns on the balancing between nodes.  Shouldn't they all be getting consumed?  My consumer service uses the following to connect to the queue.

  <mbean code="org.jboss.jms.jndi.JMSProviderLoader"
  | 	 name="jboss.messaging:service=JMSProviderLoader,name=DefaultJMSProvider">
  |     <attribute name="ProviderName">DefaultJMSProvider</attribute>
  |     <attribute name="ProviderAdapterClass">
  |       org.jboss.jms.jndi.JNDIProviderAdapter
  |     </attribute>
  |     <!-- The combined connection factory -->
  |     <attribute name="FactoryRef">ClusteredXAConnectionFactory</attribute>
  |     <!-- The queue connection factory -->
  |     <attribute name="QueueFactoryRef">ClusteredXAConnectionFactory</attribute>
  |     <!-- The topic factory -->
  |     <attribute name="TopicFactoryRef">ClusteredXAConnectionFactory</attribute>
  |     <!-- Access JMS via HAJNDI -->
  |     <attribute name="Properties">
  |        java.naming.factory.initial=org.jnp.interfaces.NamingContextFactory
  |        java.naming.factory.url.pkgs=org.jboss.naming:org.jnp.interfaces
  |        java.naming.provider.url=${jboss.bind.address:localhost}:1100
  |        jnp.disableDiscovery=false
  |        jnp.partitionName=${jboss.partition.name:DefaultPartition}
  |        jnp.discoveryGroup=${jboss.partition.udpGroup:230.0.0.4}
  |        jnp.discoveryPort=1102
  |        jnp.discoveryTTL=16
  |        jnp.discoveryTimeout=5000
  |        jnp.maxRetries=1
  |     </attribute>
  |   </mbean>
  | 



View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4104288#4104288

Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4104288