Hi,
I have created an embedded broker and having 10 producers pushing messages
over 1 topic and 10 consumer consuming it. while shutting down the broker I
get following warning:
The connection to '' is taking a long time to shutdown.
and the broker is stuck(it doesn't shut down).
Can anyone help m
You probably want to get a copy of Camel in Action and
start reading about camel.
The uri / queue placements for connecting to another broker is controlled by
the connection factory.
On Aug 3, 2011, at 11:40 PM, Gnanaguru S wrote:
> Hi
>
> I am routing using the following queue present as b
Hi
I am routing using the following queue present as below. but i want to route
it to the remote system sunning activemq. Kindly help out with the syntax
For replacing " activemq:queue:outputQueue " with remote queue address (
including ip and port ).
How it can be done
Help out.
Cheers
> What is the output with 2.2.1?
> What os are you building under?
here is my build env,
$ mvn -v
Apache Maven 2.0.11 (r909250; 2010-02-12 14:55:50+0900)
Java version: 1.5.0_22
Java home: jdk1.5.0_22/jre
Default locale: ja_JP, platform encoding: UTF-8
OS name: "linux" version: "2.6.37.6-0.7-desk
Thank you for the suggestion. I created AMQ-3436 for this issue.
https://issues.apache.org/jira/browse/AMQ-3436
I attached my JUNIT test case and the patched files.
I modified the code to use the existing PendingList (PrioritiziedPendingList or
OrderedPendingList depending on if prioritization
Hi,
I would like to know how to find the last accessed time of the
topic/subscription on the ActiveMQ broker. Any suggestions, ideas, links,
resources highly appreciated.
no, I guess the point of a virtual topic is that the messages remain,
but message expiry could be your friend here, once all messages expire
the destination will be a candidate for cleanup.
On 3 August 2011 18:50, pol_ice wrote:
> I see, is there a way to unsubscribe consumer from virtual topic?
I see, is there a way to unsubscribe consumer from virtual topic? So that I
can ensure there are no more messages enqueued in its queue?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Delete-queues-created-for-virtual-topic-consumers-tp3714004p3716344.html
Sent from the Ac
want to submit your hack as a patch, using ssh/scp makes great sense.
On 2 August 2011 17:07, johncarl81 wrote:
> Pawan Chhabra writes:
>
>>
>>
>> I had faced the similar problem. you need to set policy like
>>
> connectionFactory.getBlobTransferPolicy().setUploadUrl("http://127.0.0.1:8161/files
no, they need to be empty to be candidates for garbage collection.
On 3 August 2011 16:52, pol_ice wrote:
> One question though, will this setting delete the inactive queues with a
> number of pending messages?
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Delete
Hi Gary,
thanks again.
Yes some of the queues grow larger than previously in terms of pending
messages just before the tmp store is created.
So we need to increase our memoryUsage under the systemUsage element of the
broker configuration? Currently it will just be using the defaults.
I was not
One question though, will this setting delete the inactive queues with a
number of pending messages?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Delete-queues-created-for-virtual-topic-consumers-tp3714004p3715969.html
Sent from the ActiveMQ - User mailing list archive a
Thanks Gary,
I thought it would be a method not a broker setting.
However it should work just fine when separating testing and production
environments ( we will just need not to forget to reset auto removal
settings when setting it up on production. )
--
View this message in context:
http://act
have a peek at: http://activemq.apache.org/slow-consumer-handling.html
you just need to configure a ConstantPendingMessageLimitStrategy of 1
and a prefetch of 1 for your non durable subs.
On 3 August 2011 10:40, kaustubh khasnis wrote:
> Hi,
> Is there any way in activeMQ to disable the message
http://activemq.apache.org/delete-inactive-destinations.html
On 3 August 2011 00:06, pol_ice wrote:
> Hi there,
>
> In my functional tests I have to create a unique consumer name for each test
> to be able to imitate a subscription to the virtual topic and receiving the
> messages from the queue.
Just trying to interpret the data results from the perf-test...could anyone
please give me an indication of the different fields appearing in the
results xml file: specifically those pertaining to the CPUdata...
Also, is there a documentation on how the 'sampling' concept is being
carried out?
--
Hi,
i'm using a broker network of 6 servers. All servers have a hardcoded
connection to every other server (hyptercube) the connections are not
duplex. Advisory topics are on and the servers authenticate using a super
user.
My consumer is connected to server A
Currently messages that are send to
Hi,
Is there any way in activeMQ to disable the message cursor for non-durable
subscribers. My use case is like: the messages should always be persistent
and will have both durable and non-durable subscribers to it. In case
durable subscriber is faster than non-durable subscriber , MQ will still
ke
thinking a bit more, the simplest explanation is that you are reaching
your memory usage limits and pending messages are no longer cached in
memory. As a result, dispatch now needs to read from the store which
will be slower.
Do you notice an increase in queue depth before the slowdown?
post your
Hi,
no there are no slow advisory messages in the logs. We used to receive
these when using the topic and it would block our producers that added to
the topic, but we have not seen this since we changed to a virtual topic.
I'll try and arrange to capture some stack traces, the help is appreciate
@Yuvraj,
but still that how can I get the message rate per second. of course I can
get avarage, but I am more interested in actual number of message
consumed/produced in a given second. So I thought maybe instead of
repeatedly querying broker, if I write an interceptor, it would be better.
Also I
21 matches
Mail list logo
