activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Justin Bertram <jbert...@apache.org>
Subject Re: [Artemis 2.6.3] Multicast consumer via HTTP transport: AMQ212037 Connection failure has been detected
Date Mon, 15 Oct 2018 18:51:35 GMT
Some quick testing indicates this failure was introduced in 2.6.2 which
means if you use 2.6.1 it should work.


Justin

On Mon, Oct 15, 2018 at 12:54 PM Justin Bertram <jbertram@apache.org> wrote:

> This WARN message:
>
>   AMQ212037: Connection failure has been detected:
> io.netty.handler.codec.http.HttpObjectAggregator$AggregatedFullHttpRequest
> cannot be cast to io.netty.buffer.ByteBuf [code=GENERIC_EXCEPTION]
>
> Indicates to me that you're hitting a bug.
>
> Out of curiosity, why are you using the HTTP transport.  I don't think
> it's commonly used.
>
>
> Justin
>
> On Mon, Oct 15, 2018 at 10:15 AM thokuest <t.kuestermann@outlook.com>
> wrote:
>
>> I just started using ActiveMQ Artemis and would like to check whether I'm
>> doing something wrong or if I hit a bug.
>>
>> I want to consume messages from a multicast address via HTTP transport. I
>> tweaked the http-transport example
>> (apache-artemis-2.6.3/examples/features/standard/http-transport) for my
>> purpose. The code I'm working on is to be found here:
>> https://github.com/thokuest/activemq-artemis-http-transport-multicast
>>
>> The code produces 10 messages. A consumer receives the 10 messages. Fine,
>> but when I add a delay (Thread.sleep()) between each
>> MessageConsumer.receive() call, let's say 1 second, then I receive the
>> following exception message in the client:
>>
>>   java.lang.reflect.InvocationTargetException
>>       ...
>>   Caused by: javax.jms.IllegalStateException: AMQ119017: Consumer is
>> closed
>>       ...
>>   Caused by: javax.jms.IllegalStateException: AMQ119017: Consumer is
>> closed
>>       at
>>
>> org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.checkClosed
>> (ClientConsumerImpl.java:952)
>>       at
>> org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.receive
>> (ClientConsumerImpl.java:195)
>>       at
>> org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.receive
>> (ClientConsumerImpl.java:379)
>>       at
>> org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.getMessage
>> (ActiveMQMessageConsumer.java:212)
>>       at
>> org.apache.activemq.artemis.jms.client.ActiveMQMessageConsumer.receive
>> (ActiveMQMessageConsumer.java:128)
>>       at thokuest.HttpTransportTopicExample.main
>> (HttpTransportTopicExample.java:79)
>>
>> The server tells me the following:
>>
>>   server-out:2018-10-15 17:06:39,048 WARN
>> [org.apache.activemq.artemis.core.client] AMQ212037: Connection failure
>> has
>> been detected:
>> io.netty.handler.codec.http.HttpObjectAggregator$AggregatedFullHttpRequest
>> cannot be cast to io.netty.buffer.ByteBuf [code=GENERIC_EXCEPTION]
>>   server-out:2018-10-15 17:06:39,048 WARN
>> [org.apache.activemq.artemis.core.server] AMQ222061: Client connection
>> failed, clearing up resources for session
>> ea11b326-d08b-11e8-9365-b808cf47fdc0
>>   server-out:2018-10-15 17:06:39,048 WARN
>> [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources
>> for session ea11b326-d08b-11e8-9365-b808cf47fdc0
>>   server-out:2018-10-15 17:06:39,048 WARN
>> [org.apache.activemq.artemis.core.server] AMQ222061: Client connection
>> failed, clearing up resources for session
>> ea11b327-d08b-11e8-9365-b808cf47fdc0
>>   server-out:2018-10-15 17:06:39,058 WARN
>> [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources
>> for session ea11b327-d08b-11e8-9365-b808cf47fdc0
>>
>> Any clue what's going on?
>>
>> Kind regards,
>> Thomas K├╝stermann
>>
>>
>>
>> --
>> Sent from:
>> http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
>>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message