It looks like you are running Artemis embedded within Wildfly, but didn't
mention what version of Artemis you are using. What happens if you try to
connect to Artemis when it is not embedded within Wildfly?
Also, you are connecting to port 5445. Is this the port that has the
OpenWire protocol handler attached to it? Or in other words, do you have
your client sending OpenWire to the server when it is expecting MQTT or
something else?
On Sat, Nov 7, 2015, 5:16 AM Vinche <vincent.sou...@gmail.com> wrote:
> Hello,
>
> I'm trying to consume a remote JMS queue from a .Net Apache NMS Client
> (Apache ActiveMQ ™ -- Apache.NMS.ActiveMQ - version 1.7.1) but each time
> the
> client tries to create a Session, I've got an IllegalArgumentException on
> Wildfly :
>
> / ERROR [org.apache.activemq.artemis.core.client] (Thread-1
> (activemq-netty-threads-104851096)) 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)
> at
>
> org.apache.activemq.artemis.core.protocol.ClientPacketDecoder.decode(ClientPacketDecoder.java:60)
> at
>
> org.apache.activemq.artemis.core.protocol.ServerPacketDecoder.decode(ServerPacketDecoder.java:196)
> at
>
> org.apache.activemq.artemis.core.protocol.core.impl.RemotingConnectionImpl.bufferReceived(RemotingConnectionImpl.java:324)
> at
>
> org.apache.activemq.artemis.core.remoting.server.impl.RemotingServiceImpl$DelegatingBufferHandler.bufferReceived(RemotingServiceImpl.java:603)
> at
>
> org.apache.activemq.artemis.core.remoting.impl.netty.ActiveMQChannelHandler.channelRead(ActiveMQChannelHandler.java:68)
> at
>
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at
>
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at
>
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:242)
> at
>
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at
>
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at
>
> io.netty.handler.codec.ByteToMessageDecoder.handlerRemoved(ByteToMessageDecoder.java:202)
> at
>
> io.netty.channel.DefaultChannelPipeline.callHandlerRemoved0(DefaultChannelPipeline.java:528)
> at
>
> io.netty.channel.DefaultChannelPipeline.callHandlerRemoved(DefaultChannelPipeline.java:522)
> at
>
> io.netty.channel.DefaultChannelPipeline.remove0(DefaultChannelPipeline.java:351)
> at
>
> io.netty.channel.DefaultChannelPipeline.remove(DefaultChannelPipeline.java:322)
> at
>
> io.netty.channel.DefaultChannelPipeline.remove(DefaultChannelPipeline.java:299)
> at
>
> org.apache.activemq.artemis.core.protocol.ProtocolHandler$ProtocolDecoder.decode(ProtocolHandler.java:174)
> at
>
> io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:315)
> at
>
> io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:229)
> at
>
> org.apache.activemq.artemis.core.protocol.ProtocolHandler$ProtocolDecoder.channelRead(ProtocolHandler.java:117)
> at
>
> io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:339)
> at
>
> io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:324)
> at
>
> io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:847)
> at
>
> io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:131)
> at
> io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:511)
> at
>
> io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:468)
> at
>
> io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:382)
> at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:354)
> at
>
> io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:111)
> at java.lang.Thread.run(Thread.java:745) /
>
> Here is my wildfly configuration :
>
> / <subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
> <server name="default">
> <security-setting name="#">
> <role name="guest" send="true" consume="true"
> create-non-durable-queue="true" delete-non-durable-queue="true"/>
> </security-setting>
> <address-setting name="#"
> dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue"
> max-size-bytes="10485760" page-size-bytes="2097152"
> message-counter-history-day-limit="10"/>
> <http-connector name="http-connector"
> socket-binding="http" endpoint="http-acceptor"/>
> <http-connector name="http-connector-throughput"
> socket-binding="http" endpoint="http-acceptor-throughput">
>
> </http-connector>
> <remote-connector name="netty"
> socket-binding="messaging"/>
> <remote-connector name="netty-throughput"
> socket-binding="messaging-throughput">
>
> </remote-connector>
> <in-vm-connector name="in-vm" server-id="0"/>
> <http-acceptor name="http-acceptor"
> http-listener="default"/>
> <http-acceptor name="http-acceptor-throughput"
> http-listener="default">
>
>
> </http-acceptor>
> <remote-acceptor name="netty"
> socket-binding="messaging"/>
> <remote-acceptor name="netty-throughput"
> socket-binding="messaging-throughput">
>
>
> </remote-acceptor>
> <in-vm-acceptor name="in-vm" server-id="0"/>
> <jms-queue name="ExpiryQueue"
> entries="java:/jms/queue/ExpiryQueue"/>
> <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
> <jms-queue name="TestQueue"
> entries="java:jboss/exported/jms/queue/TestQueue"/>
> <connection-factory name="InVmConnectionFactory"
> connectors="in-vm" entries="java:/ConnectionFactory"/>
> <connection-factory name="RemoteConnectionFactory"
> connectors="http-connector"
> entries="java:jboss/exported/jms/RemoteConnectionFactory"/>
> <connection-factory name="NettyConnectionFactory"
> connectors="netty"
> entries="java:jboss/exported/jms/NettyConnectionFactory"/>
> <pooled-connection-factory name="activemq-ra"
> transaction="xa" connectors="in-vm" entries="java:/JmsXA
> java:jboss/DefaultJMSConnectionFactory"/>
> </server>
> </subsystem>
> [...]
> <socket-binding-group name="standard-sockets"
> default-interface="public"
> port-offset="${jboss.socket.binding.port-offset:0}">
> [...]
> <socket-binding name="messaging" port="5445"/>
> <socket-binding name="messaging-throughput" port="5455"/>
> </socket-binding-group>
> /
> and here is the client code which raises the exception :
>
>
> / Uri connecturi = new
> Uri("activemq:tcp://wildlfy10TestServer:5445");
> IConnectionFactory factory = new
> NMSConnectionFactory(connecturi);
>
> using (IConnection connection = factory.CreateConnection("user",
> "password"))
> using (ISession session = connection.CreateSession()) /* Code
> fails
> here and Exception is raised in Wildfly */
> {
> // do Something
> } /
>
>
> Did I do something wrong or did I hit a bug ?
>
> Thanks for your advices.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Issue-with-Wildfly-10-and-Net-NMS-Client-tp4703766.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
