[ 
https://issues.apache.org/jira/browse/ARTEMIS-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Thomas Küstermann updated ARTEMIS-2132:
---------------------------------------
    Description: 
Nabble forum reference: [\[Artemis 2.6.3\] Multicast consumer via HTTP 
transport: AMQ212037 Connection failure has been 
detected|http://activemq.2283324.n4.nabble.com/Artemis-2-6-3-Multicast-consumer-via-HTTP-transport-AMQ212037-Connection-failure-has-been-detected-td4744416.html]

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 on 
[Github|https://github.com/thokuest/activemq-artemis-http-transport-multicast].

The code produces 10 messages and a consumer receives these 10 messages. If I 
add a delay as in {{Thread.sleep()}} between each call to 
{{MessageConsumer.receive()}}, let's say 1 second, then I receive the following 
exceptions:

{code:none|title=Client Side}
java.lang.reflect.InvocationTargetException
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
(ArtemisClientPlugin.java:61)
    at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
(ArtemisAbstractPlugin.java:74)
    at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
(DefaultBuildPluginManager.java:134)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:208)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:154)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:146)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:117)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:81)
    at 
org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
 (SingleThreadedBuilder.java:51)
    at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
(LifecycleStarter.java:128)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
    at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
    at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
    at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
    at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
(Launcher.java:289)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
(Launcher.java:229)
    at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
(Launcher.java:415)
    at org.codehaus.plexus.classworlds.launcher.Launcher.main 
(Launcher.java:356)
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)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
(ArtemisClientPlugin.java:61)
    at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
(ArtemisAbstractPlugin.java:74)
    at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
(DefaultBuildPluginManager.java:134)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:208)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:154)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:146)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:117)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:81)
    at 
org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
 (SingleThreadedBuilder.java:51)
    at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
(LifecycleStarter.java:128)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
    at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
    at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
    at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
    at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
(Launcher.java:289)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
(Launcher.java:229)
    at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
(Launcher.java:415)
    at org.codehaus.plexus.classworlds.launcher.Launcher.main 
(Launcher.java:356)
Caused by: org.apache.activemq.artemis.api.core.ActiveMQObjectClosedException: 
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)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
(ArtemisClientPlugin.java:61)
    at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
(ArtemisAbstractPlugin.java:74)
    at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
(DefaultBuildPluginManager.java:134)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:208)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:154)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:146)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:117)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:81)
    at 
org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
 (SingleThreadedBuilder.java:51)
    at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
(LifecycleStarter.java:128)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
    at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
    at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
    at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
    at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
(Launcher.java:289)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
(Launcher.java:229)
    at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
(Launcher.java:415)
    at org.codehaus.plexus.classworlds.launcher.Launcher.main 
(Launcher.java:356)
{code}

{code:none|title=Server Side}
server-out:2018-10-17 12:56:13,367 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-17 12:56:13,367 WARN  
[org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, 
clearing up resources for session 429aaede-d1fb-11e8-b57e-0a0027000011
server-out:2018-10-17 12:56:13,367 WARN  
[org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for 
session 429aaede-d1fb-11e8-b57e-0a0027000011
server-out:2018-10-17 12:56:13,367 WARN  
[org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, 
clearing up resources for session 429c357f-d1fb-11e8-b57e-0a0027000011
server-out:2018-10-17 12:56:13,377 WARN  
[org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for 
session 429c357f-d1fb-11e8-b57e-0a0027000011
{code}

According to [~jbertram], this is caused by commit 
{{775b1c78aa690872ef7775f97ccdea408ed3830c}}, ARTEMIS-1927. See Nabble forum 
reference for details.

h4. Workarounds

# Downgrade to Artemis 2.6.3
# Configure {{confirmationWindowSize}} to something greater than 0 in the 
ConnectionFactory URL

  was:
Nabble forum reference: [\[Artemis 2.6.3\] Multicast consumer via HTTP 
transport: AMQ212037 Connection failure has been 
detected|http://activemq.2283324.n4.nabble.com/Artemis-2-6-3-Multicast-consumer-via-HTTP-transport-AMQ212037-Connection-failure-has-been-detected-td4744416.html]

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 on 
[Github|https://github.com/thokuest/activemq-artemis-http-transport-multicast].

The code produces 10 messages and a consumer receives these 10 messages. If I 
add a delay as in {{Thread.sleep()}} between each call to
{{MessageConsumer.receive()}}, let's say 1 second, then I receive the 
following exceptions:

{code:none|title=Client Side}
java.lang.reflect.InvocationTargetException
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
(ArtemisClientPlugin.java:61)
    at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
(ArtemisAbstractPlugin.java:74)
    at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
(DefaultBuildPluginManager.java:134)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:208)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:154)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:146)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:117)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:81)
    at 
org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
 (SingleThreadedBuilder.java:51)
    at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
(LifecycleStarter.java:128)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
    at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
    at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
    at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
    at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
(Launcher.java:289)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
(Launcher.java:229)
    at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
(Launcher.java:415)
    at org.codehaus.plexus.classworlds.launcher.Launcher.main 
(Launcher.java:356)
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)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
(ArtemisClientPlugin.java:61)
    at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
