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.
