Seems PFC can work in your case.
Enabling PFC in your specific queue can prevent producers from pushing more
messages than the memory limit.
When consumers take messages from the queue, the memory usage decreases to be
smaller than the limit,
producers can resume pushing messages.
At 2013-02-27
Thanks for the config. I'll take that and set it to my environment. Would
you mind sharing your sample code that you have so far to send the initial
message?
On Wed, Feb 27, 2013 at 3:13 PM, stynor wrote:
> Its either that, or bitrot has set in and the code - which appears to be
> almost 5 ye
Its either that, or bitrot has set in and the code - which appears to be
almost 5 years old now. Perhaps it simply no longer works with modern
versions of .NET? Since I can't find any documentation, or examples or
unit tests I really don't know where to start. I scraped together a working
fire-a
I did a test of latest AMQ.
- Two servers, 8GB. 64bit. Ubuntu 12.04
- AMQ 5.8 stable
- Stompest, python client
- I ran two brokers, connected.
- I wrote a simple producer that just looped infinitely sending messages
to a queue.
- On the remote server, I ran a consumer that just retrieved and pr
Full disclosure on my side - I am a .NET developer, but I haven't used the
WCF bindings. :-)
>From the message text in the exception being thrown, my first guess is that
there is some kind of configuration setting that is missing. It reads like
it is trying to enforce/protect the WCF communicati
I guess the service factory that creates the broker should register a vm
connection factory service in osgi once it has successfully started a
broker,
that could then be used to depend on. I think that is a sensible
enhancement.
One thing that may help today is adding a dependency on the service
Mike -
Did you ever find any documentation or examples for the Apache.NMS.WCF
library? I'm starting down the same path you seem to have started a few
months back - so far, haven't found any examples or unit test code to
validate that the WCF library still behaves as designed...
Thanks!
Steve
Well... Where do I start :)
Full disclosure: I'm a java developer trying to add support for our .NET
developers. I know just enough .NET to get myself into serious trouble.
The NMS.WCF source does not have any example or test projects - and no
documentation that I've been able to find. The st
A likely explanation for such a graph is that you're using VM cursors
and your consumers are slow. Therefore your messages are piling up in
memory. I wonder if producer flow control is enabled at all and why
the constant pending message limit strategy is not ditching old
messages.
Unless you post
Those perm mem settings are too low. It will thrash the GC.
Sent from my Verizon Wireless 4G LTE Smartphone
Original message
From: "mandar.wanpal"
Date:
To: users@activemq.apache.org
Subject: Re: AMQ halts and crashes after few thousand reqs
Hi All,
Thanks for the repl
Yep, Dejan has been tracking the OSGI bundle changes:
https://issues.apache.org/jira/browse/AMQ-4034
https://issues.apache.org/jira/browse/AMQ-4341
On Wed, Feb 27, 2013 at 8:25 AM, Charlie Mordant wrote:
> Hi,
>
> I tried to install activemq-camel on Karaf (2.3.0) and while doing, i got
> this
Hi Diego,
So ActiveMQ has a JMS API wrapper that can under the covers proxy the
sessions from the wrapped connection. Perhaps we should try to port that
to work with stompjms too.
On Fri, Feb 22, 2013 at 9:46 AM, diegoc wrote:
> Hi there
>
> I am using this Stomp client:
>
> http://grepcode.c
Use the tools provided in the binary distribution.
Look in the example folder (you only need ant installed).
--Mensaje original--
De: iluv2salsa
Para: users@activemq.apache.org
Responder a: users@activemq.apache.org
Asunto: Conntecting to a remote broker.
Enviado: 25 de feb de 2013 21:24
I
Hi,
I tried to install activemq-camel on Karaf (2.3.0) and while doing, i got
this error:
Error executing command: Jar is not a bundle, no Bundle-SymbolicName
mvn:org.apache.activemq/activemq-camel/5.8.0
camel-activemq-5.8.0 is not a valid osgi bundle (its manifest lack of info),
as the ones for
On 02/27/2013 05:20 AM, spam trap wrote:
[ActiveMQ-CPP v3.4.4]
I have an ActiveMQ asynchronous consumer that I need to start and stop
consuming. I also need it to redeliver messages that it has
previously consumer but not acknowledged. To do this I am using the
INDIVIDUAL_ACKNOWLEDGE mode.
To
You can set up separate transport connectors for producers and consumers.
That way you can bring down producers by shutting down their transport
connector, and allow consumers to keep going.
On Wed, Feb 27, 2013 at 6:23 AM, jayeff wrote:
> Hi all,
>
> is there a way to prevent a given queue from
That's good to hear. We tried to use AMQ (and still want it to be a
solution for us!) a couple years ago in our amazon cluster and using
network of brokers found that consumers would fall off and not reconnect
and on the producer side things would just come to a halt. We had to act
quickly and
Hello,
Since I upgraded from ActiveMQ 5.7.0 to 5.8.0 in Karaf 2.3.0, I had to
change the configuration for the setup of the embedded broker and the
ConnectionFactory service.
Previously I created the broker and the ConnectionFactory from the same
blueprint XML file, using the activemq xbean namesp
[ActiveMQ-CPP v3.4.4]
I have an ActiveMQ asynchronous consumer that I need to start and stop
consuming. I also need it to redeliver messages that it has
previously consumer but not acknowledged. To do this I am using the
INDIVIDUAL_ACKNOWLEDGE mode.
To start and stop the consumer I am using ses
Wish I could put up some of Hiram's benchmark ActiveMQ tests' perf stats up
here from even one of our dev clusters (forget about stress or prod env's) but
company policy doesn't permit I share. One of my prod clusters does apple push
notifications among other things - it has been up and invisibl
In one example I checked the DLQ message sent at 03:30 was not redelievered
and it had not expired, it had expiry set to 06:30.
The only significant ActiveMQ log entry at that time is the JDBC connection
failure logged during the ACK processing for this message.
--
View this message in context:
21 matches
Mail list logo
