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 <jbert...@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.kuesterm...@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 >> >
