qpid-proton mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Robbie Gemmell (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (PROTON-422) [proton-j] proton-c proton-j send and receive compatibility
Date Fri, 20 Jun 2014 16:34:24 GMT

    [ https://issues.apache.org/jira/browse/PROTON-422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14039000#comment-14039000
] 

Robbie Gemmell commented on PROTON-422:
---------------------------------------

I did however make some small tweaks to make the java send example behave more like the others,
see PROTON-613.

> [proton-j] proton-c proton-j send and receive compatibility 
> ------------------------------------------------------------
>
>                 Key: PROTON-422
>                 URL: https://issues.apache.org/jira/browse/PROTON-422
>             Project: Qpid Proton
>          Issue Type: Bug
>          Components: proton-c, proton-j
>    Affects Versions: 0.5
>         Environment: Windows 7, JDK 7, JDK 6
>            Reporter: Sahal Zain
>            Assignee: Robbie Gemmell
>
> 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{handle=0, deliveryId=0, deliveryTag=\x00\x00\x00\x00\x00\x00\x00\x00,
messageFormat=0, settled=true, more=false, rcvSettleMode=null, state=null, resume=false, aborted=false,
batchable=false}[\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{handle=0, closed=true, error=null}
> Sep 09, 2013 9:40:40 AM org.apache.qpid.proton.engine.impl.FrameParser input
> FINE: IN: CH[0] : Close{error=null}
> 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]]
>  



--
This message was sent by Atlassian JIRA
(v6.2#6252)

Mime
View raw message