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
