You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Marko Asplund (JIRA)" <ji...@apache.org> on 2013/10/15 23:27:45 UTC

[jira] [Comment Edited] (AMQ-4792) Send over amqp+nio transport block indefinitely

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

Marko Asplund edited comment on AMQ-4792 at 10/15/13 9:26 PM:
--------------------------------------------------------------

Hi Kevin.
I placed the class in ActiveMQ 5.8.0 source tree in activemq-amqp module (under test). Had to make some small changes to make it compile (nioPort, method throws declarations).

There's no errors from the test but based on the output it looks like the test client tries to connect to an incorrect port (see attached output).
Also, the output doesn't include any mention of amqp-nio connector being started.


was (Author: aspa):
Hi Kevin.
I placed the class in ActiveMQ 5.8.0 source tree in activemq-amqp module (under test). Had to make some small changes to make it compile (nioPort, method throws declarations).

There's no errors from the test but based on the output it looks like the test client tries to connect to an incorrect port (see attached output).

> Send over amqp+nio transport block indefinitely
> -----------------------------------------------
>
>                 Key: AMQ-4792
>                 URL: https://issues.apache.org/jira/browse/AMQ-4792
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Connector
>    Affects Versions: 5.8.0
>         Environment: Red Hat Enterprise Linux 6.4, OpenJDK 1.7.0_25
>            Reporter: Marko Asplund
>         Attachments: AMQ4792Test.java, org.apache.activemq.transport.amqp.bugs.AMQ4792Test-output.txt
>
>
> When trying to send a message to a topic over AMQP using QPid Java client example the operation block indefinitely if amqp+nio transport is configured on the ActiveMQ side. With amqp transport the operation succeeds.
> The example program is executed with the following arguments:
> java -cp lib/proton-api-0.5.jar:lib/proton-j-impl-0.5.jar:target/classes org.apache.qpid.proton.example.Send -a "amqp://127.0.0.1:5672/topic://test.foo" -s bar3255 'xxyyzz555'
> The code can be found here:
> http://svn.apache.org/repos/asf/qpid/proton/trunk/examples/messenger/java/src/main/java/org/apache/qpid/proton/example/Send.java



--
This message was sent by Atlassian JIRA
(v6.1#6144)