Re: way to speed up the message publishing ?

2009-09-21 Thread czy11421
Bruce Snyder wrote: On Mon, Sep 21, 2009 at 2:12 PM, czy11421 wrote: Do we have a way to speed up the message publishing ? For testing the workload, I want the Market Data Publisher Demo will publish message in every 100ms, how to do it ? Using async sends usually speeds things up

Re: what is best practices to implement Multithread + JMS ?

2009-09-21 Thread czy11421
Bruce Snyder wrote: On Fri, Sep 18, 2009 at 8:42 PM, Robert Nicholson wrote: Also, Is there a simple example of a JMS consumer that's using DMLC with ActiveMQ available? I'm attaching a zip file that contains some very basic examples of using the DefaultMessageListenerContainer. These

way to speed up the message publishing ?

2009-09-21 Thread czy11421
Do we have a way to speed up the message publishing ? For testing the workload, I want the Market Data Publisher Demo will publish message in every 100ms, how to do it ? Thanks.

Re: Spring JMS : can't receive message ?

2009-09-21 Thread czy11421
f not, consider adding something like this: Regards, 2009/9/21 czy11421 : Hi, All, I have tried to write a JMS with Spring, but failed. no compiler error, no runtime error, just wait infinitely,

Spring JMS : can't receive message ?

2009-09-20 Thread czy11421
Hi, All, I have tried to write a JMS with Spring, but failed. no compiler error, no runtime error, just wait infinitely, can't receive message, but I am sure the ActiveMQ is publishing data in 'STOCKS.SUNW' topic. Anybody has some clues ? Thanks. / MessageReceiver.jav

what is best practices to implement Multithread + JMS ?

2009-09-18 Thread czy11421
what is best practices to implement Multithread + JMS ? Let us assume we are listening financial market data feed. I have this coding like this: class MyClass implements Listener{ private final ExecutorService pool = Executors.newFixedThreadPool(poolSize); onMessage(...){ pool.e

Re: error in subscribing topic

2009-09-14 Thread czy11421
Rob Davies wrote: On 14 Sep 2009, at 00:00, czy11421 wrote: Rob Davies wrote: On 13 Sep 2009, at 20:03, czy11421 wrote: Rob Davies wrote: On 13 Sep 2009, at 17:55, czy11421 wrote: Rob, Thanks for your reply. Here is another question. If I use MessageListener, how could I start to

Re: error in subscribing topic

2009-09-13 Thread czy11421
Rob Davies wrote: On 13 Sep 2009, at 20:03, czy11421 wrote: Rob Davies wrote: On 13 Sep 2009, at 17:55, czy11421 wrote: Rob, Thanks for your reply. Here is another question. If I use MessageListener, how could I start to receive message ? Coding as below, the Listener will NOT output

Re: error in subscribing topic

2009-09-13 Thread czy11421
Rob Davies wrote: On 13 Sep 2009, at 17:55, czy11421 wrote: Rob, Thanks for your reply. Here is another question. If I use MessageListener, how could I start to receive message ? Coding as below, the Listener will NOT output message. Did I miss something ? Thanks. Edward

Re: error in subscribing topic

2009-09-13 Thread czy11421
Rob, Thanks for your reply. Here is another question. If I use MessageListener, how could I start to receive message ? Coding as below, the Listener will NOT output message. Did I miss something ? Thanks. Edward //- session = conn.createTopicSession(false, To

Re: error in subscribing topic

2009-09-13 Thread czy11421
Rob Davies wrote: On 12 Sep 2009, at 23:53, czy11421 wrote: I am running ActiveMQ 5, in the admin web page, I could see "STOCKS.SUNW" in Topics, and this topic is sending out message, then how could I subscribe this topic and get the published message ? I have tried this coding,

error in subscribing topic

2009-09-12 Thread czy11421
I am running ActiveMQ 5, in the admin web page, I could see "STOCKS.SUNW" in Topics, and this topic is sending out message, then how could I subscribe this topic and get the published message ? I have tried this coding, but I get the error as bottom. Where is the bug ? Thanks. ///

Re: Which jars for a JMS publisher consumer?

2009-09-11 Thread czy11421
For me, I just copy all jars in lib folder into classpath, it will compile, although some jars are unnecessary. Robert Nicholson wrote: Which jars from activemq do I need to include in my project if I'm just wanting to publish and consume from the queues with an external application?