(ArtemisAbstractPlugin.java:74)
    at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
(DefaultBuildPluginManager.java:134)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:208)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:154)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:146)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:117)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:81)
    at 
org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
 (SingleThreadedBuilder.java:51)
    at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
(LifecycleStarter.java:128)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
    at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
    at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
    at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
    at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
(Launcher.java:289)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
(Launcher.java:229)
    at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
(Launcher.java:415)
    at org.codehaus.plexus.classworlds.launcher.Launcher.main 
(Launcher.java:356)
Caused by: org.apache.activemq.artemis.api.core.ActiveMQObjectClosedException: 
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)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
(ArtemisClientPlugin.java:61)
    at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
(ArtemisAbstractPlugin.java:74)
    at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
(DefaultBuildPluginManager.java:134)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:208)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:154)
    at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
(MojoExecutor.java:146)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:117)
    at org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
(LifecycleModuleBuilder.java:81)
    at 
org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
 (SingleThreadedBuilder.java:51)
    at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
(LifecycleStarter.java:128)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
    at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
    at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
    at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
    at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
    at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
    at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke 
(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke 
(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke (Method.java:498)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
(Launcher.java:289)
    at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
(Launcher.java:229)
    at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
(Launcher.java:415)
    at org.codehaus.plexus.classworlds.launcher.Launcher.main 
(Launcher.java:356)
{code}

{code:none|title=Server Side}
server-out:2018-10-17 12:56:13,367 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-17 12:56:13,367 WARN  
[org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, 
clearing up resources for session 429aaede-d1fb-11e8-b57e-0a0027000011
server-out:2018-10-17 12:56:13,367 WARN  
[org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for 
session 429aaede-d1fb-11e8-b57e-0a0027000011
server-out:2018-10-17 12:56:13,367 WARN  
[org.apache.activemq.artemis.core.server] AMQ222061: Client connection failed, 
clearing up resources for session 429c357f-d1fb-11e8-b57e-0a0027000011
server-out:2018-10-17 12:56:13,377 WARN  
[org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for 
session 429c357f-d1fb-11e8-b57e-0a0027000011
{code}

According to [~jbertram], this is caused by commit 
{{775b1c78aa690872ef7775f97ccdea408ed3830c}}, ARTEMIS-1927. See Nabble forum 
reference for details.

h4. Workarounds

# Downgrade to Artemis 2.6.3
# Configure {{confirmationWindowSize}} to something greater than 0 in the 
ConnectionFactory URL


> Multicast consumer via HTTP transport: AMQ212037 Connection failure has been 
> detected
> -------------------------------------------------------------------------------------
>
>                 Key: ARTEMIS-2132
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-2132
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>    Affects Versions: 2.6.2, 2.6.3
>         Environment: - {code:none|title=$ java -version}
> java version "1.8.0_181"
> Java(TM) SE Runtime Environment (build 1.8.0_181-b13)
> Java HotSpot(TM) 64-Bit Server VM (build 25.181-b13, mixed mode)
> {code}
> - OS: Windows 7
>            Reporter: Thomas Küstermann
>            Priority: Major
>
> Nabble forum reference: [\[Artemis 2.6.3\] Multicast consumer via HTTP 
> transport: AMQ212037 Connection failure has been 
> detected|http://activemq.2283324.n4.nabble.com/Artemis-2-6-3-Multicast-consumer-via-HTTP-transport-AMQ212037-Connection-failure-has-been-detected-td4744416.html]
> 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 on 
> [Github|https://github.com/thokuest/activemq-artemis-http-transport-multicast].
> The code produces 10 messages and a consumer receives these 10 messages. If I 
> add a delay as in {{Thread.sleep()}} between each call to 
> {{MessageConsumer.receive()}}, let's say 1 second, then I receive the 
> following exceptions:
> {code:none|title=Client Side}
> java.lang.reflect.InvocationTargetException
>     at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke 
> (NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke 
> (DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke (Method.java:498)
>     at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
> (ArtemisClientPlugin.java:61)
>     at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
> (ArtemisAbstractPlugin.java:74)
>     at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
> (DefaultBuildPluginManager.java:134)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:208)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:154)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:146)
>     at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
> (LifecycleModuleBuilder.java:117)
>     at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
> (LifecycleModuleBuilder.java:81)
>     at 
> org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
>  (SingleThreadedBuilder.java:51)
>     at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
> (LifecycleStarter.java:128)
>     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
>     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
>     at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
>     at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
>     at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
>     at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke 
> (NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke 
> (DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke (Method.java:498)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
> (Launcher.java:289)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
> (Launcher.java:229)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
> (Launcher.java:415)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.main 
> (Launcher.java:356)
> 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)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke 
> (NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke 
> (DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke (Method.java:498)
>     at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
> (ArtemisClientPlugin.java:61)
>     at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
> (ArtemisAbstractPlugin.java:74)
>     at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
> (DefaultBuildPluginManager.java:134)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:208)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:154)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:146)
>     at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
> (LifecycleModuleBuilder.java:117)
>     at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
> (LifecycleModuleBuilder.java:81)
>     at 
> org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
>  (SingleThreadedBuilder.java:51)
>     at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
> (LifecycleStarter.java:128)
>     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
>     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
>     at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
>     at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
>     at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
>     at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke 
> (NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke 
> (DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke (Method.java:498)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
> (Launcher.java:289)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
> (Launcher.java:229)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
> (Launcher.java:415)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.main 
> (Launcher.java:356)
> Caused by: 
> org.apache.activemq.artemis.api.core.ActiveMQObjectClosedException: 
> 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)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke 
> (NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke 
> (DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke (Method.java:498)
>     at org.apache.activemq.artemis.maven.ArtemisClientPlugin.doExecute 
> (ArtemisClientPlugin.java:61)
>     at org.apache.activemq.artemis.maven.ArtemisAbstractPlugin.execute 
> (ArtemisAbstractPlugin.java:74)
>     at org.apache.maven.plugin.DefaultBuildPluginManager.executeMojo 
> (DefaultBuildPluginManager.java:134)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:208)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:154)
>     at org.apache.maven.lifecycle.internal.MojoExecutor.execute 
> (MojoExecutor.java:146)
>     at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
> (LifecycleModuleBuilder.java:117)
>     at 
> org.apache.maven.lifecycle.internal.LifecycleModuleBuilder.buildProject 
> (LifecycleModuleBuilder.java:81)
>     at 
> org.apache.maven.lifecycle.internal.builder.singlethreaded.SingleThreadedBuilder.build
>  (SingleThreadedBuilder.java:51)
>     at org.apache.maven.lifecycle.internal.LifecycleStarter.execute 
> (LifecycleStarter.java:128)
>     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:309)
>     at org.apache.maven.DefaultMaven.doExecute (DefaultMaven.java:194)
>     at org.apache.maven.DefaultMaven.execute (DefaultMaven.java:107)
>     at org.apache.maven.cli.MavenCli.execute (MavenCli.java:955)
>     at org.apache.maven.cli.MavenCli.doMain (MavenCli.java:290)
>     at org.apache.maven.cli.MavenCli.main (MavenCli.java:194)
>     at sun.reflect.NativeMethodAccessorImpl.invoke0 (Native Method)
>     at sun.reflect.NativeMethodAccessorImpl.invoke 
> (NativeMethodAccessorImpl.java:62)
>     at sun.reflect.DelegatingMethodAccessorImpl.invoke 
> (DelegatingMethodAccessorImpl.java:43)
>     at java.lang.reflect.Method.invoke (Method.java:498)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.launchEnhanced 
> (Launcher.java:289)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.launch 
> (Launcher.java:229)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.mainWithExitCode 
> (Launcher.java:415)
>     at org.codehaus.plexus.classworlds.launcher.Launcher.main 
> (Launcher.java:356)
> {code}
> {code:none|title=Server Side}
> server-out:2018-10-17 12:56:13,367 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-17 12:56:13,367 WARN  
> [org.apache.activemq.artemis.core.server] AMQ222061: Client connection 
> failed, clearing up resources for session 429aaede-d1fb-11e8-b57e-0a0027000011
> server-out:2018-10-17 12:56:13,367 WARN  
> [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for 
> session 429aaede-d1fb-11e8-b57e-0a0027000011
> server-out:2018-10-17 12:56:13,367 WARN  
> [org.apache.activemq.artemis.core.server] AMQ222061: Client connection 
> failed, clearing up resources for session 429c357f-d1fb-11e8-b57e-0a0027000011
> server-out:2018-10-17 12:56:13,377 WARN  
> [org.apache.activemq.artemis.core.server] AMQ222107: Cleared up resources for 
> session 429c357f-d1fb-11e8-b57e-0a0027000011
> {code}
> According to [~jbertram], this is caused by commit 
> {{775b1c78aa690872ef7775f97ccdea408ed3830c}}, ARTEMIS-1927. See Nabble forum 
> reference for details.
> h4. Workarounds
> # Downgrade to Artemis 2.6.3
> # Configure {{confirmationWindowSize}} to something greater than 0 in the 
> ConnectionFactory URL



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to