Re: how to get topicName from within onMessage()

On Thu, 2010-01-14 at 16:43 -0800, ironrooster wrote: > Hi all, > I am an ActiveMQ newbie who has managed to get a consumer/producer > system working using topics. I would like to know which topic has sent a > particular message, but I can't figure out how to do it. Perhaps someone > will hav

how to get topicName from within onMessage()

Hi all, I am an ActiveMQ newbie who has managed to get a consumer/producer system working using topics. I would like to know which topic has sent a particular message, but I can't figure out how to do it. Perhaps someone will have mercy on this problem and shoot it, like an injured horse. T

Poor design, poor performance. Better design, better performance?

In an effort to keep all of the configuration within the code, my design for implementing asynchronous messaging failed our load tests. Our application was able to withstand 1400 hits per second before implementing ActiveMQ with the following model: * embedded JVM broker * non-persistent messagin

Stomp C Client (Usage Manager Memory LImit reached)

I have a stomp client that is writing persistent messages (message size varies from 300 bytes to 2000 bytes) to AMQ. After around 40-45K messages on the AMQ and no consumers, AMQ gives the following warning message: Usage Manager memory limit reached on queue://foo.bar. Producers will be throt

Re: Problems with prefetch and TemporaryQueues

on second thoughts, the network of brokers support, which bridges temp destinations by default, that needs (or builds on) auto create of temp destinations. So the option to turn off auto creation for temp destinations could be exposed as a configuration option on the broker but it can't be the defa

Re: Problems with prefetch and TemporaryQueues

Great that you have a solution that works. I think you have a good point here. I cannot think of a reason to have auto create for temp queues save that it negates the need to call session.createTempX which is not well behaved w.r.t JMS semantics. Can you open a jira issue to track this? As to the

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

Hi Fred, thanks for raising the issue - the book is nearly complete - but will see if we can fit it in thanks, Rob On 14 Jan 2010, at 15:45, Fred Moore wrote: Hi Rob, thanks for your help so far, I created http://issues.apache.org/activemq/browse/AMQ-2568 "Embedded broker not shutting dow

Re: Visibility timeout feature

Hi Yair, We don't currently support the timeout feature - but if you could add an enhancement request - we'll try fit in 5.4 thanks, Rob On 14 Jan 2010, at 16:02, yair wrote: hi all I m currently using amazon's SQS as a queue for jobs running in my systems. When a "worker" machine takes

Visibility timeout feature

hi all I m currently using amazon's SQS as a queue for jobs running in my systems. When a "worker" machine takes a job from the queue, it becomes invisible to other workers. The queue has a configurable timeout, so that if in X seconds the worker didn't deleted the message completely from the queu

Re: BadImageFormatException with Apache.NMS.ActiveMQ‏

Timothy Bish wrote: > > On Thu, 2010-01-14 at 04:28 -0800, oskareto wrote: >> Hello! First, sorry for my English. >> >> I'm deploying this example application >> http://remark.wordpress.com/articles/publish-subscribe-with-activemq-and-nms/ >> . When I've created all the project and i've downl

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

Hi Rob, thanks for your help so far, I created http://issues.apache.org/activemq/browse/AMQ-2568 "Embedded broker not shutting down cleanly because of lingering threads" for future reference. Also, please make sure that any relevant considerations stemming from this thread will be captured in Cha

Re: Request-response without clock sync

Hello and thanks. TimeStampPlugin seems to be exactly what I'm looking for. Unfortunately it doesn't work. I still get messages only when time is synced. I added the timeStampingBrokerPlugin directive in activemq.xml under .. Do I have to do anything else but that? How can I track that down

Re: 50k + messages stuck in queue with all consumers blocking on receive

Things just got even stranger. If I stop the client, restart the broker, and then start the client again, no messages are eaten from the queue. -- View this message in context: http://old.nabble.com/50k-%2B-messages-stuck-in-queue-with-all-consumers-blocking-on-receive-tp27162095p27162953.html S

Re: Zero Prefetch Not Working in 5.3.0

Issue opened AMQ-2567. It is non deterministic. The problem disappears sometimes during debugging. Thanks for the pointers I will do some more debugging. Rudolf Am 14.01.2010 um 15:14 schrieb Gary Tully : can you open an issue for this, I just gave it a whirl (on trunk) and get similar

Re: Problems with prefetch and TemporaryQueues

Thanks for the answer, Gary. I rebuilt ActiveMQ with setAutoCreateDestinations(false); in the constructor of TempQueueRegion. It seems to solve the problem. I put some logging into AbstractRegion.lookup to verify this. Is there any reason to have autocreating enabled by default for TempQueues? S

