Re: Prefetch Limit of 1000 .... without acknowledges

2008-01-30 Thread james . strachan
which version of ActiveMQ? On 30/01/2008, Eric-AWL <[EMAIL PROTECTED]> wrote: > > Hi > > Context > > A "client" process is on "ytsvmx01s" server, Server process is on > "ytsvmx02s" server (an other server). A duplex network of brokers is made by > the client configuration. > >

Re: Data logging with AMQ message store?

2008-01-30 Thread james . strachan
I guess you could walk through the active & archive journal files to analyse message flows. Though this will include all messages on all destinations so Rob's idea might be easier to do. On 31/01/2008, Rob Davies <[EMAIL PROTECTED]> wrote: > > On Jan 30, 2008, at 12:56 PM, brian12 wrote: > > > >

Re: lots of new exceptions in activemq 5.0.0

2008-01-30 Thread Rob Davies
That problem has been fixed - take the latest snapshot release On Jan 30, 2008, at 3:18 PM, marcus olsson wrote: I also did that on the ActiveMQ server-side, but this resulted in "too many files" problem, since ActiveMQ never closed down any connections. ttmdev wrote: I started getting

Re: Data logging with AMQ message store?

2008-01-30 Thread Rob Davies
On Jan 30, 2008, at 12:56 PM, brian12 wrote: I have a need to log all messages to all topics that pass through a particular broker for offline analysis. I can write a client that subscribes to all the topics, and dumps the data to disk. However, I'd rather use something that's built-in to

Re: Prefetch Limit of 1000 .... without acknowledges

2008-01-30 Thread Rob Davies
On Jan 30, 2008, at 11:20 AM, Eric-AWL wrote: Hi Context A "client" process is on "ytsvmx01s" server, Server process is on "ytsvmx02s" server (an other server). A duplex network of brokers is made by the client configuration. An embedded VM client process, with 100 threads. - each

Re: Suppress ActiveMQ log4j messages on client

2008-01-30 Thread Paul Smith
On 31/01/2008, at 3:54 PM, David Lloyd wrote: Paul, Paul Smith wrote: On 31/01/2008, at 2:37 PM, QWERTY? wrote: Hi, We're currently using Hibernate and ActiveMQ, but i want to suppress all the activeMQ messages comming through log4j is there an easy way to do this? I can only get it d

Re: Suppress ActiveMQ log4j messages on client

2008-01-30 Thread David Lloyd
Paul, Paul Smith wrote: On 31/01/2008, at 2:37 PM, QWERTY? wrote: Hi, We're currently using Hibernate and ActiveMQ, but i want to suppress all the activeMQ messages comming through log4j is there an easy way to do this? I can only get it down to debug messages so far using log4j.logg

Re: Suppress ActiveMQ log4j messages on client

2008-01-30 Thread Paul Smith
On 31/01/2008, at 2:37 PM, QWERTY? wrote: Hi, We're currently using Hibernate and ActiveMQ, but i want to suppress all the activeMQ messages comming through log4j is there an easy way to do this? I can only get it down to debug messages so far using log4j.logger.org.apache.activemq=de

Suppress ActiveMQ log4j messages on client

2008-01-30 Thread QWERTY?
Hi, We're currently using Hibernate and ActiveMQ, but i want to suppress all the activeMQ messages comming through log4j is there an easy way to do this? I can only get it down to debug messages so far using log4j.logger.org.apache.activemq=debug Cheers, -- View this message in context: htt

Stomp Client

