You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by abhijith <to...@gmail.com> on 2016/02/11 03:45:58 UTC

Error while master boots up

Hi All,

I am new to Artemis and trying to setup simple master/slave setup with
static connectors.  I have followed static connector example to setup
config.  But, when I try to bring up the cluster I am getting an error in
master node.  Slave is coming up successfully without any issue.  Not sure
what I am doing wrong here.  Please help

23:21:42,669 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-server]. Adding protocol support for: CORE
23:21:42,678 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-amqp-protocol]. Adding protocol support for:
AMQP
23:21:42,720 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-hornetq-protocol]. Adding protocol support
for: HORNETQ
23:21:42,728 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for:
MQTT
23:21:42,738 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-openwire-protocol]. Adding protocol support
for: OPENWIRE
23:21:42,790 ERROR [org.apache.activemq.artemis.core.client] AMQ214013:
Failed to decode packet: java.lang.IllegalArgumentException: AMQ119032:
Invalid type: 1
        at
org.apache.activemq.artemis.core.protocol.core.impl.PacketDecoder.decode(PacketDecoder.java:413)
[artemis-core-client-1.2.0.jar:1.2.0]
        at
org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder.java:60)
[artemis-core-client-1.2.0.jar:1.2.0]
        at
org.apache.activemq.artemis.core.protocol.ServerPacketDecoder.decode(ServerPacketDecoder.java:202)
[artemis-server-1.2.0.jar:1.2.0]
        at
org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:343)
[artemis-core-client-1.2.0.jar:1.2.0]
        at
org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingBufferHandler.bufferReceived(ClientSessionFactoryImpl.java:1140)
[artemis-core-client-1.2.0.jar:1.2.0]
        at
org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
[artemis-core-client-1.2.0.jar:1.2.0]
        at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
[netty-all-4.0.32.Final.jar:4.0.32.Final]
        at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]



--
View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Error while master boots up

Posted by abhijith <to...@gmail.com>.
Got it fixed.  Had a connector definition wrong on slave broker.xml.  Have
pushed latest to the examples.  



--
View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407p4707462.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Error while master boots up

Posted by abhijith <to...@gmail.com>.
Hi Clebert

I tried to bring up the cluster after accepting pull request.  But for some
reason backup server does not come up.  Live comes up fine.  I have pushed
latest config again.  Can you please glance and let me know if you see
anything wrong in config?

Backup server just hangs after these messages

