messages distribution problem

2008-03-31 Thread itayke
Hello. I have a Q with several consumers (C++ consumers).Some of the consumers are slow, so I like that messages will be consumed from the Q by consumers that are available and not busy. The Q is handling a small number of messages and they don't need to be persistance. Although I have set the p

Startup scripts not working on Mac

2008-03-31 Thread krishna
Hi there, I've just started using ActiveMQ, and I am having trouble running it as a daemon. I am able to launch it just fine with 'bin/activemq', but when I run 'bin/macosx/activemq start', it appears to be starting, but does not. I'm running Mac OS 10.4.11. More details: typing 'bin/macosx/act

Re: Simple Authentication Plugin

2008-03-31 Thread sk123
Thanks Rob!! Moving addConnector() to the last work. rajdavies wrote: > > > On 27 Mar 2008, at 22:49, sk123 wrote: > >> >> Hi, >> >> I am trying to understand ActiveMQ's security feature. >> >> I started with simple authentication but seem to be missing >> something. I >> have search the

Re: Network of brokers - already connected

2008-03-31 Thread toff
Hi Joe, thank you for your reply. I saw the error message, what I cannot figure out is why it prints it: - is it trying to reconnect after being disconnected and failing? - is it connecting more than once because of wrong configuration? - how does it decide which client id to use, why? What I am

Re: Network of brokers - already connected

2008-03-31 Thread ttmdev
The following statement, taken from your standard error output, tells me that the broker w/the name "ds-pl3.technion.ac.il" is rejecting a connection request from a client because the client is trying to use a client id (NC_planetlab1.tmit.bme.hu_inboundds-pl3.technion.ac.il) that is already in us

Network of brokers - already connected

2008-03-31 Thread toff
Hi, I tried searching the mailing list archive for an answer but to no avail. So here's yet another question on networks of brokers. I am using activemq 5.0, I want to configure a network of brokers with a given topology, that is deciding which broker is to be connected to which (using multiple n

Re: Memory Leak

2008-03-31 Thread ttmdev
I noted the leak when running a 5.1 SNAPSHOT against JDK 1.5.0_06-b05 for Windows XP Pro SP2. Joe rajdavies wrote: > > > On 27 Mar 2008, at 04:18, Sachindra Nath wrote: > >> This bug is supposed to have been fixed in SUN VM 1.5.0_12. >> http://bugs.sun.com/bugdatabase/view_bug.do;jsessionid

RE: Retroactive consumers loose msgs...

2008-03-31 Thread Andrew M
In the code below I'm sending 5000 of these: static final String MSG = "1"; // 1 character msg so it shouldn't be a memory issue. The java file of the code below is here: http://66.17.204.68:8765/~andrew/CommandLinePublisher.java Thanks, Andrew -Original Message- From

Re: Message enter ActiveMQ.DLQ after consumer reconnect

2008-03-31 Thread thiamteck
Hi rajdavies, Thanks for your reply. And I have one more question, is there any way for queue consumer to ensure message never enter into DLQ regardless what was set at producer? (or in another word, a "durable" queue consumer) Thank you. rajdavies wrote: > > > On 28 Mar 2008, at 06:41, thia

Re: Pushing messages from Adempiere to ActiveMQ

2008-03-31 Thread chif
Actually i had set the frequency in import processor of one of this broker giving that error message to 5mins but when i removed that the error is no more errors. When i save my record and by way of debugging the send message method in TopicExport Processor class is able to send with the generated

Re: ActiveMQ 5.0.0 OutOfMemory

2008-03-31 Thread Hatta
Hatta wrote: > > > Hi QWERTY > > > Hi again guys! > > Just to let you know - the problem regarding the 36 process are now > resolved. > > My sys admin upgraded the kernel version from 2.4 to 2.6 > > After doing that, the process are gone and active mq 5.0.0 is stable. > > Thanks for all

Re: AMQMessageStore getting stuck

2008-03-31 Thread Rob Davies
On 26 Mar 2008, at 21:57, mccraig_ wrote: i'm getting exceptions from AMQMessageStore, and one of my queues is stuck i put 200,000 messages on a queue, and after a couple of hours and 50,000 consumed messages consumers stopped getting any more messages. restarting the broker gave me ex

Re: Memory Leak

