Details
Description
I was testing the example of proton-c and proton-j for both receive and send functionality. On the same code (c to c and java to java) it's work flawlessly. The problem occur when I'm using proton-j as a reciever and proton-c as a sender, in JDK 7 it's not work, while in JDK 6, sometimes it work (but mostly not work). But it also work fine if I'm using proton-c as a receiver and proton-j as a sender.
Below is the message log when I'm sending with proton-c sender :
FINE: Processing active connector ConnectorImpl [_channel=java.nio.channels.SocketChannel[connected local=/127.0.0.1:5672 remote=/127.0.0.1:49625]]
Sep 09, 2013 9:40:40 AM org.apache.qpid.proton.engine.impl.FrameParser input
FINE: IN: CH[0] : Transfer
[\x00Sp\xd0\x00\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00g\x00\x00\x00\x0d@@\xa1\x13amqp://0.0.0.0/test\xa1\x04test\xa1+amqp://c29e810a-d645-4edb-962e-01dcb43f5b11@@@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x00\x00\x00\x00\x00\x00@R\x00@\x00Sw\xa1\x0cHello World!]
Sep 09, 2013 9:40:40 AM org.apache.qpid.proton.engine.impl.FrameParser input
FINE: IN: CH[0] : Detach
Sep 09, 2013 9:40:40 AM org.apache.qpid.proton.engine.impl.FrameParser input
FINE: IN: CH[0] : Close
Sep 09, 2013 9:40:40 AM org.apache.qpid.proton.messenger.impl.MessengerImpl processActive
FINE: Processing active connector ConnectorImpl [_channel=java.nio.channels.SocketChannel[closed]]
For comparison, below is the message log when I'm sending the message with proton-j sender:
FINE: Processing active connector ConnectorImpl [_channel=java.nio.channels.SocketChannel[connected local=/10.8.93.56:5672 remote=/10.8.93.56:49629]]
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.engine.impl.FrameParser input
FINE: IN: CH[0] : Transfer{handle=0, deliveryId=0, deliveryTag=1, messageFormat=0, settled=true, more=false, rcvSettleMode=null, state=null, resume=false, aborted=false, batchable=false}[\x00Ss\xc0K\x05@@\xa1\x13amqp://0.0.0.0/test\xa1\x04Test\xa1+amqp://24439c22-1f01-412a-8ae2-86a9bd239ea7\x00Sw\xa1\x0eHello World!!!]
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.messenger.impl.MessengerImpl get
FINE: Attempting to get message from EndpointImpl [_localState=ACTIVE, _remoteState=ACTIVE, _localError=Error{condition=null, description='null', info=null}, _remoteError=Error{condition=null, description='null', info=null}]
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.messenger.impl.MessengerImpl get
FINE: Readable delivery found: DeliveryImpl [_tag=[49], _link=EndpointImpl [_localState=ACTIVE, _remoteState=ACTIVE, _localError=Error{condition=null, description='null', info=null}, _remoteError=Error{condition=null, description='null', info=null}], _deliveryState=null, _settled=false, _remoteSettled=true, _remoteDeliveryState=null, _flags=4, _transportDelivery=org.apache.qpid.proton.engine.impl.TransportDelivery@60bb94d9, _dataSize=99, _complete=true, _updated=true, _done=false, _offset=0]
message: 1
Address: amqp://0.0.0.0/test
Subject: Test
Headers: null
AmqpValue{Hello World!!!}
END
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.messenger.impl.MessengerImpl recv
FINE: MessengerImpl [_name=544e183e-e802-438b-92b0-ce52b4228c1f] about to wait for up to -1 messages to be received
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.messenger.impl.MessengerImpl processActive
FINE: Processing active connector ConnectorImpl [_channel=java.nio.channels.SocketChannel[connected local=/10.8.93.56:5672 remote=/10.8.93.56:49629]]
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.engine.impl.FrameParser input
FINE: IN: CH[0] : Close{error=null}
Sep 09, 2013 9:41:30 AM org.apache.qpid.proton.messenger.impl.MessengerImpl processActive
FINE: Processing active connector ConnectorImpl [_channel=java.nio.channels.SocketChannel[closed]]