activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Szymon Reichmann (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ARTEMIS-766) Artemis does not work as a replacement for ActiveMQ if there are NMS clients
Date Fri, 30 Sep 2016 20:18:20 GMT

    [ https://issues.apache.org/jira/browse/ARTEMIS-766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15536951#comment-15536951
] 

Szymon Reichmann commented on ARTEMIS-766:
------------------------------------------

I guess that artemis.log won't help here. It might be actually related to the way how the
message is sent, not received... I found this in the console (no trace of it in the log file)

{code}
java.lang.ArrayIndexOutOfBoundsException: 57
        at org.apache.activemq.util.DataByteArrayInputStream.readUTF(DataByteArrayInputStream.java:269)
        at org.apache.activemq.openwire.v10.BaseDataStreamMarshaller.looseUnmarshalString(BaseDataStreamMarshaller.java:571)
        at org.apache.activemq.openwire.v10.MessageIdMarshaller.looseUnmarshal(MessageIdMarshaller.java:122)
        at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal(OpenWireFormat.java:366)
        at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:200)
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.toAMQMessage(OpenWireMessageConverter.java:708)
        at org.apache.activemq.artemis.core.protocol.openwire.OpenWireMessageConverter.createMessageDispatch(OpenWireMessageConverter.java:426)
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQConsumer.handleDeliver(AMQConsumer.java:197)
        at org.apache.activemq.artemis.core.protocol.openwire.amq.AMQSession.sendMessage(AMQSession.java:207)
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.deliverStandardMessage(ServerConsumerImpl.java:1043)
        at org.apache.activemq.artemis.core.server.impl.ServerConsumerImpl.proceedDeliver(ServerConsumerImpl.java:417)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.proceedDeliver(QueueImpl.java:2508)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.deliver(QueueImpl.java:2000)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl.access$1700(QueueImpl.java:100)
        at org.apache.activemq.artemis.core.server.impl.QueueImpl$DeliverRunner.run(QueueImpl.java:2749)
        at org.apache.activemq.artemis.utils.OrderedExecutorFactory$OrderedExecutor$ExecutorTask.run(OrderedExecutorFactory.java:103)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
{code}

I will try to prepare a test-case for it.

