Uploaded image for project: 'ActiveMQ Classic'
  1. ActiveMQ Classic
  2. AMQ-6142

ActiveMQBytesMessage decompress throws DataFormatException incorrect header check

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 5.10.2, 5.12.1, 5.11.3, 5.13.0
    • 5.13.1, 5.14.0
    • Broker
    • None

    Description

      In our environment we use an embedded broker. On one topic where compression is enabled, the server is also listening in on the messages. From ActiveMQ 5.10.0 up to 5.13.0, we encounter DataFormatException: incorrect header check exceptions on the tcp clients due to corruption of the payload. Attached are a test server and client. At some point, the client will exit due to mentioned exception. Increase chances by running multiple clients. This scenario works with 5.8.0 and 5.9.1.

      If the server has multiple consumers on the same topic, they will encounter corruption as well, but this has other side-effects.

      Attachments

        1. Client.java
          0.8 kB
          Claudio Tagliola
        2. MessageListener.java
          0.3 kB
          Claudio Tagliola
        3. Server.java
          2 kB
          Claudio Tagliola
        4. pom.xml
          0.9 kB
          Claudio Tagliola
        5. amq-6142.diff
          2 kB
          Gary Tully

        Issue Links

          Activity

            People

              cshannon Christopher L. Shannon
              tagliola Claudio Tagliola
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: