git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: [Artemis 2.6.3] Multicast consumer via HTTP transport: AMQ212037 Connection failure has been detected


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@xxxxxxxxxx> 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@xxxxxxxxxxx>
> 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
>>
>