2008-03-31 Thread Rob Davies
On 27 Mar 2008, at 04:18, Sachindra Nath wrote: This bug is supposed to have been fixed in SUN VM 1.5.0_12. http://bugs.sun.com/bugdatabase/view_bug.do;jsessionid=ee6ec97669ab91923bde6c d8c041?bug_id=6460501 Would we still expect the ActiveMQ5.0 + Sun JDK 1.5.0_12 memory leak? Possibly - cou

Re: Strange StreamMessage problem

2008-03-31 Thread Rob Davies
Great! thanks for explaining this to everyone John cheers, Rob On 27 Mar 2008, at 20:42, John F. Lentz wrote: After looking at the documentation more closely I think I've answered my own question, and that this behavior is by design. "To read the field value, readBytes should be successiv

Re: Simple Authentication Plugin

2008-03-31 Thread Rob Davies
On 27 Mar 2008, at 22:49, sk123 wrote: Hi, I am trying to understand ActiveMQ's security feature. I started with simple authentication but seem to be missing something. I have search the forum as well as Google but no luck. My test starts the embedded broker and makes a connection. Based

Re: choosing the right value for networkTTL

2008-03-31 Thread Rob Davies
On 28 Mar 2008, at 00:36, mgorkani wrote: In my test setup i have 3 servers which are using multicast discovery to find connections for a network of brokers. Each broker has client listener for topic A. If one of the brokers publishes to the topic, all of them should get it. Would that b

Re: Message enter ActiveMQ.DLQ after consumer reconnect

2008-03-31 Thread Rob Davies
On 28 Mar 2008, at 06:41, thiamteck wrote: My college just told me that the message only enter DLQ after consumer reconnect, if the consumer is same server as the ActiveMQ. Anyway, I not yet test it out myself. This is something we need to add - to actively timeout messages - currently

Re: Synchronous publishing with ActiveMQ

2008-03-31 Thread Rob Davies
On 28 Mar 2008, at 09:26, makr wrote: As I understand such "synchronous publish" is not available in current ActiveMQ release but this is a desirable feature? Does this statement apply to both communication models? publish- subscribe (topic) and send-receive (queue)? Is such feature includ

Re: Consuming persistent messages from a non-durable subscriber

2008-03-31 Thread Rob Davies
On 28 Mar 2008, at 09:42, Ramit Arora wrote: Hi All, I have a situation where I have to consume persisent messages from many non-durable subscribers. My publishers push persistent messages to a topic, which are consumed asynchronously by non-durable subscribers. I am using the AMQ Persi

Re: How the TCP traffic works

2008-03-31 Thread Rob Davies
On 28 Mar 2008, at 12:45, Garfield071 wrote: I am brand new on ActvieMQ. I am wondering how the resolution of the clients IP adress is done by the broker. Do I have to assign a URL to each client and define it in a DNS ? How the client is wake up when a new message. I know that the clie

Re: JMS Chat Application

2008-03-31 Thread Rob Davies
inlined: On 29 Mar 2008, at 00:50, francois1 wrote: Hi, My chat application needs to multicast messages to the proper chat rooms. An important requirement is that clients must be able to subscribe and unsubscribe to/from chat rooms. It looks like that it could be done with message select

Re: when will activemq 5.0.1 come out? how will testing improve in future releases?

2008-03-31 Thread Rob Davies
On 29 Mar 2008, at 04:42, sparky2708 wrote: Since 5.0.0 is basically unusable with all the InactivityMonitor and EOFExceptions when will a 5.0.x version become available that we can use? 5.1 Snapshot seems not much better. Just out of curiosity, how did 5.0.0 come out with so many bugs in

Re: Retroactive consumers loose msgs...

2008-03-31 Thread Rob Davies
How big are your messages ? - they might be reclaimed if you hit a memory limit in the broker On 29 Mar 2008, at 07:22, Andrew M wrote: My Retroactive Consumer is only receiving the last 789 out of 5000 msgs sent. Any suggestions? Thanks. import javax.jms.Connection; import javax.jms

Re: Java to .NET using NMS

2008-03-31 Thread Rob Davies
On 31 Mar 2008, at 02:01, Oleg Deribas wrote: Andrew M wrote: It looks from this page: http://activemq.apache.org/nms.html like NMS allows openwire to talk to .NET languages. Are there any examples of that? Here is example: http://activemq.apache.org/nms/nms.html But it looks like this