Hello,
I'm trying to publish messages using ConsumableQueue like this:
TopicProperty topicProp = new TopicProperty(global);
topicProp.setMsgDistributor("ConsumableQueue,1.0");
pq.setTopicProperty(topicProp);
xmlBlaster reported an exception when receiving the message:
java.lang.NullPointerException
at
org.xmlBlaster.engine.distributor.plugins.ConsumableQueuePlugin.processHistoryQueue(ConsumableQueuePlugin.java:192)
at
org.xmlBlaster.engine.distributor.plugins.ConsumableQueueWorker.run(ConsumableQueueWorker.java:36)
at
EDU.oswego.cs.dl.util.concurrent.PooledExecutor$Worker.run(PooledExecutor.java:732)
at java.lang.Thread.run(Unknown Source)
[Sep 29, 2004 12:12:40 PM ERROR
XmlBlaster.DispatchWorkerPool.xmlBlaster_192_168_1_101_3412-1
ConsumableQueuePlugin] processQueue: null
I did a quick trace and got rid of the exception by changing
"queue/history/maxEntriesCache" and "queue/history/maxEntries" back to
the default of 10 (I had set it to 0). I believe I had set the queue to
0 when trying to address this issue:
http://www.xmlblaster.org/mhonarc-xmlBlaster/msg02003.html
I'm off to test my ConsumableQueue code, just figured you may want to
know.
Thanks,
Aaron