B/c we use the unique feature the VT provides so we won't uses the regular
topic subscription.
Anyway,when you use the VT and want to disable PFC, you have to disable PFC for
the VT and all the queues that are matched in runtime.
People may not be aware of this usage pattern and potentially gets
Well, I believe you can consume directly from the VT using regular topic
semantics.
On Wed, Apr 17, 2013 at 9:32 AM, SuoNayi wrote:
> yes, if we do that the retroactive consumers won't be able to get passed
> messages.
> Since we can always expect that there are no consumers on the virtual
> to
yes, if we do that the retroactive consumers won't be able to get passed
messages.
Since we can always expect that there are no consumers on the virtual topic,
is it reasonable if the topic is virtual we will do that optimization ?
At 2013-04-18 00:21:25,"Christian Posta" wrote:
>that's a go
that's a good point... not sure what the value of flow controlling the
producer if there are no consumers to a topic... maybe preserving
retroactive consumers?
On Wed, Apr 17, 2013 at 9:18 AM, SuoNayi wrote:
> The message flow can not go there at the moment.
> In the send method it will check i
The message flow can not go there at the moment.
In the send method it will check if the memory is full at first, if full then
the thread will wait for space and the producer gets blocked.
I mean before checking the memory is full or not, we can see if there are
consumers, if none the thread just
Check the dispatch method in Topic.java... we do just that:
synchronized (consumers) {
if (consumers.isEmpty()) {
onMessageWithNoConsumers(context, message);
return;
}
}
onMessageWithNoConsumers really
in the topic,such as we can
first check if there are consumers on the topic, if not we can just return
and do nothing anymore, so that the producer wont get blocked.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/What-can-be-reason-of-460-memory-usage-limit
well, I will file a jira to track this issue.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/What-can-be-reason-of-460-memory-usage-limit-tp4665651p4665847.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
ory
limits combined are higher than the overall system limit. These settings
must be taken into account.
-
http://www.christianposta.com/blog
--
View this message in context:
http://activemq.2283324.n4.nabble.com/What-can-be-reason-of-460-memory-usage-limit-tp4665651p4665807.html
Sent from th
2283324.n4.nabble.com/What-can-be-reason-of-460-memory-usage-limit-tp4665651p4665800.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
activemq26.xml
<http://activemq.2283324.n4.nabble.com/file/n4665795/activemq26.xml>
please see the attachment.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/What-can-be-reason-of-460-memory-usage-limit-tp4665651p4665795.html
Sent from the ActiveMQ - User m
SuoNayi,
Can you post the configs you're using for memory? SystemUsage and
destination policies, etc?
On Sun, Apr 7, 2013 at 7:24 AM, SuoNayi wrote:
> Hi,we're using the virtual topic to scatter messages to 12
> queues/consumers.
>
> When one consumer of one queue becomes very slow since it's
Hi,we're using the virtual topic to scatter messages to 12 queues/consumers.
When one consumer of one queue becomes very slow since it's located in London,
far from our data center in china, our single producer becomes very slow to
publish messages.
What phenomenon we observed is that:
When the
13 matches
Mail list logo
