Re: Messages Stuck in the queue(with the broker)

We experience this problem as well. It's a very serious issue, and I hope it gets some attention. We don't have test code that can reproduce it, as it seems intermittent. We can reproduce it when we get lucky by jamming a lot of messages into queues with slow consumers. We've seen it with single o

Re: Load balancing using Queues

I'll let others say how it picks which among available competing consumers gets the next message, but there are two customizations that I'm aware of: the exclusive consumer flag (changing load balancing to failover, effectively) and message groups, which provide a form of consumer affinity, so tha

Re: Load Balancing in ActiveMQ

A queue with multiple competing consumers IS a form of load balancing, so the answer to what you are trying to do is probably simpler than you expect. Refer to the http://activemq.apache.org/clustering.html clustering page. Competing consumers on a queue will vie for messages, each taking up to

Re: activeMQ on oracle AQ

AQ is more like an alternative messaging mechanism that supports basic JMS than it is a persistence mechanism for activemq. The article you gave allows bridging to it. Activemq can use oracle as its persistence store, but it does this using its own tables that it creates. The error you are gettin

Re: Getting count of messages in a queue (ActiveMQ 5.2.0)

You can do it via JMX. You can use an XPATH expression against http://broker:8161/admin/xml/queues.jsp if you have the admin console installed. If you have access to the Broker object you can call broker.getDestinations(activeMQdestination) which is a set of Destination objects you can call getDes

Re: too many open files

We have a similar problem. I'm skeptical that simply raising the ulimit is the right solution. What I've seen is a file descriptor leak where STOMP connections leak when closed by an intermediate firewall. The producer's packets will be dropped and it will close its connection, but activemq just k

Re: actual status of activeMQ and AMQP

I'd love to read more about the plans for ActiveMQ 6. The http://activemq.apache.org/new-features-in-60.html page is kind of sparse. bwtaylor wrote: > > Awesome! You guys are the bomb. > > I think all three of those (OSGI, AMQP, and true REST) will be very well > receive

Re: actual status of activeMQ and AMQP

.org/SMX4KNL/index.html > . > With the input of SonicMQ architects - we are building out the > enterprise class features of ActiveMQ, but we will be accommodating > more wire formats - including AMQP -as well as true restful API. > > > On 8 Mar 2009, at 04:59, bwtaylor wr

Re: actual status of activeMQ and AMQP

> currently for enterprises. Ironic - when the whole point of AMQP was > to try break vendor lock-in! > > cheers, > > Rob > > Rob Davies > http://fusesource.com > http://rajdavies.blogspot.com/ > > > > On 26 Jan 2009, at 18:49, bwtaylor wrote: > >> >&g

Re: actual status of activeMQ and AMQP

I'll also express strong interest in AMQP and I'll take the liberty of saying that most people using stomp for cross platform integration with ActiveMQ should be expressing interest. With the influx of enterprise apps being written in dynamic languages, AMQP offers high end messaging features in a

Re: Only memory transaction store with JDBC persistence adapter??

I'm kind of baffled by this, as I thought you had to flush the prepare out to a durable media, too. This is in fact, what http://activemq.apache.org/how-do-transactions-work.html claims happens. I don't see how XA transactions with the JDBCMessageStore is achieving the proper level of durability d

Re: Setting stomp wire format parameters

I think this may be related to these bugs: https://issues.apache.org/activemq/browse/AMQ-1203 and https://issues.apache.org/activemq/browse/AMQ-1192 . What Hiram Chirino describes is a dead ringer for my situation... -- copy of Hiram's comments from AMQ-1192 I think this is due

Re: Setting stomp wire format parameters

I checked out AMQ-1739. I think my situation is different. My stomp sockets all show as ESTABLISHED, not CLOSE_WAIT. The interesting thing is that the message producer clients don't show the sockets as existing anymore. I think what may be happening is that an intermediary firewall drops the conne

Re: Setting stomp wire format parameters

Ping. Anybody? This is hanging my server as I leak about 25 sockets a day until I hit the OS limit. bwtaylor wrote: > > The configuring-wire-formats page, > http://activemq.apache.org/configuring-wire-formats.html , implies that > the options shown apply only to the openwire wire

Re: How can I check the memory usage of activemq broker without jconsole?

Are you saying you need to get the memory usage inside your code? If not, jstat is pretty useful for this. It's the java equivalent of vmstat. It's in the JDK bin directory. http://java.sun.com/j2se/1.5.0/docs/tooldocs/share/jstat.html -- View this message in context: http://www.nabble.com/How

Re: VM transport not using pass-by-reference

I traced through some code. It looks like ActiveMQSession.send() does honor copyMessageOnSend as noted. But this only explains why you see 2001, not 2002 messages. Message consumption on a topic happens in a two step process: 1) During dispatch, a MessageDispatch object is enqueued to consumer's

Setting stomp wire format parameters

The configuring-wire-formats page, http://activemq.apache.org/configuring-wire-formats.html , implies that the options shown apply only to the openwire wire format. I am having an issue with stomp sockets not getting closed (which pile up until the OS limit is hit and then the broker is unreachabl