Hi all,
As part of an Univ. project, we developed a small architecture:
- Clients=N (JMS producers) sends query requests
- ActiveMQ Topics L=queue size P=# of queues
- Processors=M (JMS clients) execute and sends query results
- PostgresQL
were we would vary these variables and observe the thr
Hello,
I bumped into this same issue but I know apriori the number of consumers M
that I was going to have so to limit the overall queue size L you configure
the constant size limit X to:
X = L / M; meaning the size you actually want divided by the number of
consumers.
This is a workaround but
hi all,
I was previously asking how to extend the constant message pending limit
strategy to send a custom "discarded" message to the replyTo field of the
old message before discarding it so a blocked sender can be released. This
architecture in general does not make much sense on top of JMS ...
Hello,
I need a variant of the existing constantPendingMessageLimitStrategy that
extends it in functionality so it would not only discard messages but also
"let the publisher know" that the message has been discarded. This I can do
by replying to the replyTo queue assumed to be contained in the m
Hello,
I implemented a request-response project that runs on top of ActiveMQ. I
used the following code as starting point:
http://activemq.apache.org/how-should-i-implement-request-response-with-jms.html
The problem here is that my request-response has to be blocking i.e. the
producer has to blo
Gary Tully wrote:
>
> The constantPendingMessageLimitStrategy is only applicable to topics. For
> queues, there is no way to have excess messages auto discarded except
> through message expiry.
> Will a topic work for your use case?
>
Hi Gary,
Many thanks for your reply. Indeed I said queues i
Hello,
I create queues on the fly meaning they get created as soon as I start
publishing messages. That's fine now the problem is that I can't find the
way to specify the constantPendingMessageLimitStrategy as I need these
queues to be of a specific size (messages should be discarded).
e.g.
thi