ReplicatedFailbackStaticExample1-out:23:35:14,798 INFO 
[org.apache.activemq.artemis.core.server] AMQ221013: Using NIO Journal
ReplicatedFailbackStaticExample1-out:23:35:14,863 INFO 
[org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found:
[artemis-server]. Adding protocol support for: CORE
ReplicatedFailbackStaticExample1-out:23:35:14,866 INFO 
[org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found:
[artemis-amqp-protocol]. Adding protocol support for: AMQP
ReplicatedFailbackStaticExample1-out:23:35:14,877 INFO 
[org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found:
[artemis-hornetq-protocol]. Adding protocol support for: HORNETQ
ReplicatedFailbackStaticExample1-out:23:35:14,879 INFO 
[org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found:
[artemis-mqtt-protocol]. Adding protocol support for: MQTT
ReplicatedFailbackStaticExample1-out:23:35:14,882 INFO 
[org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found:
[artemis-openwire-protocol]. Adding protocol support for: OPENWIRE
awaiting server tcp://localhost:61617 start at
ReplicatedFailbackStaticExample1-out:23:35:15,010 INFO 
[org.apache.activemq.artemis.core.server] AMQ221043: Protocol module found:
[artemis-stomp-protocol]. Adding protocol support for: STOMP



--
View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407p4707441.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Error while master boots up

Posted by abhijith <to...@gmail.com>.
Thanks Clebert!! Really apppretiate your help.  I will try this out and let
you know the outcome.

Can I get a bit more info on connector's name?  Does connector type is
picked up by name??  I tried reading connectors document under 'configuring
transports' but couldn't find much info on significance of name.



--
View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407p4707440.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Error while master boots up

Posted by Clebert Suconic <cl...@gmail.com>.
I have sent a pull request to your fork fixing a few configuration errors:

https://github.com/abhijith-prabhakar/activemq-artemis/pull/1


You had backup connecting itself and the server wasn't still up.



On Thu, Feb 11, 2016 at 3:56 PM, abhijith <to...@gmail.com> wrote:
> Thanks for the response.  I have added an example with config I am using
> here:
> https://github.com/abhijith-prabhakar/activemq-artemis/tree/master/examples/bugs
>
> I tried to run Replicated static example test case and it is giving me
> different error with embedded broker. Please also note the the above error
> occurred on when I tried to bring up cluster on Solaris VM.
>
> Please let me know if you need any more info.
>
> Appreciate your help.
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407p4707428.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.



-- 
Clebert Suconic

Re: Error while master boots up

Posted by abhijith <to...@gmail.com>.
Thanks for the response.  I have added an example with config I am using
here: 
https://github.com/abhijith-prabhakar/activemq-artemis/tree/master/examples/bugs

I tried to run Replicated static example test case and it is giving me
different error with embedded broker. Please also note the the above error
occurred on when I tried to bring up cluster on Solaris VM.

Please let me know if you need any more info.

Appreciate your help.



--
View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407p4707428.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Error while master boots up

Posted by Clebert Suconic <cl...@gmail.com>.
Can you provide configurations, a running example?

Or an easy way would be you creating a fork of Artemis from
https://github.com/apache/activemq-artemis/, and put what's happening
on an example.


Even a wrong configuration shouldn't throw such exceptions, so I'm
interested on knowing how you managed to do it.


On Wed, Feb 10, 2016 at 9:45 PM, abhijith <to...@gmail.com> wrote:
> Hi All,
>
> I am new to Artemis and trying to setup simple master/slave setup with
> static connectors.  I have followed static connector example to setup
> config.  But, when I try to bring up the cluster I am getting an error in
> master node.  Slave is coming up successfully without any issue.  Not sure
> what I am doing wrong here.  Please help
>
> 23:21:42,669 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
> Protocol module found: [artemis-server]. Adding protocol support for: CORE
> 23:21:42,678 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
> Protocol module found: [artemis-amqp-protocol]. Adding protocol support for:
> AMQP
> 23:21:42,720 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
> Protocol module found: [artemis-hornetq-protocol]. Adding protocol support
> for: HORNETQ
> 23:21:42,728 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
> Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for:
> MQTT
> 23:21:42,738 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
> Protocol module found: [artemis-openwire-protocol]. Adding protocol support
> for: OPENWIRE
> 23:21:42,790 ERROR [org.apache.activemq.artemis.core.client] AMQ214013:
> Failed to decode packet: java.lang.IllegalArgumentException: AMQ119032:
> Invalid type: 1
>         at
> org.apache.activemq.artemis.core.protocol.core.impl.PacketDecoder.decode(PacketDecoder.java:413)
> [artemis-core-client-1.2.0.jar:1.2.0]
>         at
> org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder.java:60)
> [artemis-core-client-1.2.0.jar:1.2.0]
>         at
> org.apache.activemq.artemis.core.protocol.ServerPacketDecoder.decode(ServerPacketDecoder.java:202)
> [artemis-server-1.2.0.jar:1.2.0]
>         at
> org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:343)
> [artemis-core-client-1.2.0.jar:1.2.0]
>         at
> org.apache.activemq.artemis.core.client.impl.ClientSessionFactoryImpl$DelegatingBufferHandler.bufferReceived(ClientSessionFactoryImpl.java:1140)
> [artemis-core-client-1.2.0.jar:1.2.0]
>         at
> org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
> [artemis-core-client-1.2.0.jar:1.2.0]
>         at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:265)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:308)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:294)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:846)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at
> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:112)
> [netty-all-4.0.32.Final.jar:4.0.32.Final]
>         at java.lang.Thread.run(Thread.java:745) [rt.jar:1.8.0_66]
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.nabble.com/Error-while-master-boots-up-tp4707407.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.



-- 
Clebert Suconic