> Artemis does not work as a replacement for ActiveMQ if there are NMS clients
> ----------------------------------------------------------------------------
>
>                 Key: ARTEMIS-766
>                 URL: https://issues.apache.org/jira/browse/ARTEMIS-766
>             Project: ActiveMQ Artemis
>          Issue Type: Bug
>    Affects Versions: 1.4.0
>         Environment: Apache.NMS 1.7.1
> Apache.NMS.ActiveMQ 1.7.2
>            Reporter: Szymon Reichmann
>            Priority: Minor
>
> I've been using ActiveMQ v 5.x for quite a while. Just recently I added a NMS client
that consumes messages produced in a Java application. It worked just fine. I decided to give
Artemis a try. Unfortunately it doesn't seem to work properly on the Artemis <-> NMS
client part. 
> Messages that are produced and consumed in the Java application works fine.
> But on the NMS client side no messages are being received.
> After connecting the the queue (it currently has 5 messages waiting to be consumed) I
see the following in the log.
> {code}
> 10:37:51,829 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
ClusterCommunication::Sending notification for addBinding LocalQueueBinding [address=jms.topic.ActiveMQ.Advisory.TempQueue,
queue=QueueImpl[name=f85f9094-5c0f-470a-be54-d031b13d66f0, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008]]@7b527d1f,
filter=null, name=f85f9094-5c0f-470a-be54-d031b13d66f0, clusterName=f85f9094-5c0f-470a-be54-d031b13d66f09a3fecd3-8668-11e6-98aa-000c29447008]
from server ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008
> 10:37:51,830 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968941,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=f85f9094-5c0f-470a-be54-d031b13d66f0,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968940,_AMQ_NotifTimestamp=1475257071830,_AMQ_ClusterName=f85f9094-5c0f-470a-be54-d031b13d66f09a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb14056-8734-11e6-9bfd-000c29447008]]@44721067
> 10:37:51,830 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968941,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=f85f9094-5c0f-470a-be54-d031b13d66f0,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968940,_AMQ_NotifTimestamp=1475257071830,_AMQ_ClusterName=f85f9094-5c0f-470a-be54-d031b13d66f09a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb14056-8734-11e6-9bfd-000c29447008]]@44721067
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,833 INFO  [org.apache.activemq.artemis.core.server] AMQ221052: Deploying topic
jms.topic.ActiveMQ.Advisory.TempQueue
> 10:37:51,834 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
ClusterCommunication::Sending notification for addBinding LocalQueueBinding [address=jms.topic.ActiveMQ.Advisory.TempQueue,
queue=QueueImpl[name=jms.topic.ActiveMQ.Advisory.TempQueue, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008]]@5d2fa19b,
filter=FilterImpl [sfilterString=__AMQX=-1], name=jms.topic.ActiveMQ.Advisory.TempQueue, clusterName=jms.topic.ActiveMQ.Advisory.TempQueue9a3fecd3-8668-11e6-98aa-000c29447008]
from server ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008
> 10:37:51,839 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968944,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968943,_AMQ_FilterString=__AMQX=-1,_AMQ_NotifTimestamp=1475257071835,_AMQ_ClusterName=jms.topic.ActiveMQ.Advisory.TempQueue9a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb203a7-8734-11e6-9bfd-000c29447008]]@1184925132
> 10:37:51,839 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968944,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968943,_AMQ_FilterString=__AMQX=-1,_AMQ_NotifTimestamp=1475257071835,_AMQ_ClusterName=jms.topic.ActiveMQ.Advisory.TempQueue9a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb203a7-8734-11e6-9bfd-000c29447008]]@1184925132
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,847 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968945,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[message=ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=TOPIC_CREATED,_AMQ_NotifTimestamp=1475257071847]]@787653250
> 10:37:51,847 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968945,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[message=ActiveMQ.Advisory.TempQueue,_AMQ_NotifType=TOPIC_CREATED,_AMQ_NotifTimestamp=1475257071847]]@787653250
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,847 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968946,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=f85f9094-5c0f-470a-be54-d031b13d66f0,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=ID:IBLAZON-SE1-13651-636108286720307602-1:0:-1,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_RemoteAddress=/192.168.232.128:13650,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1475257071847,_AMQ_ClusterName=f85f9094-5c0f-470a-be54-d031b13d66f09a3fecd3-8668-11e6-98aa-000c29447008]]@1595371228
> 10:37:51,848 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968946,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=f85f9094-5c0f-470a-be54-d031b13d66f0,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=ID:IBLAZON-SE1-13651-636108286720307602-1:0:-1,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempQueue,_AMQ_RemoteAddress=/192.168.232.128:13650,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1475257071847,_AMQ_ClusterName=f85f9094-5c0f-470a-be54-d031b13d66f09a3fecd3-8668-11e6-98aa-000c29447008]]@1595371228
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,848 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
ClusterCommunication::Sending notification for addBinding LocalQueueBinding [address=jms.topic.ActiveMQ.Advisory.TempTopic,
queue=QueueImpl[name=964c404b-42e9-4df5-b2a0-e1df2fb94bfb, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008]]@1d5b0e17,
filter=null, name=964c404b-42e9-4df5-b2a0-e1df2fb94bfb, clusterName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb9a3fecd3-8668-11e6-98aa-000c29447008]
from server ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008
> 10:37:51,849 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968949,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968948,_AMQ_NotifTimestamp=1475257071849,_AMQ_ClusterName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb9a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb42688-8734-11e6-9bfd-000c29447008]]@637946252
> 10:37:51,849 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968949,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968948,_AMQ_NotifTimestamp=1475257071849,_AMQ_ClusterName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb9a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb42688-8734-11e6-9bfd-000c29447008]]@637946252
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,850 INFO  [org.apache.activemq.artemis.core.server] AMQ221052: Deploying topic
jms.topic.ActiveMQ.Advisory.TempTopic
> 10:37:51,852 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
ClusterCommunication::Sending notification for addBinding LocalQueueBinding [address=jms.topic.ActiveMQ.Advisory.TempTopic,
queue=QueueImpl[name=jms.topic.ActiveMQ.Advisory.TempTopic, postOffice=PostOfficeImpl [server=ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008]]@7892cccb,
filter=FilterImpl [sfilterString=__AMQX=-1], name=jms.topic.ActiveMQ.Advisory.TempTopic, clusterName=jms.topic.ActiveMQ.Advisory.TempTopic9a3fecd3-8668-11e6-98aa-000c29447008]
from server ActiveMQServerImpl::serverUUID=9a3fecd3-8668-11e6-98aa-000c29447008
> 10:37:51,852 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968952,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968951,_AMQ_FilterString=__AMQX=-1,_AMQ_NotifTimestamp=1475257071852,_AMQ_ClusterName=jms.topic.ActiveMQ.Advisory.TempTopic9a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb4c2c9-8734-11e6-9bfd-000c29447008]]@471280779
> 10:37:51,852 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968952,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_Binding_Type=0,_AMQ_RoutingName=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_Distance=0,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_NotifType=BINDING_ADDED,_AMQ_Binding_ID=4294968951,_AMQ_FilterString=__AMQX=-1,_AMQ_NotifTimestamp=1475257071852,_AMQ_ClusterName=jms.topic.ActiveMQ.Advisory.TempTopic9a3fecd3-8668-11e6-98aa-000c29447008,foobar=9cb4c2c9-8734-11e6-9bfd-000c29447008]]@471280779
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,856 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968953,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[message=ActiveMQ.Advisory.TempTopic,_AMQ_NotifType=TOPIC_CREATED,_AMQ_NotifTimestamp=1475257071856]]@1501143720
> 10:37:51,856 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968953,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[message=ActiveMQ.Advisory.TempTopic,_AMQ_NotifType=TOPIC_CREATED,_AMQ_NotifTimestamp=1475257071856]]@1501143720
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,857 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968954,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=ID:IBLAZON-SE1-13651-636108286720307602-1:0:-1,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_RemoteAddress=/192.168.232.128:13650,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1475257071857,_AMQ_ClusterName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb9a3fecd3-8668-11e6-98aa-000c29447008]]@591242201
> 10:37:51,857 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968954,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=ID:IBLAZON-SE1-13651-636108286720307602-1:0:-1,_AMQ_Address=jms.topic.ActiveMQ.Advisory.TempTopic,_AMQ_RemoteAddress=/192.168.232.128:13650,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1475257071857,_AMQ_ClusterName=964c404b-42e9-4df5-b2a0-e1df2fb94bfb9a3fecd3-8668-11e6-98aa-000c29447008]]@591242201
is not going anywhere as it didn't have a binding on address:activemq.notifications
> 10:37:51,867 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Couldn't find any bindings for address=activemq.notifications on message=ServerMessage[messageID=4294968956,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=jms.queue.JPQueue,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=ID:IBLAZON-SE1-13651-636108286720307602-1:0:1,_AMQ_Address=jms.queue.JPQueue,_AMQ_RemoteAddress=/192.168.232.128:13650,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1475257071866,_AMQ_ClusterName=jms.queue.JPQueue9a3fecd3-8668-11e6-98aa-000c29447008]]@303247046
> 10:37:51,868 DEBUG [org.apache.activemq.artemis.core.postoffice.impl.PostOfficeImpl]
Message ServerMessage[messageID=4294968956,durable=true,userID=null,priority=0, bodySize=512,
timestamp=0,expiration=0, durable=true, address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=jms.queue.JPQueue,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=ID:IBLAZON-SE1-13651-636108286720307602-1:0:1,_AMQ_Address=jms.queue.JPQueue,_AMQ_RemoteAddress=/192.168.232.128:13650,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1475257071866,_AMQ_ClusterName=jms.queue.JPQueue9a3fecd3-8668-11e6-98aa-000c29447008]]@303247046
is not going anywhere as it didn't have a binding on address:activemq.notifications
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message