50k + messages stuck in queue with all consumers blocking on receive

Hi, I've somehow gotten myself into the situation where I've got 50,000+ messages stuck in a queue for no apparent reason. Allow me to explain: I've got a system where a component rapidly produces messages that are put on topic (around 400 per second). A second component listens to the topic, tak

Re: Zero Prefetch Not Working in 5.3.0

can you open an issue for this, I just gave it a whirl (on trunk) and get similar but non deterministic results. The second consumer got 6 and 7 on two runs. PrefetchSubscription and prefetchExtension on a deliveryAck in a transaction are areas that you need to look into to resolve this. Great that

Re: BadImageFormatException with Apache.NMS.ActiveMQ‏

On Thu, 2010-01-14 at 04:28 -0800, oskareto wrote: > Hello! First, sorry for my English. > > I'm deploying this example application > http://remark.wordpress.com/articles/publish-subscribe-with-activemq-and-nms/ > . When I've created all the project and i've downloaded the requiered dll's > (Apac

Zero Prefetch Not Working in 5.3.0

Hello, I have problems using a prefetch of Zero. The consumer starts prefetching messages after some receives. Our use case is, that we have a large computation which is split into smaller sub jobs. These jobs are sent via ActiveMQ to some processing nodes on different machines. The duration of job

Re: Per queue limits on durable messages

Not at the moment out of the box. The Store Usage limits are broker wide so there is no way to limit the disk usage of a single destination. One thought would be to use non persistent messages for non important data. An alternative avenue (which would require a bit of a code deep dive) would be to

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

Hi Fred, I can confirm most of what you are seeing - will look at the best way to handle the scheduler case - might make more sense for it not to be static. The [Timer-0] thread - I'm not seeing that - though I'm working from trunk cheers, Rob On 14 Jan 2010, at 11:51, Fred Moore wrote:

BadImageFormatException with Apache.NMS.ActiveMQ‏

Hello! First, sorry for my English. I'm deploying this example application http://remark.wordpress.com/articles/publish-subscribe-with-activemq-and-nms/ . When I've created all the project and i've downloaded the requiered dll's (Apache.NMS 1.2.0 and Apache.NMS.ActiveMQ), and I execute the appli

Re: Trivial embedded broker not shutting down cleanly because of lingering threads

Hi Rob, FWIW here is the ThreadExplorer class: http://pastebin.com/f1aa2a099 > Do you actually call stop() on the broker ? Yes. > Have you disabled the shutdownHook from the broker ? No, we just did it but nothing has changed. In the meantime we experimented further and we were able to shutdown

Re: ActiveMQ FuseSource Stomp large payloads problem

Will post an issue. I'll see if I can submit a patch as well cheers, j. ps: I've cross posted to stackoverflow to see if the php geniuses over there have some ideas. On Thu, Jan 14, 2010 at 11:26 AM, Dejan Bosanac wrote: > Hi Jamie, > > thanks for pointing to this issue. The best approach is to

Re: ActiveMQ FuseSource Stomp large payloads problem

Hi Jamie, thanks for pointing to this issue. The best approach is to file a bug in project's Jira (http://fusesource.com/issues/browse/STOMP) and we'll take it from there (a patch that solves it would be even better). Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration -

ActiveMQ FuseSource Stomp large payloads problem

Hi All, It appears that the ActiveMQ FuseSource Stomp PHP client can't handle messages larger than 1024 bytes. The code is as follows in Stomp.php: $rb = 1024; $data = ''; $end = false; do { $read = fread($this->_socket, $rb); if ($read ===

Bridge between ActiveMQ and WebLogic 9.2

Hi, I have followed the tutorial http://activemq.apache.org/how-to-deploy-activemq-ra-versionrar-to-weblogic.html to deploy the ActiveMQ adapter in WebLogic. The adapter seems to work and is available as a "Resource Adapter" application. But at this point, I really don't know what to do with it.

Re: How to avoid "Slow KahaDB access: cleanup took 545" error msg?

Dear Ben, There has already been a discussion similar to yours: http://old.nabble.com/Slow-KahaDB-access-td26594249.html#a26594249 You can have a look at the page dedicated to the KahaDb: http://cwiki.apache.org/confluence/display

How to avoid "Slow KahaDB access: cleanup took 545" error msg?

When running the current ActiveMQ MessageBroker (under WinXP) the console shows dozends of notifications like "Slow KahaDB access: cleanup took 545" Whats wrong? How can I avoind these msgs? Ben -- View this message in context: http://old.nabble.com/How-to-avoid-%22Slow-KahaDB-access%3A-clea