git.net

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

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


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