2008-01-30 Thread cmagoyrk
I am using ActiveMQ version 5.0.0 . I create a stomp producer and add messages to a queue (does not matter if the messages are added as persistent or not, same behavior). I create a consumer to read from that queue. Once the consumer begins to read, the producer is slowed down drastically ( from

Re: Activemq integration

2008-01-30 Thread Marco Buss
activebud schrieb: Hi All, I am using activemq 5 , mysql 5.0.37 and mysql-connector-java-3.1.12-bin.jar my activemq.xml as follows http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.org/config/1.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schem

Re: Stomp protocol problems

2008-01-30 Thread Sebastjan Trepca
On 1/30/08, gustav.mauer <[EMAIL PROTECTED]> wrote: > > I assume you only want to ACK a message once the consumer/worker thread has > processed it? I have also been wondering what the best pattern is for that. > I was also wondering if the correct way to proceed is to create a listener > for each w

Re: lots of new exceptions in activemq 5.0.0

2008-01-30 Thread marcus olsson
I also did that on the ActiveMQ server-side, but this resulted in "too many files" problem, since ActiveMQ never closed down any connections. ttmdev wrote: > > I started getting the inactivity exceptions when I switched to the latest > 5.0 and addressed them by setting wireFormat.maxInactivity

Re: ActiveMQ topology question (Store and Forward)

2008-01-30 Thread ttmdev
With a forwarding bridge in-place between a remote collector and the central server, a queue that is created on the collector will not automatically be reflected/created on the server. You either have to define a queue in the server broker's cfg file or have clients, which are connected to the se

Re: Stomp protocol problems

2008-01-30 Thread gustav.mauer
I assume you only want to ACK a message once the consumer/worker thread has processed it? I have also been wondering what the best pattern is for that. I was also wondering if the correct way to proceed is to create a listener for each worker thread? And if a listener thread is busy, with the requ

Data logging with AMQ message store?

2008-01-30 Thread brian12
I have a need to log all messages to all topics that pass through a particular broker for offline analysis. I can write a client that subscribes to all the topics, and dumps the data to disk. However, I'd rather use something that's built-in to ActiveMQ if it's available. I was looking at the A

Re: Stomp protocol problems

2008-01-30 Thread Dejan Bosanac
I'm not sure what are you trying to achieve, but if you need to group messages in one queue, you can use selectors (http://activemq.apache.org/selectors.html). You have an example of how to use them in test cases. Another option would be to send messages to different queues. On Jan 30, 2008 1:19 P

Activemq integration

2008-01-30 Thread activebud
Hi All, I am using activemq 5 , mysql 5.0.37 and mysql-connector-java-3.1.12-bin.jar my activemq.xml as follows http://www.springframework.org/schema/beans"; xmlns:amq="http://activemq.org/config/1.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www

Re: Stomp protocol problems

2008-01-30 Thread Sebastjan Trepca
Yes, sorry for not RTFM, it's not very logical though, to ACK all messages when you ack one. So what are my options then? Stomp protocol doesn't seem to support sessions: "The session-id header is a unique identifier for this session (though it isn't actually used yet). " Should I create separate

Re: Stomp protocol problems

2008-01-30 Thread Dejan Bosanac
I guess I responded instinctively without thinking it through. This is definitely a correct behavior. Cheers On Jan 30, 2008 9:39 AM, gustav.mauer <[EMAIL PROTECTED]> wrote: > > I am under the impression this is correct behaviour. See for example: > http://java.sun.com/products/jms/tutorial/ pag

Prefetch Limit of 1000 .... without acknowledges

2008-01-30 Thread Eric-AWL
Hi Context A "client" process is on "ytsvmx01s" server, Server process is on "ytsvmx02s" server (an other server). A duplex network of brokers is made by the client configuration. An embedded VM client process, with 100 threads. - each thread create a temporary queue - each thread send

ActiveMQ topology question (Store and Forward)

2008-01-30 Thread Tamir
I'm new to ActiveMQ, so bear with me ... I want to use ActiveMQ in the following scenario, and haven't find a way to configure it the way I want it. I have a lot of remove JVM (let's call them collectors) that send data to one central JVM (server). For scalability and availability reasons, I wan

Re: Stomp protocol problems

2008-01-30 Thread gustav.mauer
I am under the impression this is correct behaviour. See for example: http://java.sun.com/products/jms/tutorial/ page 63 Sebastjan Trepca wrote: > > Hi, > > I'm using ActiveMQ(both versions are affected) with STOMP protocol and > noticed a problem with it. At least I hope it's a problem. > >