You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by wistonia <ti...@perceptive.com> on 2010/04/15 14:21:55 UTC
Message compression, intermittent java.util.ZipException
AMQ 5.3.0, Tomcat 6.0.20
I have and embedded client and server broker running within a single Tomcat
instance for testing. With
message compression enabled we get the following error. Any ideas what we
can do to mitigate this, or at least debug it further?
2010-04-15 11:46:16,378 INFO [ActiveMQ Transport: tcp:///127.0.0.1:1786]
[org.apache.activemq.broker.util.LoggingBrokerPlugin] Adding destination :
Queue:QUEUECLIENTTOSERVER
2010-04-15 11:46:16,378 INFO [ActiveMQ Transport:
tcp://localhost/127.0.0.1:61617]
[org.apache.activemq.broker.util.LoggingBrokerPlugin] Acknowledging message
for client ID : NC_InitiatorMainBroker_inbound_InitiatorLocalBroker,
ID:BHX000053-1746-1271328334500-5:0:3:1:2
2010-04-15 11:46:16,378 INFO [BrokerService]
[org.apache.activemq.broker.util.LoggingBrokerPlugin] preProcessDispatch
:MessageDispatch {commandId = 0, responseRequired = false, consumerId =
ID:BHX000053-1777-1271328358487-2:0:1:1, destination =
queue://QUEUECLIENTTOSERVER, message = ActiveMQTextMessage {commandId = 13,
responseRequired = false, messageId =
ID:BHX000053-1746-1271328334500-5:0:3:1:2, originalDestination = null,
originalTransactionId = null, producerId =
ID:BHX000053-1746-1271328334500-9:0:1:1, destination =
queue://QUEUECLIENTTOSERVER, transactionId = null, expiration = 0, timestamp
= 1271328376363, arrival = 0, brokerInTime = 1271328376378, brokerOutTime =
1271328376378, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = true, userID = null, content =
org.apache.activemq.util.ByteSequence@cb561c, marshalledProperties =
org.apache.activemq.util.ByteSequence@f4a982, dataStructure = null,
redeliveryCounter = 0, size = 27939, properties = {messageType=8,
BrokerPath=InitiatorMainBroker}, readOnlyProperties = false, readOnlyBody =
false, droppable = false, text = null}, redeliveryCounter = 0}
2010-04-15 11:46:16,394 INFO [BrokerService]
[org.apache.activemq.broker.util.LoggingBrokerPlugin] postProcessDispatch
:MessageDispatch {commandId = 7, responseRequired = false, consumerId =
ID:BHX000053-1777-1271328358487-2:0:1:1, destination =
queue://QUEUECLIENTTOSERVER, message = ActiveMQTextMessage {commandId = 13,
responseRequired = false, messageId =
ID:BHX000053-1746-1271328334500-5:0:3:1:2, originalDestination = null,
originalTransactionId = null, producerId =
ID:BHX000053-1746-1271328334500-9:0:1:1, destination =
queue://QUEUECLIENTTOSERVER, transactionId = null, expiration = 0, timestamp
= 1271328376363, arrival = 0, brokerInTime = 1271328376378, brokerOutTime =
1271328376394, correlationId = null, replyTo = null, persistent = true, type
= null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId =
null, compressed = true, userID = null, content =
org.apache.activemq.util.ByteSequence@cb561c, marshalledProperties =
org.apache.activemq.util.ByteSequence@f4a982, dataStructure = null,
redeliveryCounter = 0, size = 27939, properties = {messageType=8,
BrokerPath=InitiatorMainBroker}, readOnlyProperties = false, readOnlyBody =
false, droppable = false, text = null}, redeliveryCounter = 0}
2010-04-15 11:46:16,394 WARN [ActiveMQ Session Task]
[com.perceptive.initiator.dcs.jms.MessageListenerServer] JMSException
thrown: unknown compression method
javax.jms.JMSException: unknown compression method
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.command.ActiveMQTextMessage.getText(ActiveMQTextMessage.java:91)
at
com.perceptive.initiator.dcs.jms.MessageListenerServer.receive(MessageListenerServer.java:29)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.util.MethodInvoker.invoke(MethodInvoker.java:273)
at
org.springframework.jms.listener.adapter.MessageListenerAdapter.invokeListenerMethod(MessageListenerAdapter.java:463)
at
org.springframework.jms.listener.adapter.MessageListenerAdapter.onMessage(MessageListenerAdapter.java:355)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:534)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:495)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:467)
at
org.springframework.jms.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:439)
at
org.springframework.jms.listener.SimpleMessageListenerContainer.processMessage(SimpleMessageListenerContainer.java:311)
at
org.springframework.jms.listener.SimpleMessageListenerContainer$2.onMessage(SimpleMessageListenerContainer.java:287)
at
org.apache.activemq.ActiveMQMessageConsumer.dispatch(ActiveMQMessageConsumer.java:1088)
at
org.apache.activemq.ActiveMQSessionExecutor.dispatch(ActiveMQSessionExecutor.java:127)
at
org.apache.activemq.ActiveMQSessionExecutor.iterate(ActiveMQSessionExecutor.java:197)
at
org.apache.activemq.thread.PooledTaskRunner.runTask(PooledTaskRunner.java:122)
at
org.apache.activemq.thread.PooledTaskRunner$1.run(PooledTaskRunner.java:43)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.lang.Thread.run(Unknown Source)
Caused by: java.util.zip.ZipException: unknown compression method
at java.util.zip.InflaterInputStream.read(Unknown Source)
at java.util.zip.InflaterInputStream.read(Unknown Source)
at java.io.DataInputStream.readInt(Unknown Source)
at
org.apache.activemq.util.MarshallingSupport.readUTF8(MarshallingSupport.java:318)
at
org.apache.activemq.command.ActiveMQTextMessage.getText(ActiveMQTextMessage.java:86)
... 22 more
2010-04-15 11:46:16,394 INFO [VMTransport]
[org.apache.activemq.broker.util.LoggingBrokerPlugin] Acknowledging message
for client ID : ID:BHX000053-1777-1271328358487-3:0,
ID:BHX000053-1746-1271328334500-5:0:3:1:2
--
View this message in context: http://old.nabble.com/Message-compression%2C-intermittent-java.util.ZipException-tp28254566p28254566.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.