Re: Programmatically purge() a queue

2009-08-11 Thread Bruce Snyder
On Tue, Aug 11, 2009 at 1:40 PM, centis wrote: > > I am trying to find an example of purging a Queue from Java.  Can someone > point me to someting besides, "Using JMX..." :)  I just need a way to clear > out the existing queues before my regression tests run. Oddly, the solution is to use JMX; ju

changing rg.apache.activemq.command.ActiveMQQueue destination at runtime?

2009-08-11 Thread Mick Knutson
I an creating a MDP and want to set the rg.apache.activemq.command.ActiveMQQueue destination at runtime to point to a VirtualTopic. Does anyone have any examples of this, and/or any gotchas ? --- Thank You… Mick Knutson, President BASE Logic, Inc. Enterprise Architecture, Design, Mentoring & Ag

Re: Implement request response with JMS over Stomp

2009-08-11 Thread Jose Luna
> If I understood right, then each requesting service A (A1...An) should > maintain its own unique correlation id (permanent during the connection's > life). My initial suggestion was actually to have a unique correlation-id for each request. This provides greater granularity than the above pro

vs2005-activemq-example blank console

2009-08-11 Thread asawilliams
I am able to compile/build the vs2005-activemq-example in vs2008, but when I try to run it, a console shows up and its blank. I should at least see the "Starting the example:", but I dont even get that. I have not changed the original code and here are the versions of the includes: apr 1.3.8 apr

Re: conduit subscriptions

2009-08-11 Thread Joe Fernandez
What about using virtual topics instead of topics? This way, all your consumers consume from queues. Joe http://www.ttmsolutions.com MatsH wrote: > > Hey, > > We use both topics and queues alongside selectors, ActiveMQ 5.2, and we > were intending to go live using a network of brokers and the

Re: Programmatically purge() a queue

2009-08-11 Thread Andreas Gies
hmmm, why not start the broker with the option "deleteAllMessagesOnStartup=true" for the test ? Best regards Andreas On Aug 11, 2009, at 7:40 PM, centis wrote: I am trying to find an example of purging a Queue from Java. Can someone point me to someting besides, "Using JMX..." :) I ju

Programmatically purge() a queue

2009-08-11 Thread centis
I am trying to find an example of purging a Queue from Java. Can someone point me to someting besides, "Using JMX..." :) I just need a way to clear out the existing queues before my regression tests run. Thanks! CB -- View this message in context: http://www.nabble.com/Programmatically-purge

Re: Virtual Topic and remote Client consumers

2009-08-11 Thread Mick Knutson
I tried what you suggested with this Broker: http://activemq.apache.org/schema/core";> ** ** And then I was sending mess

conduit subscriptions

2009-08-11 Thread Mats.Henrikson
Hey, We use both topics and queues alongside selectors, ActiveMQ 5.2, and we were intending to go live using a network of brokers and the clients using the failover: protocol. Unfortunately, due to how conduit subscriptions work we will start with a single broker for now, until we can figure out

Re: createSession() makes all the threads to wait ...

2009-08-11 Thread Norbert Pfistner
Maybe this is a ProducerFlowControl issue. Have you tried to turn it off? (see also http://kovyrin.net/2009/01/23/activemq-tips-flow-control-and-stalled-producers-problem/) Greetings, Norbert kley schrieb: sinus wrote: Hello to everybody. I need a help. During 3 days I'm trying to solve a p

Re: createSession() makes all the threads to wait ...

2009-08-11 Thread kley
sinus wrote: > > Hello to everybody. I need a help. During 3 days I'm trying to solve a > problem that appears with my embedded pub/sub(with listener) model after > processing around 8 messages. > So, all goes well: publishing and consumig , but after ~ 8 messages > the threads of my mu

Re: Implement request response with JMS over Stomp

2009-08-11 Thread Alexander L.
Jose, Thank you for the solution. =) If I understood right, then each requesting service A (A1...An) should maintain its own unique correlation id (permanent during the connection's life). That way message broker could decide which requesting service An to route message to if two or more request

New FAQ pages

2009-08-11 Thread Dejan Bosanac
Using log4j appender with ActiveMQ - http://activemq.apache.org/how-do-i-use-log4j-jms-appender-with-activemq.html Wire format negotiation exception - http://activemq.apache.org/javaxjmsjmsexception-wire-format-negociation-timeout-peer-did-not-send-his-wire-format.html Enjoy -- Dejan Bosanac Ope

Re: Implement request response with JMS over Stomp

2009-08-11 Thread Jose Luna
You can use two normal (non-temporary) queues, one for requests and one for responses. Each request will have a correlation-id header. Let's call the requesting service A and the responding service B. Service A will send to /queue/requests. Service B will receive (consume) the request, and

createSession() makes all the theard to wait ...

2009-08-11 Thread sinus
Hello to everybody. I need a help. During 3 days I'm trying to solve a problem that appears with my embedded pub/sub(with listener) model after processing around 8 messages. So, all goes well: publishing and consumig , but after ~ 8 messages the threads of my multi-theaded application blo

ActiveMQ failover and message consumption ?

2009-08-11 Thread bvill
I am using activemq in failover mode. I have noticed the following behavior : starting master starting slave => message publication and message consumption works fine. stopping master => message publication works fine. Message consumption does not work. stopping slave starting master starting sl

Implement request response with JMS over Stomp

2009-08-11 Thread Alexander L.
Hello All, Article http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html How should I implement request response with JMS describes how to implement request response using temporary queues created by clients. Stomp does not support temporary queues http://activemq.a

Build activemq-cpp lib in 32bit on 64bit system

2009-08-11 Thread Peter . Neu
Hi, I need to build a 32bit version of activemqcpp lib on a 64bit SLES 10 system because we use some third-party libs which unfortunately are only available in 32bit. I compiled apr,apr-util and apr-iconv with this compiler flag: CC="gcc -m32" ./configure. All went swell but when trying to do

Re: How can consumer monitor the producer via Spring

2009-08-11 Thread Dejan Bosanac
Hi, you're using vm transaport and you can exchange messages using it only inside the same application (vm). If you want to use this from two applications, one of them must connect over network. See http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.htmlfor more details. Cheer

jdbcPersistenceAdapter and lockAcquireSleepInterval

2009-08-11 Thread pevgen
Hello. I use a spring configuration and a "jdbcPersistenceAdapter" with oracle. How can i set a property "lockAcquireSleepInterval" in the spring configuration ? Thanks Evgeny -- View this message in context: http://www.nabble.com/jdbcPersistenceAdapter-and-lockAcquireSleepInterval-tp24913336p

ActiveMQ 5.3 pending message issue

2009-08-11 Thread Chen-hsiu Huang
Hi, We're using ActiveMQ 5.3 as our message service. However, we found that messages stall easily through our test. 1. We have two servers, each with two Intel Xeon E5420 CPUs, total 8 cores, 32 GB memory for each. Both servers run on Linux CentOS 5.3. 2. JDK 1.6.0_13 is used 3. The two serve