Re: Consumer queues for virtual topics do not receive messages

2013-07-24 Thread rsteppac
This is the production configuration. I have doubts that I get around creating a unit test to reproduce this any time soon. :-( http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://activemq.apache.org/schema/core http://activemq.apache.o

Re: consumer threads waiting on VMTransport locks...

2013-07-24 Thread Gary Tully
it would be useful to see a full thread dump of the vm to see the read end of that vm connection. On 24 July 2013 17:40, boday wrote: > at this point, I can't reproduce it on demand, just seeing random locking > occur after hours of uptime... > > > ceposta wrote >> Any chance you can reproduce th

Re: Reliably calculate time spent in broker

2013-07-24 Thread Dejan Bosanac
Hi Kristof, I think the approach to your problem is to develop a custom plugin that can track messages and their process times. There's some information on interceptor mechanism in ActiveMQ at these pages http://activemq.apache.org/interceptors.html http://activemq.apache.org/developing-plugins.h

Re: How to improve the performance of KahaDB

2013-07-24 Thread Gary Tully
crank up the concurrency, so use 10 threads and 10 connections. the journal will batch the writes to give better through put. same holds for jdbc. Also for JMS you can avoid a disk sync for every message send by using a transacted session. Only the commit is a synchronous blocking call. On 23 July

Re: HTTP transport

2013-07-24 Thread Dejan Bosanac
Hi, there's a difference between Camel http component and ActiveMQ http transport. Both are solid for what they've been designed to do. Regards -- Dejan Bosanac -- Red Hat, Inc. FuseSource is now part of Red Hat dbosa...@redhat.com Twitter: @dejanb Blog: http://sensatic.net Ac

Active MQ - Message Groups

2013-07-24 Thread MB
After reading ActiveMQ Message Groups feature (http://activemq.apache.org/message-groups.html), I'm a little confused about how it works in a clustered environment. The basic premise as far as I can see is that messages of a particular type (defined by the JMSXGroupID, set in a message) are all se

Re: consumer threads waiting on VMTransport locks...

2013-07-24 Thread boday
at this point, I can't reproduce it on demand, just seeing random locking occur after hours of uptime... ceposta wrote > Any chance you can reproduce this? > > > On Tue, Jul 23, 2013 at 1:03 AM, boday < > ben.oday@ > >wrote: > >> no errors in the logs, but we see message flow resume after a

cursor memory usage/limit vs memory usage/limit

2013-07-24 Thread Jake Choi
Hi, Using activemq-core-5.7.0 (embedded broker), I noticed that there is the separate memory usage/limit called "cursor memory usage/limit" which the per-destination memory limit (that I set via per-destination policy) doesn't account for, but shared between all queues. For example, from the JMX

Re: HTTP transport

2013-07-24 Thread moodboom
Jason did you arrive at a compact way to include http support? Sorry to revive this old thread, but it seems relevant to my problem. I'm new to this, using a pretty vanilla ActiveMQ config with a camel route, and getting "No component found with scheme: http4". So I'm wondering what the minima

Reliably calculate time spent in broker

2013-07-24 Thread kristof sajdak
Hi, I'm currently working on a project which uses AMQ to implement fire-and-forget scenarios. The producer sends a persistent message to the broker, a transactional consumer which is configured with maximumRedeliveries = -1 processes the message. If the listener attached to the consumer encoun

ActiveMQ CPP Issue with createCMSConnectionFactory

2013-07-24 Thread dpatel
I just upgraded from activemqcpp version 3.6 to 3.7.0. After the upgrade when I try to execute the following line in release config the dll crashes. cms::ConnectionFactory *conn_factory = cms::ConnectionFactory::createCMSConnectionFactory(conn_str); This works just fine in debug mode. Is anyone e

How to improve the performance of KahaDB

2013-07-24 Thread IT_KevinShaw
Hello, Well,now I'm testing the performance between KahaDB and MySQL. In the past,I used job to synchronize data from one MySQL table to another,a job had 10 threads and 1000 more of MySQL messages could be synchronized per second. Now I use ActiveMQ,KahaDB or MySQL for persistence.Things do not

Re: Variable volume of messages across consumers

2013-07-24 Thread Praveen Bysani
I did take a look at the activemq logs on both the brokers, i only have information such as below in the primary broker. There is not much i can infer from this. 2013-07-24 15:06:21,916 | DEBUG | bridging (localhost -> localhost) 5a2c1e2a-9df2-45a8-aebc-861c3ab271e0:1:1:161, consumer: ID:global-de