activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Michael Chen (JIRA)" <j...@apache.org>
Subject [jira] Updated: (AMQ-2929) Compressed text message received by consumer uncompressed
Date Thu, 23 Sep 2010 00:17:40 GMT

     [ https://issues.apache.org/activemq/browse/AMQ-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Michael Chen updated AMQ-2929:
------------------------------

    Attachment: ActiveMQConsumerTest.java
                ActiveMQConsumerTest.xml

Attached the test source program and its Spring xml. A producer is needed that uses the same
jmsFactory defined in this XML to pump some messages (compressed) to the "test.registration"
queue before running the test program. No message will be retrieved due to the ZipException.

> Compressed text message received by consumer uncompressed
> ---------------------------------------------------------
>
>                 Key: AMQ-2929
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2929
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.3.2
>         Environment: ActiveMQ 5.3.2 / Camel 2.2.0
>            Reporter: Michael Chen
>         Attachments: ActiveMQConsumerTest.java, ActiveMQConsumerTest.xml
>
>
> I have a queue setup to send and consume compressed text messages.  This is done via
Spring setting ActiveMQConnectionFactory.useCompression to true.  If the consumer connects
to this queue before the first message is arrives, everything works great.
> If the messages are sent to this queue before the consumer connects, those early messages
will cause ZipException "unknown compression method" when consumed by the belated consumer.
Debugger shows that the ActiveMQTextMessage.content already contains the uncompressed text
(with 4 leading length bytes) when ActiveMQTextMessage.getText() is called.
> If I set useCompression to false, early messages are consumed with no problems.  Please
look into this.
> I notice that after ActiveMQTextMessage.getText() decompress the message, it does not
set compressed to false. Not sure if that is the cause.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message