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

ActiveMQBytesMessage decompress throws DataFormatException incorrect header check

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 5.10.2, 5.12.1, 5.11.3, 5.13.0
    • Fix Version/s: 5.13.1, 5.14.0
    • Component/s: Broker
    • Labels:
      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. amq-6142.diff
          2 kB
          Gary Tully
        2. Client.java
          0.8 kB
          Claudio Tagliola
        3. MessageListener.java
          0.3 kB
          Claudio Tagliola
        4. pom.xml
          0.9 kB
          Claudio Tagliola
        5. Server.java
          2 kB
          Claudio Tagliola

          Issue Links

            Activity

              People

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

                Dates

                • Created:
                  Updated:
                  Resolved: