From users-return-50583-archive-asf-public=cust-asf.ponee.io@activemq.apache.org Mon Oct 15 19:55:03 2018 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx-eu-01.ponee.io (Postfix) with SMTP id E9BC6180647 for ; Mon, 15 Oct 2018 19:55:02 +0200 (CEST) Received: (qmail 62515 invoked by uid 500); 15 Oct 2018 17:55:01 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 62503 invoked by uid 99); 15 Oct 2018 17:55:01 -0000 Received: from mail-relay.apache.org (HELO mailrelay1-lw-us.apache.org) (207.244.88.152) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Oct 2018 17:55:01 +0000 Received: from mail-ot1-f53.google.com (mail-ot1-f53.google.com [209.85.210.53]) by mailrelay1-lw-us.apache.org (ASF Mail Server at mailrelay1-lw-us.apache.org) with ESMTPSA id EDD69E1C for ; Mon, 15 Oct 2018 17:55:00 +0000 (UTC) Received: by mail-ot1-f53.google.com with SMTP id l58so19775681otd.6 for ; Mon, 15 Oct 2018 10:55:00 -0700 (PDT) X-Gm-Message-State: ABuFfohKD8LlNbQNhkZbSb/TeEvzXUJmttuUDRAa3+Gl1Z/bcbqb6uqn O7/MjwJe/PQDqULUtKxsefQ+Edi+6QdTdjrWG2dU6g== X-Google-Smtp-Source: ACcGV62ONIP8miHAX+ISx+zHubUcniv1g2hU/0HwqlrybqWJ/M9XZCOdlWnItAPucnJ+HBAtOV8hzHEhGCLyhSXYBCs= X-Received: by 2002:a9d:5225:: with SMTP id e37mr11955351oth.336.1539626100352; Mon, 15 Oct 2018 10:55:00 -0700 (PDT) MIME-Version: 1.0 References: <1539616510661-0.post@n4.nabble.com> In-Reply-To: <1539616510661-0.post@n4.nabble.com> From: Justin Bertram Date: Mon, 15 Oct 2018 12:54:48 -0500 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: [Artemis 2.6.3] Multicast consumer via HTTP transport: AMQ212037 Connection failure has been detected To: users@activemq.apache.org Content-Type: multipart/alternative; boundary="000000000000cc8d4105784822f7" --000000000000cc8d4105784822f7 Content-Type: text/plain; charset="UTF-8" Content-Transfer-Encoding: quoted-printable 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=3DGENERIC_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 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 clos= ed > ... > Caused by: javax.jms.IllegalStateException: AMQ119017: Consumer is clos= ed > at > org.apache.activemq.artemis.core.client.impl.ClientConsumerImpl.checkClos= ed > (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 h= as > been detected: > io.netty.handler.codec.http.HttpObjectAggregator$AggregatedFullHttpReques= t > cannot be cast to io.netty.buffer.ByteBuf [code=3DGENERIC_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=C3=BCstermann > > > > -- > Sent from: > http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html > --000000000000cc8d4105784822f7--