[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Analyzing the path, we are ok to send it as one-way since if the WriteTask spots an error, it will log it and stop the ReadTask. The ReadTask will then do connectionClosing() to tell the main broker that the client has vanished. There is no need to report the error back to the delivery thread. This will allow the delivery thread to be recycled more quickly. View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3870106#3870106 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3870106 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Good catch, although your solution is wrong. :-)
If you don't reply to the message, it will gradually build up
on the server as an unreplied message and you will run out of memory.
You will also be blocking delivery threads waiting for the reply.
The sendReply should be trimming the message (it is missing from
org.jboss.mq.il.uil2.msgs.ReceiveRequestMsg)
|public void trimReply()
|{
| messages = null;
|}
|
However, your solution brings an interesting point.
The server does not need to know at this point whether the messages were
actually
received (that is handled by acknowledgements).
It only needs to know whether there is an error communicating with the
client so you are not continually writing messages into a broken connection.
So a better fix is to send the ReceiveRequest as a "one-way" message:
UILClientIL
|public void receive(ReceiveRequest messages[])
| throws Exception
|{
| ReceiveRequestMsg msg = new ReceiveRequestMsg(messages);
| - socketMgr.sendMessage(msg);
| + socketMgr.sendReply(msg);
|}
|
UILClientILService
| case m_receiveRequest:
| ReceiveRequestMsg rmsg = (ReceiveRequestMsg) msg;
| ReceiveRequest[] messages = rmsg.getMessages();
| connection.asynchDeliver(messages);
| - socketMgr.sendReply(msg);
| break;
|
But then we need to add code to the WriteTask so it can signal
on the server side that the message didn't make it to the client.
Currently, this is given to the thread waiting for the response:
| if (msg != null)
| {
| msg.setError(e);
| synchronized (msg)
| {
|msg.notify();
| }
| }
|
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3870100#3870100
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3870100
---
SF email is sponsored by - The IT Product Guide
Read honest & candid reviews on hundreds of IT Products from real users.
Discover which products truly live up to the hype. Start reading now.
http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click
___
JBoss-user mailing list
JBoss-user@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
OK, I've done some debugging, and inspecting the trace generated by the client
(the receiver/consumer) gone through the code.
Now, the code in the class org.jboss.mq.il.uil2.UILClientILService, in the
method handleMsg we saw this:
| switch( msgType )
| {
| case m_receiveRequest:
| ReceiveRequestMsg rmsg = (ReceiveRequestMsg) msg;
| ReceiveRequest[] messages = rmsg.getMessages();
| connection.asynchDeliver(messages);
|socketMgr.sendReply(msg);
| break;
| ...
|}
|
The line in red, is sending the full message back when a receiveRequest message
is received. That's the part that seems to be resending the message back.
So, I've commented this line and recompiled the jboss sources. I took the
jbossmq.jar for the clients, rerun the test, and everithing worked just fine,
and the duplicate messages disappeared.
I wanted to know if I can just do this, or it will break something.
What's the purpose of returnin the message, even if the message is one way?
Thanks,
Marcelo
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3870095#3870095
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3870095
---
SF email is sponsored by - The IT Product Guide
Read honest & candid reviews on hundreds of IT Products from real users.
Discover which products truly live up to the hype. Start reading now.
http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click
___
JBoss-user mailing list
JBoss-user@lists.sourceforge.net
https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Create a bug report in jira with the testcase your using to see this behavior. http://jira.jboss.com View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3870028#3870028 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3870028 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Tested also on JBoss 4.01, using UIL2 connection. For discarding a network problem, also tested on different networks. The same problem goes on. It's a real bug, and actually i'm debugging JBossMQ code. If anyone wants to help, it will be welcomed. Thanks, Marcelo View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3869967#3869967 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3869967 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Moderated: Test it with an up-to-date version before reporting bugs. My guess is this is OIL, which we don't even use anymore. View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3869832#3869832 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3869832 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Could you please? Or even better, fix it :-) and send a patch. View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3868843#3868843 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3868843 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
I did a simple test to discard the fact that my app was adding some noise. I made a QueueSender (sends a BytesMessage to the JBoss queue/testQueue) and a QueueReceiver (consumes messages from the same queue). I captured the traffic between those machines, and the result was the same. I here add the frames capture made with ethereal (the sender's ip is 192.168.7.121, the receiver's ip is 192.168.7.192, jboss jms server running on 192.168.7.121:8093) anonymous wrote : | source 192.168.7.121 dest 192.168.7.192 8093 > 40662 | | 00 08 a1 55 cb e3 00 10 4b 8a 87 9e 08 00 45 00 ...U K.E. | 0010 00 9f 2e 55 40 00 80 06 3b 7a c0 a8 07 79 c0 a8 [EMAIL PROTECTED] ;z...y.. | 0020 07 c0 1f 9d 9e d6 87 16 42 a4 05 f7 66 5b 80 18 B...f[.. | 0030 fa 29 5a e5 00 00 01 01 08 0a 00 35 db 44 03 66 .)Z. ...5.D.f | 0040 96 c9 77 68 19 80 00 00 21 00 00 00 00 01 02 02 ..wh !... | 0050 00 09 74 65 73 74 51 75 65 75 65 00 00 00 02 00 ..testQu eue. | 0060 00 00 00 00 00 00 00 00 00 00 04 07 00 13 49 44 ..ID | 0070 3a 33 2d 31 31 30 39 39 35 35 32 35 37 31 38 36 :3-11099 55257186 | 0080 33 00 00 01 02 6e 7d 23 62 01 09 ff ff ff ff 00 3n}# b... | 0090 09 00 00 01 07 00 04 49 44 3a 33 00 00 00 00 00 ...I D:3. | 00a0 00 00 04 48 6f 6c 61 01 80 00 00 00 79...Hola. y | | source 192.168.7.192 dest 192.168.7.121 40662 > 8093 | | 00 10 4b 8a 87 9e 00 08 a1 55 cb e3 08 00 45 00 ..K. .UE. | 0010 00 9f b4 0c 40 00 40 06 f5 c2 c0 a8 07 c0 c0 a8 [EMAIL PROTECTED]@. | 0020 07 79 9e d6 1f 9d 05 f7 66 5b 87 16 43 0f 80 18 .y.. f[..C... | 0030 16 d0 3c de 00 00 01 01 08 0a 03 66 97 bf 00 35 ..<. ...f...5 | 0040 db 44 77 68 19 80 00 00 21 00 00 00 00 01 02 02 .Dwh !... | 0050 00 09 74 65 73 74 51 75 65 75 65 00 00 00 02 00 ..testQu eue. | 0060 00 00 00 00 00 00 00 00 00 00 04 07 00 13 49 44 ..ID | 0070 3a 33 2d 31 31 30 39 39 35 35 32 35 37 31 38 36 :3-11099 55257186 | 0080 33 00 00 01 02 6e 7d 23 62 01 09 ff ff ff ff 00 3n}# b... | 0090 09 00 00 01 07 00 04 49 44 3a 33 00 00 00 00 00 ...I D:3. | 00a0 00 00 04 48 6f 6c 61 01 80 00 00 00 79...Hola. y | source 192.168.7.192 dest 192.168.7.121 40662 > 8093 | | 00 10 4b 8a 87 9e 00 08 a1 55 cb e3 08 00 45 00 ..K. .UE. | 0010 00 64 b4 0d 40 00 40 06 f5 fc c0 a8 07 c0 c0 a8 [EMAIL PROTECTED]@. | 0020 07 79 9e d6 1f 9d 05 f7 66 c6 87 16 43 0f 80 18 .y.. f...C... | 0030 16 d0 b9 12 00 00 01 01 08 0a 03 66 97 bf 00 35 ...f...5 | 0040 db 44 77 2d 01 00 00 00 3b 00 01 01 02 00 09 74 .Dw- ;..t | 0050 65 73 74 51 75 65 75 65 00 13 49 44 3a 33 2d 31 estQueue ..ID:3-1 | 0060 31 30 39 39 35 35 32 35 37 31 38 36 33 80 00 00 10995525 71863... | 0070 00 79 .y | | source 192.168.7.192 dest 192.168.7.121 40662 > 8093 | | 00 10 4b 8a 87 9e 00 08 a1 55 cb e3 08 00 45 00 ..K. .UE. | 0010 00 4a b4 0e 40 00 40 06 f6 15 c0 a8 07 c0 c0 a8 [EMAIL PROTECTED]@. | 0020 07 79 9e d6 1f 9d 05 f7 66 f6 87 16 43 19 80 18 .y.. f...C... | 0030 16 d0 22 88 00 00 01 01 08 0a 03 66 97 bf 00 35 ..". ...f...5 | 0040 db 44 77 13 0d 00 00 00 3c 00 80 00 00 00 00 00 .Dw. <... | 0050 00 00 00 00 00 00 00 79...y | | Thanks a lot, Marcelo. PS: Maybe I could add this to JBossMQ JIRA? I will look in the sources to see if i can fix this problem View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3868835#3868835 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3868835 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
Already know that it does not have impact in my application. What I NEED is to lower bandwidth consumption, so I'm trying to discover why this is happening, and how to fix it. Thanks, Marcelo View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3868560#3868560 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3868560 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages
I wouldn't concern yourself with messages appearing twice or going back the other way in the network trace, unless they show up in your application as duplicates. It could be a performance issue, however. View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3868549#3868549 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3868549 --- SF email is sponsored by - The IT Product Guide Read honest & candid reviews on hundreds of IT Products from real users. Discover which products truly live up to the hype. Start reading now. http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click ___ JBoss-user mailing list JBoss-user@lists.sourceforge.net https://lists.sourceforge.net/lists/listinfo/jboss-user
[JBoss-user] [Messaging, JMS & JBossMQ] - Re: Duplicate messages received from Queue
The mean cause for such an action lies in the code itself: namely- the QueueSession being invalidated by an exception. The acknowledegement flow only when the QueueSession returns without an exception in case of a transacted queue. Make sure that the transacted value is false in case u want to use individual acknowledgements. thanks. View the original post : http://www.jboss.org/index.html?module=bb&op=viewtopic&p=3848061#3848061 Reply to the post : http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&p=3848061 --- This SF.Net email is sponsored by: YOU BE THE JUDGE. Be one of 170 Project Admins to receive an Apple iPod Mini FREE for your judgement on who ports your project to Linux PPC the best. Sponsored by IBM. Deadline: Sept. 13. Go here: http://sf.net/ppc_contest.php ___ JBoss-user mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-user
