Hi,
Tested and wrote an blog post on $Subject [1]. Used MB 3.0.0 Milestone 2
pack.
Noted following.
1. I saw *for each message* it creates a subscription to queue indicated by
reply destination. Is this acceptable? In a loaded scenario this will not
work.
2. Sometimes MB gives following errors (intermittent).
[2015-02-08 09:39:00,094] INFO
{org.wso2.andes.subscription.SubscriptionStore} - New Local Subscription
Added [SMSReceiveNotificationStore]ID=4@NODESUNRISE-LINUX/
127.0.1.1/D=true/X=false/O=null/E=amq.direct/ET=org.wso2.andes.server.exchange.DirectExchange$1@72fa4b2a/EUD=0/S=true
[2015-02-08 09:39:02,185] ERROR
{org.wso2.andes.server.cassandra.MessageFlusher} - Error occurred while
sending messages to subscribers from buffer
java.lang.NullPointerException
at
org.wso2.andes.server.cassandra.OnflightMessageTracker.getNotAckedMessageCount(OnflightMessageTracker.java:728)
at
org.wso2.andes.server.cassandra.MessageFlusher.isThisSubscriptionHasRoom(MessageFlusher.java:364)
at
org.wso2.andes.server.cassandra.MessageFlusher.sendMessagesToSubscriptions(MessageFlusher.java:441)
at
org.wso2.andes.server.cassandra.MessageFlusher.sendMessagesInBuffer(MessageFlusher.java:335)
at
org.wso2.andes.server.cassandra.MessageFlusher.sendMessageToFlusher(MessageFlusher.java:297)
at
org.wso2.andes.server.slot.SlotDeliveryWorker.run(SlotDeliveryWorker.java:229)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2015-02-08 09:39:07,188] FATAL
{org.wso2.andes.server.cassandra.MessageFlusher} - Error running Cassandra
Message FlusherError occurred while sending messages to subscribers from
message bufferjava.lang.NullPointerException
org.wso2.andes.kernel.AndesException: Error occurred while sending messages
to subscribers from message bufferjava.lang.NullPointerException
at
org.wso2.andes.server.cassandra.MessageFlusher.sendMessagesInBuffer(MessageFlusher.java:339)
at
org.wso2.andes.server.cassandra.MessageFlusher.sendMessageToFlusher(MessageFlusher.java:297)
at
org.wso2.andes.server.slot.SlotDeliveryWorker.run(SlotDeliveryWorker.java:229)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
[2015-02-08 09:39:07,224] INFO
{org.wso2.andes.subscription.SubscriptionStore} - Local Subscription
Removed [SMSReceiveNotificationStore]ID=4@NODESUNRISE-LINUX/
127.0.1.1/D=true/X=false/O=null/E=amq.direct/ET=org.wso2.andes.server.exchange.DirectExchange$1@72fa4b2a/EUD=0/S=false
[1].
http://abeykoon.blogspot.com/2015/02/jms-synchronous-invocations-dual.html
--
*Hasitha Abeykoon*
Senior Software Engineer; WSO2, Inc.; http://wso2.com
*cell:* *+94 719363063*
*blog: **abeykoon.blogspot.com* <http://abeykoon.blogspot.com>
_______________________________________________
Dev mailing list
Dev@wso2.org
http://wso2.org/cgi-bin/mailman/listinfo/dev
