I'm using active/active exclusive consumer model to consume message from the
ActiveMQ. Since I'm writing the consumed message files and split the file
based on time(e.g. 30min). When the active consumer dies and the standby
consume become active I need to start up the timer. So is there a way to
kn
Reusing the Jms resources such as sessions, producers is a good practice but
not for consumers.
Reusing consumers can bring in message stuck problem and you can take a look at
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
You can use activemq-pool to them handily.
At 2013-04-22
Hi Christian, does it make sense the VMCursor does not respect memory usage
limit?
At 2013-04-23 07:03:12,"Christian Posta" wrote:
>What are you using for prefetch on your consumers? And how many consumers?
>The queue subscription will use a VM cursor. If your subscription gets
>dispatched a
Hello,
I have an issue. I push 100 messages to the queue with one consumer
initially. The consumer takes the message and starts working. After few
seconds, I start another consumer. The second consumer does not take any
messages from the queue eventhough there are messages pending in the queue.
Id
What are you using for prefetch on your consumers? And how many consumers?
The queue subscription will use a VM cursor. If your subscription gets
dispatched a number of messages that would put it over the memory limit,
then that is your issue. If you can put together a test case, I can take a
look
Here you go. I am only use Queues at this time.
http://www.springframework.org/schema/beans";
xmlns:amq="http://activemq.apache.org/schema/core";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframewor
post the rest of your config.
On Mon, Apr 22, 2013 at 2:05 PM, SledgeHammer wrote:
> Trying to set up my ActiveMQ to be non persistent so I can get it as fast
> as
> possible. We don't need to re-queue messages if the queue is restarted. As
> I
> have it right now, it takes 50ms for a 1MB send.
Trying to set up my ActiveMQ to be non persistent so I can get it as fast as
possible. We don't need to re-queue messages if the queue is restarted. As I
have it right now, it takes 50ms for a 1MB send. When I add
persistance="false" to the broker tag, it drops down to 15ms for a 1MB send.
Issue, o
hawt.io is pretty awesome. I was learning jquery and knocked this up as a
training exercise and thought I would share it.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Alternative-ActiveMQ-and-Camel-status-web-site-tp4666098p4666126.html
Sent from the ActiveMQ - User ma
Hi,
Thanks for your response.
However, your suggestion is not valid for me.
Thanks anyway.
Jon
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-MessageConsumed-event-tp4666115p4666120.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Why not just use SSL?
On Mon, Apr 22, 2013 at 6:39 AM, jonfrias wrote:
> Hi all,
>
> I am writing because I'm implementing my own activemq-broker which
> implements some feautures extra over the default version.
>
> I'm implementing the encryptation feature to all the messages which are
> sent
Hi all,
I am writing because I'm implementing my own activemq-broker which
implements some feautures extra over the default version.
I'm implementing the encryptation feature to all the messages which are sent
within servicemix. To do this:
1 - I have overrided the method "preProcessDispatch". I
Thanks for your answers,
I continue having the same problem. Reading the API specifications of
"close" method for MessageConsumer and MessageProducer, I noticed that it
specifies the following:
"Since a provider may allocate some resources on behalf of a MessageProducer
outside the JVM, clients s
I got the whole source of libopenwire, libactivemq, and compile main.c of
example, all seems good, but after I ran the example, it told me:
Could not connect: Cannot allocate memory (12)
the failed function is in ow.c, when ow_read_command called
ow_unmashal_object, which called ow_unmarshal_nest
14 matches
Mail list logo
