Return-Path: 
 <dev-return-22454-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-dev-archive@www.apache.org
Received: (qmail 92746 invoked from network); 22 Sep 2010 10:14:04 -0000
Received: from unknown (HELO mail.apache.org) (140.211.11.3)
  by 140.211.11.9 with SMTP; 22 Sep 2010 10:14:04 -0000
Received: (qmail 94192 invoked by uid 500); 22 Sep 2010 10:14:04 -0000
Delivered-To: apmail-activemq-dev-archive@activemq.apache.org
Received: (qmail 93982 invoked by uid 500); 22 Sep 2010 10:14:03 -0000
Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:dev-help@activemq.apache.org>
List-Unsubscribe: <mailto:dev-unsubscribe@activemq.apache.org>
List-Post: <mailto:dev@activemq.apache.org>
List-Id: <dev.activemq.apache.org>
Reply-To: dev@activemq.apache.org
Delivered-To: mailing list dev@activemq.apache.org
Received: (qmail 93974 invoked by uid 99); 22 Sep 2010 10:14:02 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 22 Sep 2010 10:14:02 +0000
X-ASF-Spam-Status: No, hits=-2000.0 required=10.0
	tests=ALL_TRUSTED
X-Spam-Check-By: apache.org
Received: from [140.211.11.22] (HELO thor.apache.org) (140.211.11.22)
    by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 22 Sep 2010 10:14:01 +0000
Received: from thor (localhost [127.0.0.1])
	by thor.apache.org (8.13.8+Sun/8.13.8) with ESMTP id o8MADe4H006014
	for <dev@activemq.apache.org>; Wed, 22 Sep 2010 10:13:41 GMT
Message-ID: <30322954.27901285150420405.JavaMail.jira@thor>
Date: Wed, 22 Sep 2010 06:13:40 -0400 (EDT)
From: "Michael Chen (JIRA)" <jira@apache.org>
To: dev@activemq.apache.org
Subject: [jira] Updated: (AMQ-2929) Compressed text message received by
 consumer uncompressed
In-Reply-To: <6599568.26951285115080908.JavaMail.jira@thor>
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 7bit
X-JIRA-FingerPrint: ae95407df07c98740808b2ef9da0087c


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

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


Here is how the connection factory defined:

    <bean id="jmsXmlFactory" class="org.apache.activemq.pool.PooledConnectionFactory"
          destroy-method="stop">
        <property name="connectionFactory">
            <bean class="org.apache.activemq.ActiveMQConnectionFactory">
                <property name="brokerURL" value="${brokerConnectionURL}"/>
                <property name="userName" value="${activemq.username}"/>
                <property name="password" value="${activemq.password}"/>
                <property name="clientIDPrefix" value="${processUniqueName}Xml-${serverId}-${pid}"/>
                <property name="transformer">
                    <bean class="org.apache.activemq.util.xstream.XStreamMessageTransformer"/>
                </property>
                <property name="useCompression" value="true"/>
            </bean>
        </property>
    </bean>


> 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: JMS client
>    Affects Versions: 5.3.2
>         Environment: ActiveMQ 5.3.2 / Camel 2.2.0
>            Reporter: Michael Chen
>
> 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.