Mailing-List: contact commits-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@activemq.apache.org
Date: Thu, 13 Nov 2014 15:40:34 +0000 (UTC)
From: "Lars Paulsen (JIRA)" <jira@apache.org>
To: commits@activemq.apache.org
Message-ID: <JIRA.12755087.1415893208000.491940.1415893234020@Atlassian.JIRA>
In-Reply-To: <JIRA.12755087.1415893208000@Atlassian.JIRA>
References: <JIRA.12755087.1415893208000@Atlassian.JIRA>
 <JIRA.12755087.1415893208709@arcas>
Subject: [jira] [Created] (APLO-371) ClassCastException on receiving first
 TRANSFER message
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit

Lars Paulsen created APLO-371:
---------------------------------

             Summary: ClassCastException on receiving first TRANSFER message
                 Key: APLO-371
                 URL: https://issues.apache.org/jira/browse/APLO-371
             Project: ActiveMQ Apollo
          Issue Type: Bug
          Components: apollo-amqp
    Affects Versions: 1.6, 1.7
         Environment: INFO  | OS     : Windows Vista 6.0
INFO  | JVM    : Java HotSpot(TM) Client VM 1.8.0_25 (Oracle Corpo
INFO  | Apollo : 1.7 (at: C:\apollo\apache-apollo-1.7)
INFO  | Starting store: leveldb store at C:\apollo\mybroker\data
            Reporter: Lars Paulsen


I am running tests of an embedded system using QPID proton C stack connecting to a Windows Vista PC running Apache Apollo 1.7. The transport protocol used is AMQP.

The connection establishment succeeds but when the Apollo server receives the first TRANSFER message a ClassCastException is thrown:

2014-11-13 15:41:59,602 | WARN  | stackref=149a9991438
java.lang.ClassCastException: org.apache.qpid.proton.codec.DecoderImpl$UnknownDescribedType cannot be cast to org.apache.qpid.proton.amqp.messaging.Section
	at org.apache.qpid.proton.message.impl.MessageImpl.decode(MessageImpl.java:574)
	at org.apache.activemq.apollo.amqp.AmqpMessage.decoded(AmqpMessage.scala:86)
	at org.apache.activemq.apollo.amqp.AmqpProtocolHandler$AmqpProducerRoute.onMessage(AmqpProtocolHandler.scala:812)
	at org.apache.activemq.apollo.amqp.AmqpProtocolHandler$ProducerSupport$class.process(AmqpProtocolHandler.scala:782)
	at org.apache.activemq.apollo.amqp.AmqpProtocolHandler$AmqpProducerRoute.process(AmqpProtocolHandler.scala:788)
	at org.apache.activemq.apollo.amqp.AmqpProtocolHandler$$anon$3.processDelivery(AmqpProtocolHandler.scala:479)
	at org.apache.qpid.proton.hawtdispatch.impl.AmqpTransport.fireListenerEvents(AmqpTransport.java:406)
	at org.apache.qpid.proton.hawtdispatch.impl.AmqpTransport$AmqpTransportListener.process(AmqpTransport.java:473)
	at org.apache.qpid.proton.hawtdispatch.impl.AmqpTransport$AmqpTransportListener.onTransportCommand(AmqpTransport.java:465)
	at org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:659)
	at org.fusesource.hawtdispatch.transport.TcpTransport$6.run(TcpTransport.java:538)
	at org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:226)
	at org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:96)
	at org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)

I am not sure if this problem is related to the Apache Apollo project or the Apache QPID project. Also, I'm not sure if probably the received TRANSFER message is miscoded.

This is the message dump of the received TRANSFER:
RECV: /172.16.1.31:5672 | Transfer{handle=0, deliveryId=0, deliveryTag=\x00Sp\xd0\x00\x00\x00\x0b\x00\x00\x00\x05BP\x04@
BR\x00\x00Ss\xd0\x00\x00\x004\x00\x00\x00\x0d@@\xa1\x0cqueue://test@@@@\xa3\x04UTF8\x83\x00\x00\x00\x00\x00\x00\x03\xe8\
x83\x00\x00\x00\x00\x00\x00\x00\x00@R\x00@, messageFormat=0, settled=false, more=false, rcvSettleMode=null, state=null,
resume=false, aborted=false, batchable=false}

I hope this is not a fault from my side but I did not find any information to continue further on my own.


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)