[jboss-user] [JBoss Messaging] - Re: Clustered server preference
chip_schoch
do-not-reply at jboss.com
Wed Apr 16 14:43:56 EDT 2008
Let me clear up some things. First, I am not using 1.3.0. I am using JBoss AS 4.2.2.ga, JBM1.4.0.SP1, as stated in the intial post. I simply made the mistake of referencing a paragraph in the 1.3 documentation. My bad.
I have been running numerous tests using the program I included, although I found a few bugs that I fixed, and it is clear that the the consumption on a distributed queue is not FIFO. And as I look at the JMS spec I see that FIFO is not guaranteed. One wonders why they use the term MessageQueue instead of MessageBag. So, I will ask my question again. Is there a way to configure JBossMessaging (1.4.0SP1) such that I can get FIFO from a particular destination regardless of the number of consumers of that destination?
Finally, my singleton service is a service that monitors a directory on a SAN for incoming files and queues a message when a file comes in. I really don't want the service running on multiple nodes monitoring a shared directory. It is not a "singleton cluster". It is a singleton service that runs in the cluster.
The only reason I am trying to understand this stuff is that we are about ready to deploy our new architecture in production (3 linux app servers clustered and 4 windows app servers running a jms client service) and we are not seeing the load balanced across them like we should. Apparently my misunderstanding of how distributed queues work is a major contributing factor.
Here is the last 3 runs of my program with 2 client listeners using:
<mbean code="org.jboss.jms.server.connectionfactory.ConnectionFactory"
| name="jboss.messaging.connectionfactory:service=LoadBalanceConnectionFactory"
| xmbean-dd="xmdesc/ConnectionFactory-xmbean.xml">
| <depends optional-attribute-name="ServerPeer">jboss.messaging:service=ServerPeer</depends>
| <depends optional-attribute-name="Connector">jboss.messaging:service=Connector,transport=bisocket</depends>
| <depends>jboss.messaging:service=PostOffice</depends>
|
| <attribute name="JNDIBindings">
| <bindings>
| <binding>/LoadBalanceConnectionFactory</binding>
| <binding>/LoadBalanceConnectionFactory</binding>
| <binding>java:/LoadBalanceConnectionFactory</binding>
| <binding>java:/LoadBalanceConnectionFactory</binding>
| </bindings>
| </attribute>
|
| <attribute name="PrefetchSize">1</attribute>
| <attribute name="SlowConsumers">true</attribute>
| <attribute name="SupportsFailover">false</attribute>
| <attribute name="SupportsLoadBalancing">true</attribute>
| </mbean>
| </server>
[2008-04-16 13:44:26,266] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_0
| [2008-04-16 13:44:26,313] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_1
| [2008-04-16 13:44:26,313] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_2
| [2008-04-16 13:44:26,329] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_3
| [2008-04-16 13:44:26,344] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_4
| [2008-04-16 13:44:26,360] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_5
| [2008-04-16 13:44:26,376] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_6
| [2008-04-16 13:44:26,391] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_7
| [2008-04-16 13:44:26,407] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_8
| [2008-04-16 13:44:26,422] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_9
| [2008-04-16 13:44:26,438] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_10
| [2008-04-16 13:44:26,454] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_11
| [2008-04-16 13:44:26,469] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_12
| [2008-04-16 13:44:26,485] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_13
| [2008-04-16 13:44:26,501] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_14
| [2008-04-16 13:44:26,516] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_15
| [2008-04-16 13:44:26,532] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_16
| [2008-04-16 13:44:26,547] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_17
| [2008-04-16 13:44:26,563] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_18
| [2008-04-16 13:44:26,579] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_19
| [2008-04-16 13:44:26,594] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_20
| [2008-04-16 13:44:26,610] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_21
| [2008-04-16 13:44:26,626] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_22
| [2008-04-16 13:44:26,641] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_23
| [2008-04-16 13:44:26,657] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_24
| [2008-04-16 13:44:27,016] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_0
| [2008-04-16 13:44:27,016] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_1
| [2008-04-16 13:44:28,032] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_2
| [2008-04-16 13:44:28,047] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_3
| [2008-04-16 13:44:29,063] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_4
| [2008-04-16 13:44:29,079] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_5
| [2008-04-16 13:44:30,094] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_6
| [2008-04-16 13:44:30,110] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_7
| [2008-04-16 13:44:31,157] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_8
| [2008-04-16 13:44:31,157] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_9
| [2008-04-16 13:44:32,204] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_10
| [2008-04-16 13:44:32,204] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_11
| [2008-04-16 13:44:33,219] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_12
| [2008-04-16 13:44:33,235] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_13
| [2008-04-16 13:44:34,266] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_15
| [2008-04-16 13:44:34,266] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_14
| [2008-04-16 13:44:35,297] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_16
| [2008-04-16 13:44:35,297] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_17
| [2008-04-16 13:44:36,329] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_18
| [2008-04-16 13:44:36,344] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_19
| [2008-04-16 13:44:37,376] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_20
| [2008-04-16 13:44:37,376] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_21
| [2008-04-16 13:44:38,407] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_22
| [2008-04-16 13:44:38,407] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_23
| [2008-04-16 13:44:39,422] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_24
| [2008-04-16 13:44:52,360] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_0
| [2008-04-16 13:44:52,391] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_1
| [2008-04-16 13:44:52,422] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_2
| [2008-04-16 13:44:52,422] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_3
| [2008-04-16 13:44:52,454] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_4
| [2008-04-16 13:44:52,469] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_5
| [2008-04-16 13:44:52,485] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_6
| [2008-04-16 13:44:52,501] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_7
| [2008-04-16 13:44:52,516] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_8
| [2008-04-16 13:44:52,532] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_9
| [2008-04-16 13:44:52,547] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_10
| [2008-04-16 13:44:52,563] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_11
| [2008-04-16 13:44:52,579] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_12
| [2008-04-16 13:44:52,594] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_13
| [2008-04-16 13:44:52,610] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_14
| [2008-04-16 13:44:52,626] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_15
| [2008-04-16 13:44:52,641] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_16
| [2008-04-16 13:44:52,657] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_17
| [2008-04-16 13:44:52,672] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_18
| [2008-04-16 13:44:52,672] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_19
| [2008-04-16 13:44:52,704] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_20
| [2008-04-16 13:44:52,704] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_21
| [2008-04-16 13:44:52,735] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_22
| [2008-04-16 13:44:52,735] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_23
| [2008-04-16 13:44:52,751] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_24
| [2008-04-16 13:44:53,313] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_0
| [2008-04-16 13:44:53,313] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_3
| [2008-04-16 13:44:54,407] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_1
| [2008-04-16 13:44:54,422] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_23
| [2008-04-16 13:44:55,454] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_22
| [2008-04-16 13:44:55,485] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_21
| [2008-04-16 13:44:56,532] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_24
| [2008-04-16 13:44:56,547] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_2
| [2008-04-16 13:44:57,594] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_19
| [2008-04-16 13:44:57,610] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_20
| [2008-04-16 13:44:58,719] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_11
| [2008-04-16 13:44:58,751] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_12
| [2008-04-16 13:44:59,813] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_16
| [2008-04-16 13:44:59,829] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_17
| [2008-04-16 13:45:00,876] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_7
| [2008-04-16 13:45:00,954] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_8
| [2008-04-16 13:45:01,969] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_6
| [2008-04-16 13:45:02,047] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_9
| [2008-04-16 13:45:03,063] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_15
| [2008-04-16 13:45:03,126] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_18
| [2008-04-16 13:45:04,172] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_5
| [2008-04-16 13:45:04,219] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_10
| [2008-04-16 13:45:05,266] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_4
| [2008-04-16 13:45:05,329] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_13
| [2008-04-16 13:45:06,360] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_14
| [2008-04-16 13:45:20,188] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_0
| [2008-04-16 13:45:20,235] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_1
| [2008-04-16 13:45:20,251] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_2
| [2008-04-16 13:45:20,266] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_3
| [2008-04-16 13:45:20,282] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_4
| [2008-04-16 13:45:20,297] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_5
| [2008-04-16 13:45:20,313] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_6
| [2008-04-16 13:45:20,329] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_7
| [2008-04-16 13:45:20,344] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_8
| [2008-04-16 13:45:20,360] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_9
| [2008-04-16 13:45:20,376] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_10
| [2008-04-16 13:45:20,391] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_11
| [2008-04-16 13:45:20,407] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_12
| [2008-04-16 13:45:20,422] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_13
| [2008-04-16 13:45:20,438] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_14
| [2008-04-16 13:45:20,454] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_15
| [2008-04-16 13:45:20,469] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_16
| [2008-04-16 13:45:20,485] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_17
| [2008-04-16 13:45:20,501] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_18
| [2008-04-16 13:45:20,516] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_19
| [2008-04-16 13:45:20,532] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_20
| [2008-04-16 13:45:20,532] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_21
| [2008-04-16 13:45:20,563] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_22
| [2008-04-16 13:45:20,563] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_23
| [2008-04-16 13:45:20,579] INFO - com.eLynx.Utility.test.JBMTest - Queueing message: Test_Message_24
| [2008-04-16 13:45:21,001] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_6
| [2008-04-16 13:45:21,001] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_0
| [2008-04-16 13:45:22,079] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_18
| [2008-04-16 13:45:22,141] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_19
| [2008-04-16 13:45:23,126] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_11
| [2008-04-16 13:45:23,188] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_12
| [2008-04-16 13:45:24,172] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_5
| [2008-04-16 13:45:24,251] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_7
| [2008-04-16 13:45:25,282] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_4
| [2008-04-16 13:45:25,344] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_8
| [2008-04-16 13:45:26,376] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_9
| [2008-04-16 13:45:26,454] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_10
| [2008-04-16 13:45:27,422] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_14
| [2008-04-16 13:45:27,516] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_15
| [2008-04-16 13:45:28,485] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_21
| [2008-04-16 13:45:28,563] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_22
| [2008-04-16 13:45:29,594] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_16
| [2008-04-16 13:45:29,672] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_17
| [2008-04-16 13:45:30,657] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_23
| [2008-04-16 13:45:30,735] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_24
| [2008-04-16 13:45:31,751] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_1
| [2008-04-16 13:45:31,844] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_2
| [2008-04-16 13:45:32,813] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_20
| [2008-04-16 13:45:32,907] INFO - com.eLynx.Utility.test.TestListener - Listener_1 received message: Test_Message_3
| [2008-04-16 13:45:33,860] INFO - com.eLynx.Utility.test.TestListener - Listener_2 received message: Test_Message_13
|
View the original post : http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4144609#4144609
Reply to the post : http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&p=4144609
More information about the jboss-user
mailing list