On 18/12/2007, shineOnYou <[EMAIL PROTECTED]> wrote:
>
> Hi James,
> Thanks for reply.
> Would you please explain the significance of Thread(int size) method in
> ProcessorType Class.
> Initially i thought the following code will create n consumer thread.
> from(endpoint_1).Thread(n).process(new EventDrivenConsumer());
That would result in the processing of the messages being sent to an
asynchronous thread pool. What you really want is N parallel JMS
consumers - so the concurrentConsumers is what you want - so that
under the covers you create N different JMS sessions &
MessageConsumers etc
> Well how to set multiple parameters i tried to use following that does not
> seem to be working.
> from("test-jms:queue:soo.loo?concurrentConsumers=5&explicitQosEnabled=true&priority=7").process(new
> Processor(){ }
That looks fine to me - why doesn't it work?
> One more problem is that when i executed the application(stand-alone)
> several time and then i started getting following exception and warning ---
> WARNING: Failed to start jmx connector: Cannot bind to URL
> [rmi://localhost:1099/jmxrmi]: javax.naming.NameAlreadyBoundException:
> jmxrmi [Root exception is java.rmi.AlreadyBoundException: jmxrmi]
> Dec 18, 2007 8:02:01 PM
> org.apache.activemq.store.DefaultPersistenceAdapterFactory createJournal
> INFO: Journal is locked... waiting 10 seconds for the journal to be
> unlocked.
> Dec 18, 2007 8:02:11 PM
> org.apache.activemq.store.DefaultPersistenceAdapterFactory createJournal
> INFO: Journal is locked... waiting 10 seconds for the journal to be
> unlocked.
Sounds like you are running more than one ActiveMQ broker on the same
box. Disable JMX on the broker if you want?
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://open.iona.com
