ActiveMQ 4.1.1 client hangs on issuing a burst of messages

2009-01-14 Thread uma_rk
Env: ActiveMQ 4.1.1, Spring 2.5.4, JDK1.6 I have a number of clients (about 9) connecting to an external broker using TCP transport. When one of the clients sends a volley of messages, the activemq connection seems to deadlock - I say *seems* to because I see no deadlocks in the full thread d

Re: HTTP Transport Configuration with Tomcat

2009-01-14 Thread msatyadi
Yes, the application requires things to work across default http/https connection. We cannot require the users of our application to punch holes on their firewall to enable tcp communication over the default activeMQ port. Dejan Bosanac wrote: > > Hi, > > is there any particular reason you p

Discovery & Store and Forwarding Queues

2009-01-14 Thread project2501
Hi, I read that multicast broker discovery is enabled by default and in my 5.2 AMQ it seems its configured that way. What I want to do is run 2 ActiveMQ 5.2 instances on a subnet, on different machines and have them auto-discover each other - and have messages sent to any local broker to propa

Re: Pausing a consumer

2009-01-14 Thread James Strachan
Just add a sleep in your consumer. 2008/3/14 brianbaquiran : > > Hello, > Is there a way to temporarily pause or throttle messages received by a > consumer using a messageListener? > > I'm writing a program that takes messages from a queue and sends them to a > process on a remote server using a p

Re: PyActiveMQ: Retrieving Queue Size (Or other Queue related info)

2009-01-14 Thread Timothy Bish
ActiveMQ doesn't have a QueueBrowser implementation, we'd love for someone to contribute the code, but for right now its not supported. Regards Tim On Wed, 2009-01-14 at 09:15 -0800, Jahvid.Williams wrote: > Good Day All, > > Does anyone know if it is currently possible using pyactivemq (for pyt

Re: Pausing a consumer

2009-01-14 Thread Jahvid.Williams
brianbaquiran wrote: > > Hello, > Is there a way to temporarily pause or throttle messages received by a > consumer using a messageListener? > As far as i have found in the on_message method for your MessageListener class you could attempt to slow down the message consumption process, possibly

Re: Log4J ActiveMQ JMS Appender

2009-01-14 Thread Richard Dunn
> can you run with -Dlog4j.debug (set the system property) to see where > the log4j configuration is coming from? The following is the debug output - other webapps (not spring) started up normally, with the same settings from the log4j.properties. log4j: Using URL [file:/usr/local/apache-tomcat

Re: Log4J ActiveMQ JMS Appender

2009-01-14 Thread Bruce Snyder
On Wed, Jan 14, 2009 at 10:39 AM, Richard Dunn wrote: > > I am also having this problem, but the problem only occurs in one scenario - > in my appfuse based spring web application. If I use the same versions of > activemq and log4j in my other web applications (older traditional > jsp/servlet weba

Re: Log4J ActiveMQ JMS Appender

2009-01-14 Thread Gary Tully
can you run with -Dlog4j.debug (set the system property) to see where the log4j configuration is coming from? It may be that the wireFormatNegotiator is trying to log a message which is trying to start a jms connection which uses wireFormatNegotiator etc. Chicken and egg. logging for activemq need

Re: Log4J ActiveMQ JMS Appender

2009-01-14 Thread Richard Dunn
I am also having this problem, but the problem only occurs in one scenario - in my appfuse based spring web application. If I use the same versions of activemq and log4j in my other web applications (older traditional jsp/servlet webapps) everything works fine. I am currently using activemq 5.1, 5

PyActiveMQ: Retrieving Queue Size (Or other Queue related info)

2009-01-14 Thread Jahvid.Williams
Good Day All, Does anyone know if it is currently possible using pyactivemq (for python 2.5) to retrieve queue information, more specifically the size of a queue/topic? I know in java there is a QueueBrowser, however is such an implementation readily available in the current pyactivemq, ActiveMQ-

Requirements to ensure no message loss in master/slave configuration

2009-01-14 Thread ariekenb
Suppose I have the following situation: incoming messages on JMS queues -> bean processor (business logic) -> outgoing messages on JMS queues I have this all running on ServiceMix 4, which includes ActiveMQ 5.1. I'm injecting messages into the bean processor using the Camel bean component to in

Re: JDBC Master slave does not work when the primary node is rebooted

2009-01-14 Thread Gary Tully
This jira[1] has a discussion and a patch attached that may help: [1] https://issues.apache.org/activemq/browse/AMQ-1350 It would be good to get another perspective on it to see if the suggestions can be rolled into trunk. 2009/1/14 soa-junkie : > > We are using the JDBC master slave deployment

Re: Persistant and Non-Persistant queues

2009-01-14 Thread Gary Tully
also see: http://activemq.apache.org/what-is-the-difference-between-persistent-and-non-persistent-delivery.html 2009/1/14 James Strachan : > 2009/1/14 David Newcomb : >> >> Firstly, I am using Spring to help manage my Topics / Queues. >> >> To start with I'll give a brief explanation of my scenar

Re: Persistant and Non-Persistant queues

2009-01-14 Thread James Strachan
2009/1/14 David Newcomb : > > Firstly, I am using Spring to help manage my Topics / Queues. > > To start with I'll give a brief explanation of my scenario. > > 1. Work requests come into my system and are added to a non-persistant > queue. > 2. Another thread takes entries out of the (non-persisten

Persistant and Non-Persistant queues

2009-01-14 Thread David Newcomb
Firstly, I am using Spring to help manage my Topics / Queues. To start with I'll give a brief explanation of my scenario. 1. Work requests come into my system and are added to a non-persistant queue. 2. Another thread takes entries out of the (non-persistent) queue, does some stuff and adds the

Re: problem while using xpath in eip-router

2009-01-14 Thread manish_goyal
Hi, More clear picture of my scenario is:- I am getting message with soap-env in ActiveMQ queue. from there message is getting consume by jms consumer. Jms consumer is sending this message to eip-router . Using xpath-splitter in eip-router i am extracting some elements of message and routing ele

Re: HTTP Transport Configuration with Tomcat

2009-01-14 Thread Dejan Bosanac
Hi, is there any particular reason you prefer the http transport over the default tcp one? Http transport has many drawbacks and if you have Java clients, tcp should be the way to go. Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning

Re: ActiveMQ Basic Queries

2009-01-14 Thread Antriksh Verma
Hi Garry .. Thanks for ur valuable suggestion. Perhaps have to reconfigure my broker/clients configurations , I was using default settings of Broker/Producer/Consumer. Hope to get support from you further too !! Again Thanks. Regards Antriksh Gary Tully wrote: > > check out : http://activemq

Re: Publication on Topic slows to a crawl

2009-01-14 Thread Bruce Snyder
On Sat, Dec 13, 2008 at 9:20 AM, mar1394 wrote: > > I am running ActiveMQ 5.0, using only non-durable consumers on a Topic, with > both persistent and non persistent messages. I have one high rate producer > and I have many consumers (up to 100 at this time, I have a requirement for > 200). My p