Re: Queue Recovery loads the entire data?

2007-05-21 Thread James Strachan
FWIW 4.2 does this paging to/from disk. On 5/22/07, Pandey <[EMAIL PROTECTED]> wrote: Hi, I am using JDBCPersistence (without journaling) in my product. There are times when : - my broker goes down - there are already some messages in the queue as they were not processed yet. - my broker comes

Re: How do I remove ActiveMQ.Advisory.Producer.Queue.xxxx

2007-05-21 Thread Jonas Lim
Hi, You can disable advisory support in your broker config file : > Regards, Jonas sparky2708 wrote: My ActiveMQ clients create TEMPORARY queues and I have been looking through the active queues recently and I noticed a number of advisory queues are sticking around that refer to the t

[camel] Spring's SingleConnectionFactory

2007-05-21 Thread Jeff Gunther
We did some load testing today and noticed some performance issues with the JmsComponent. Based on some research, it appears that Spring's SingleConnectionFactory might improve performance. Do you think that the SingleConnectionFactory can improve overall JMS performance? If so, how can the

Queue Recovery loads the entire data?

2007-05-21 Thread Pandey
Hi, I am using JDBCPersistence (without journaling) in my product. There are times when : - my broker goes down - there are already some messages in the queue as they were not processed yet. - my broker comes up again and restores the queue(s) On the third step, it seems to be executing a simple

Re: Creating Network of Brokers

2007-05-21 Thread Bruce Snyder
On 5/21/07, Gaurav Hariani <[EMAIL PROTECTED]> wrote: It seems you are trying to run two instances of ActiveMQ from the same installation. And they are both trying to write to the same journal ... change the configuration to use a different journal location for the second broker. Make sure your

Re: Creating Network of Brokers

2007-05-21 Thread Gaurav Hariani
It seems you are trying to run two instances of ActiveMQ from the same installation. And they are both trying to write to the same journal ... change the configuration to use a different journal location for the second broker. Vinod_mit wrote: Hi I have just installed activemq, I have to star

Re: Shared File System Master Slave with OCFS

2007-05-21 Thread James Strachan
On 5/19/07, Christopher G. Stach II <[EMAIL PROTECTED]> wrote: James Strachan wrote: > > Thanks for the heads up! :) > > I guess we could make the locking strategy pluggable & we could have > some implementation call the fcntl locking. e.g. maybe using Jtux > > http://www.basepath.com/aup/jtux/ >

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Timothy Bish
You could try pulling the latest code from trunk to see what effect the TCP_NODELAY option will have on performance on your machine. The code in trunk sets TCP_NODELAY on by default. regards Tim On Mon, 2007-05-21 at 10:52 -0700, Pravin Kundal wrote: > Hey Sir, the string you sent "WORKED"..

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Pravin Kundal
Hey Sir, the string you sent "WORKED"..thanks!! Stomp improved the results but still away from our target. posting some results. Message was string of around size 50 to 70 characters. All with Non_Persistent message relibility (i.e. atmost once) Here are our readings: A] Using Openwire,

Could not create directory on journal directory path

2007-05-21 Thread Garner, Shawn
ActiveMQ 4.1 on Windows 2003 with Java 1.5 I'm getting this in the error logs: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'org.apache.activemq.store.PersistenceAdapterFactoryBean': FactoryBean threw exception on object creation; nested exception i

Re: How to test a failover netowork broker

2007-05-21 Thread James Strachan
On 5/21/07, Vinod_mit <[EMAIL PROTECTED]> wrote: Hi friends, How i can test a activemq failover broker, i have created two brokers and i want to test with a simple program can any one help me Try looking at some tests in ActiveMQ, we do similar things. Basically just run mutliple brokers in o

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Mittler, Nathan
Sorry ... The url should be "tcp://localhost:61613?wireFormat=stomp" See http://activemq.apache.org/cms/configuring.html > -Original Message- > From: Pravin Kundal [mailto:[EMAIL PROTECTED] > Sent: Monday, May 21, 2007 12:34 PM > To: users@activemq.apache.org > Subject: RE: Implementati

Re: Transport Exceptions close the connection

2007-05-21 Thread James Strachan
On 5/21/07, Adrian Tarau <[EMAIL PROTECTED]> wrote: Hello, I have the following problem : A connection(embedded broker, vm transport) is created and then a few sessions. I poll for messages, with my own threads in order to do throttling. One thing that confuses me is : if an exception occurs so

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Pravin Kundal
I am trying to test it out using stomp. But it is giving me exceptions On Consumer Client: ActiveMQConnectionFactory - unknown Transport Factory. I tried with following brokerURI's std::string brokerURI = "stomp://localhost:61613" "?wireFormat=stomp"

Transport Exceptions close the connection

