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


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
>