activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Marko Asplund (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (AMQ-4792) Send over amqp+nio transport block indefinitely
Date Tue, 15 Oct 2013 21:27:45 GMT

    [ 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)

Mime
View raw message