2007-05-21 Thread Adrian Tarau
Hello, I have the following problem : A connection(embedded broker, vm transport) is created and then a few sessions. I poll for messages, with my own threads in order to do throttling. One thing that confuses me is : if an exception occurs somewhere in the transport(for example an interrupt on t

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Pravin Kundal
Sorry, I missed the second line of link. I could access it. Thanks Pravin Kundal wrote: > > I couldn't access the link below. > > Is it the same example that Apache-ActiveMQ ship with the CMS library? > > Thanks a lot. > > > Mittler, Nathan wrote: >> >> >>> >>> In the case I will need t

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Pravin Kundal
I couldn't access the link below. Is it the same example that Apache-ActiveMQ ship with the CMS library? Thanks a lot. Mittler, Nathan wrote: > > >> >> In the case I will need to implement the concurrency control >> over the session, so that only one thread can use the >> session, as se

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Mittler, Nathan
> > In the case I will need to implement the concurrency control > over the session, so that only one thread can use the > session, as sessions are implemented for serial use? Rght? Yes, you should add your own concurrency control for the session. > > I tried the first case in which i imple

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Pravin Kundal
Thank you Sir for you immediate reply ! Ok now in the case where "The ActiveMQ-CPP implementation, however, will allow you to share a session across threads." In the case I will need to implement the concurrency control over the session, so that only one thread can use the session, as sessi

How to test a failover netowork broker

2007-05-21 Thread Vinod_mit
Hi friends, How i can test a activemq failover broker, i have created two brokers and i want to test with a simple program can any one help me thanks -- View this message in context: http://www.nabble.com/How-to-test-a-failover-netowork-broker-tf3790548s2354.html#a10719646 Sent from the Active

RE: Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Mittler, Nathan
The formal JMS/CMS definition of a Session implies that each thread would get its own session. The ActiveMQ-CPP implementation, however, will allow you to share a session across threads. For consumers, it should be known that each session has a single message dispatch thread, so a slow asynchro

How do I remove ActiveMQ.Advisory.Producer.Queue.xxxx

2007-05-21 Thread sparky2708
My ActiveMQ clients create TEMPORARY queues and I have been looking through the active queues recently and I noticed a number of advisory queues are sticking around that refer to the temporary queues that I created. It seems that even though the temporary queues are gone the advisory topics are st

Re: even then odd message ordering

2007-05-21 Thread James Strachan
On 5/20/07, warwick.mayson <[EMAIL PROTECTED]> wrote: Hi All I have a simple setup... one producer, one broker one consumer for a single queue. The producer sends numbered TextMessages The consumer receives all even numbered messages then recieves all odd numbered messages. Has anyone else s

Re: XML configuration: The element topic : Usage

2007-05-21 Thread James Strachan
On 5/21/07, MarkusJ <[EMAIL PROTECTED]> wrote: Hello, for the startup configuration of topics, the xml configuration file contains the element 'topic'. This element has got the element 'properties' (type: spring bean). How do I use this element? I've tried this:

Implementation of multithreading model on CMS ActiveMQ

2007-05-21 Thread Pravin Kundal
I am bit confused from the JMS specification. I want to implement mutithreaded model for producer/consumer. Now I am confused at the point where, I have only one destination object (Queue). So should I create mutiple threads, each thread having one session and one producer. OR, multiple thre

Creating Network of Brokers

2007-05-21 Thread Vinod_mit
Hi I have just installed activemq, I have to start work with failover netowrk brokers.I dont have much idea about this can any one explain me regarding this. I did like this iam not sure iam right.if wrong please help me. 1. I have created first broker like this , In the activemq.xml i put th

Re: Write to Topic when one is not created

2007-05-21 Thread James Strachan
On 5/21/07, camper <[EMAIL PROTECTED]> wrote: in activemq.xml i have usageManager set to 4096 MB, this is the output when it dies Note that setting does not affect the JVM heap size; try changing that. -- James --- http://macstrac.blogspot.com/

Re: Write to Topic when one is not created

2007-05-21 Thread camper
in activemq.xml i have usageManager set to 4096 MB, this is the output when it dies Exception in thread "ActiveMQ Transport: tcp:///192.168.2.184:52359" java.lang.OutOfMemoryError: Java heap space Exception in thread "ActiveMQ Transport: tcp:///192.168.2.182:35570" java.lang.OutOfMemoryError: Jav

Re: Write to Topic when one is not created

2007-05-21 Thread James Strachan
On 5/21/07, camper <[EMAIL PROTECTED]> wrote: You were right, when i disabled advisory support those topics stopped showing up. I am getting Out of Memory errors and I thought that that might be a problem, messages being queued but not consumed. I am using a Snapshot version of 4.2, are you aw

Re: Write to Topic when one is not created

2007-05-21 Thread camper
You were right, when i disabled advisory support those topics stopped showing up. I am getting Out of Memory errors and I thought that that might be a problem, messages being queued but not consumed. I am using a Snapshot version of 4.2, are you aware of any known issues that would cause an java

Re: How to setup a "Network of Brokers" / ActiveMQ Broker cluster with 0-M4.2 ?

2007-05-21 Thread Vinod_mit
Hi i read this article, Iam new to activemq. Iam trying to create two network brokers. I did like this but i have some doubts, let me explain my way. 1. i have created an activemq.xml with these details . and i have started my activemq it works fi

Activemq cpp for solaris compilation error

2007-05-21 Thread cppUser
Hi, I was trying to compile the cpp client in solaris and got the following compilation error. The compiler used was g++ 3.4.3 Undefined first referenced symbol in file vtable for activemq::connector::openwire::marshal::v2::ActiveMQStreamMessage