advisoryForConsumed and orignalMessageId == null?

2009-02-05 Thread Bjørn T Johansen
I am trying out the advisoryForConsumed advisory but the originalMessageId == null.. Is this not the way to get the original message id: message.getStringProperty("orignalMessageId"); Is there some other way that should be used instead? Regards, BTJ -- --

ConcurrentModificationException while closing consumer

2009-02-05 Thread bonnyr
AMQ 5.1 (but problem exists in the sources of AMQ-5.2 as of today) My setup: * Broker is configured with a single queue, full with messages, on a host accessible via the network. * Application configured with a single consumer, connected to a single sesssion, running in its own thread. * ActiveMQ

ConcurrentModificationException while closing consumer

2009-02-05 Thread bonnyr
AMQ 5.1 (but problem exists in the sources of AMQ-5.2 as of today) My setup: * Broker is configured with a single queue, full with messages, on a host accessible via the network. * Application configured with a single consumer, connected to a single sesssion, running in its own thread. * ActiveMQ

Re: Messages being consumed but not delivered to the application

2009-02-05 Thread mcarter
That would certainly produce the described behaviour. I've checked very carefully though and I'm 100% certain that I don't have another consumer. I've discovered a few more things though. I only have two machines involved in this transaction but it seems to only be triggered when I"m using a part

ActiveMQ and JNDI provider

2009-02-05 Thread Gregory Guibert
Hello everybody, As documented on the website, the JNDI implementation provided by ActiveMQ is in a read-only mode, and the only kind of objects stored in this JNDI are the administered objects concerning JMS. (Topic, Queues, TopicConnectionFactories, ...) In addition to the JMS-related objects, I

Re: Q Consumers stop receiving messages

2009-02-05 Thread Jim Gomes
Hi Bill, Thanks for the tips and suggestions. I'll take a look at giving them a try. Right now our data store is the default Kaha data store. I had wondered if switching to some other data store might improve things. - Jim On Thu, Feb 5, 2009 at 4:41 AM, Bill Schuller wrote: > We ran into a

Has anyone configured Oracle's BPEL to receive ActiveMQ messages?

2009-02-05 Thread budcurtis
I need to set up Oracle's BPEL 10.1.3 server to receive messages from an existing ActiveMQ server. I haven't found any description on how to set up the connection factory settings in the oc4j-ra.xml: or any other required conf

Re: Are there any Management solutions for AMQ.

2009-02-05 Thread Joe Fernandez
The existing MBeans may address some of your requirements; however, you'd be working with the JMX and not JMS. You can also develop your own custom broker plugin and register it with the MBean server to address functionality not covered by the existing MBeans. Check out the 1.6 JConsole it has a m

Re: sending messages to a topic that program is listening to

2009-02-05 Thread Bill Schuller
Here is some more detailed information on message properties and selectors. The ActiveMQ documentation is a little sparse. Selectors are part of the JMS API, so they behave the same across broker implementations. http://www.informit.com/articles/article.aspx?p=170722&seqNum=2 On 2/5/09 9:48 AM,

Re: sending messages to a topic that program is listening to

2009-02-05 Thread Bill Schuller
Implement a header property identifying the source of the message ( ŒsetStringProperty(source, ³me²)¹. In your topic subscription, use a selector like Œsource not me¹ in each of your apps... On 2/5/09 9:38 AM, "Mark Webb" wrote: > I have a group of applications that use JMS to communicate. I w

sending messages to a topic that program is listening to

2009-02-05 Thread Mark Webb
I have a group of applications that use JMS to communicate. I would like to set up a topic for internal control messages (status, heartbeat..etc). Each of these processes will subscribe to the topic and send messages to each other periodically. The problem I have is that if application A sends a

ActiveMQ in Action - new chapters available online

2009-02-05 Thread Dejan Bosanac
Hi all, just to announce that new chapters are available online through Manning Early Access Program (MEAP) - http://www.manning.com/snyder/ Chapter 2 provides a detailed overview of ActiceMQ Chapter 4 explains ActiveMQs message persistence options Chapter 7 addresses the aspects related to provi

Are there any Management solutions for AMQ.

2009-02-05 Thread uprooter
Generally speaking: I want to control a bunch of brokers from a central broker using JMS. When I say control I mean things like allow/disallow new sessions. dropping existing sessions. shutting down the broker remotely. and query the broker for it's status. I My very simple approach is to write an

Re: Q Consumers stop receiving messages

2009-02-05 Thread Bill Schuller
We ran into a similar problem with one of our ActiveMQ implementations. My theory was that messages were being paged out of memory and the consumers were consuming faster than the dispatch queue could be re-filled. We made a plethora of changes all at once, but here was the tact I took: 1. Faster

Re: Problem with topic...

2009-02-05 Thread Bjørn T Johansen
Btw, is there a solution for this without using durable topics? I.e. like having the listener not connect and disconnect all the time? BTJ On Thu, 5 Feb 2009 12:40:19 +0100 Bjørn T Johansen wrote: > Think I found the problem... Seems like there is a timing issue with the > Spring listener (no

Re: Problem with topic...

2009-02-05 Thread Bjørn T Johansen
Think I found the problem... Seems like there is a timing issue with the Spring listener (not sure if it's just Spring or the way JMS works). I thought when listening, I would receive all activity but the listener seem to be connecting and disconnecting all the time, which makes it "loose" some p

Problem with topic...

2009-02-05 Thread Bjørn T Johansen
I have a problem when using topic... I have two listener that listen on the same topic.. But when I post a topic, sometimes both listeners read the topic and sometime only one reads the topic.. This is the configuration of the topic..: and this is the listeners:

Re: Problem configuring a "network of brokers"?

2009-02-05 Thread Bjørn T Johansen
I had a problem with the destiantion-type (was not set) in my spring listener configuration, it's working now... (after setting dest.type = topic) BTJ On Thu, 5 Feb 2009 10:27:32 +0100 Dejan Bosanac wrote: > Hi, it should work for topics, the same as for queues. The only problem I > can antici

Re: memoryUsage vs Heap

2009-02-05 Thread Dejan Bosanac
Hi Adam, can you post a configuration you were trying (with memoryUsage) and a client that can reproduce the problem. I saw your earlier post that you're using 5.1.0, did you try it with 5.2.0? Regards -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://

Re: Messages being consumed but not delivered to the application

2009-02-05 Thread Dejan Bosanac
Maybe you have another consumer that consumes that message? Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Thu, Feb 5, 2009 at 7:28 AM, mcarter wrote: > > Hi all, > I have a strang

Re: Problem configuring a "network of brokers"?

2009-02-05 Thread Dejan Bosanac
Hi, it should work for topics, the same as for queues. The only problem I can anticipate is that you may use non-durable topic subscribers. Check out these articles http://activemq.apache.org/how-do-durable-queues-and-topics-work.html http://activemq.apache.org/why-do-i-not-receive-messages-on-my-