Current Position:Home > Flooding the Stomp interface - any ideas?

Flooding the Stomp interface - any ideas?

Update:11-30Source: network consolidation
Does anyone have any experience of overloading the new Stomp interface using the OpenMQ 4.4 beta running under Windows? I've found that if messages are sent in too fast, exceptions occur. This happens with a Producer tool (for example Michael Justin's free download) and a different demo program based on the Delphi TStompClient component from the Codehaus site. I suspect it will happen with any program that writes, say, several hundred messages to a topic or queue in rapid succession.
A workaround which I have just tried this morning is to put in a Sleep(0) after each send in order to cede a bit of processor time to the JMS - early signs are that this seems to work. However I would like to know if anyone else has experience of this issue and what the best way forward is. Is it a JMS bug?
The exception generated is below - you can see that the JMS is having trouble interpreting a Stomp message with missing characters at the start of the message. (Different fragments will displayed in different occurrences of the exception).
04-Jun-2009 18:56:23
SEVERE: Parse incomming data failed: Unknown STOMP command: tination:/topic/Torus2ClientTopic
com.sun.messaging.bridge.service.stomp.FrameParseException: Unknown STOMP command: tination:/topic/Torus2ClientTopic
at com.sun.messaging.bridge.service.stomp.StompFrameMessage.parseCommand(
at com.sun.messaging.bridge.service.stomp.StompProtocolParser.hasNextMessage(
at com.sun.grizzly.filter.ParserProtocolFilter.execute(
at com.sun.grizzly.DefaultProtocolChain.executeProtocolFilter(
at com.sun.grizzly.DefaultProtocolChain.execute(
at com.sun.grizzly.DefaultProtocolChain.execute(
at com.sun.grizzly.ProtocolChainContextTask.doCall(
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$ Source)
at Source)
Thanks for any ideas...

The Best Answer

I've tried a few different platforms and mostly JRE 1.6u13. Yesterday I started using the JDK (1.6u13 - for compatibility with Open build 8/9). I have used Windows 2003 & Windows Vista. To be sure that everything is the latest, I've re-installed this afternoon as follows:
- Processor: Intel 2 Core Duo 2GHz.
- OS: Windows 32-bit Vista SP1
- Install JDK 1.6u14
- Install OpenMQ 4.4 build 9 and set up for Stomp
- Start imqbrokerd from a command window
- Create a topic with default parameters with the imqadmin tool
- Download "Habari OpenMQ Client - Delphi demo download" from:
- Unzip and run: ...\HabariOpenMQ-demo\demo\delphigui\GUIDemo.exe
- Ignoring the row of big buttons on top (no reason, that's just what I did) look at the left hand half of the screen and the different sections separated by parallel lines:
     - In the Connection section click the Connect button
     - In the Session section click the Create button;
     - Click OK in the dialog that appears, accepting Automatic Acknowledgement
     - In the Destinations section type the name of your test topic in the empty text box just above the New button and click New
     - Subscribe to this topic by highlighting it in the Destinations list box and clicking the Subscribe button
     - Click the Send button to send the default message and check that it is received in the Log Window (Received test message:....)
     - Change the repeat count to 10000 and click Send again.
This configuration (with JDK 1.6u14 instead of u13) seems to be more robust than previous configurations I have tried. I could not get the problem to occur when sending only 1000 messages, so I increased the count to 10000. Then dozens of errors occurred.
I suspect the problem is not at the client side because it is also seen with a different client - using code based on the Delphi TStompClient class downloaded from the Codehaus site. (The TStompClient even uses a different TCP socket from the Habari component so it has different code at all levels of the program).
Banner at the top of a startup log is:
Open Message Queue 4.4
Sun Microsystems, Inc.
Version: 4.4 (Build 9-d)
Compile: Fri 06/05/2009
Copyright (c) 2009 Sun Microsystems, Inc. All rights reserved. Use is
subject to license terms.
Java Runtime: 1.6.0_14 Sun Microsystems Inc. C:\Program Files\Java\jdk1.6.0_14\jre
[12/Jun/2009:13:11:39 BST] IMQ_HOME=C:\Program Files\Sun\MessageQueue\mq
[12/Jun/2009:13:11:39 BST] IMQ_VARHOME=C:\Program Files\Sun\MessageQueue\var\mq
[12/Jun/2009:13:11:39 BST] Windows Vista 6.0 x86 (2 cpu) jon.stewart
[12/Jun/2009:13:11:40 BST] Java Heap Size: max=189376k, current=18176k
[12/Jun/2009:13:11:40 BST] Arguments:
[12/Jun/2009:13:11:40 BST] [B1004]: Starting the portmapper service using tcp [ 7676, 50, * ] with min threads 1 and max threads of 1
[12/Jun/2009:13:11:40 BST] [B1060]: Loading persistent data...
[12/Jun/2009:13:11:40 BST] Using built-in file-based persistent store: C:\Program Files\Sun\MessageQueue\var\mq\instances\imqbroker\
[12/Jun/2009:13:11:40 BST] [B1318]: Initialize bridge service manager
[12/Jun/2009:13:11:40 BST] BridgeManager: Loading bridge stomp
[12/Jun/2009:13:11:40 BST] BridgeManager: Loaded bridge stomp
[P.S. the different name for this post is 'cos I was having trouble accessing my original Sun account]
  • Flooding the Stomp interface - any ideas? Update:11-30

    Does anyone have any experience of overloading the new Stomp interface using the OpenMQ 4.4 beta running under Windows? I've found that if messages are sent in too fast, exceptions occur. This happens with a Producer tool (for example Michael Justin'

  • Synchronization of sequence execution with UIMessage handling Update:11-30

    We are using TestStand 4.0 with SequentialModel and custom Operator Interface. Operator Interface provides UIMsg_UserMessageBase handler for displaying log messages. When posting (asynchronous) significant number of messages from within test module,

  • Redundant Multicast switching Update:11-30

    All, I have a customer with a L2 network with multiple VLANS and consisting of multiple access switches with two L2/L3 core switches.  Both core switches have a SVI for each vlan using HSRP to provde redundant Default Gateways. The main core switch i

  • Bridge-domain traffic paths Update:11-30

    Hi guys, Couldn't really get into logic of bridge-domain and hsrp coexistence. How traffic will be flooded? Imagine following topology: Bridge-domain and hsrp is running between ASR1 and ASR2. Host C has two network adapters. Both are in UP state, bu

  • Forwarding DHCP requests Update:11-30

    Just looking for a confirmation that I haven't left anything out on my config for forwarding DHCP packets. My DHCP servers will be on and The users are on If I'm to forward the packets from the user segment I h

  • VLAN problem with SRW2048 Update:11-30

    I'm having problem with a setup with multiple SRW2048 connected together.  However, I can see the problem when simplifying my setup and using only two SRW2048 together. The first SRW2048 receives one connection from many different servers and sends t

  • Transparent FW and pinging to remote device Update:11-30

    Hi everyone, I was reading about transparent FW  it says Unlike a transparent switch, however, the device will not flood frames out interfaces for an unknown MAC address destination. Instead the ASA will respond with an ARP request for a directly con

  • SG300-10P SYN Protection Update:11-30

    Hi Community, just registered after reading some topics in the last months. Great answers here - thank you for that! No I have a minor issue with a new feature and did not find any solutions yet. Yesterday I upgraded my SG300-10P to firmware

  • How to configure IGMP routing right? Update:11-30

    My server need to pass multicast UDP streams from physical NIC to a virtual NIC. Network layout is this: Ubuntu Server (ffmpeg) in Hyper-V <---> Windows Server (Wowza) <---> Multicast subnet. Here is what I've done: Enabled RRAS service. Added

  • 3750X - Dropped multicat traffic flooding on all switchport vlan interfaces Update:11-30

    Hello forum,  I have a problem on source  multicast blocking. I have a switch with a vlan interface (Ex. vlan 20 )and on that vlan interface an extended ACL is present. That ACL block specific multicast groups. Furtehrmore I have many switchport acce