Hi Gary,
Thanks for replying.
I have logged a Jira for the issue:
https://issues.apache.org/jira/browse/AMQ-3361
thanks
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Advisory-for-MessageConsumed-tp3547010p3578728.html
Sent from the ActiveMQ - User mailing list
Hi Anurag,
I'm not sure how you've configured the ActiveMQ transport but take a look on
this [1] and see if that helps. It clearly states that setting
maxInactivityDuration to 0 would disable inactivity monitoring. But, you may
want to set to some other value.
[1] http://activemq.apache.org/co
Hi All,
I using activmemq-5.4 I am seeing the following error messages:
org.apache.activemq.transport.InactivityIOException: Channel was inactive
for too long: /172.20.210.18:41140
at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:236)
at
or
Hi all,
It looks like I have to make every single message I send on the queue
PERSISTENT (by setting the JMSDeliveryMode on each message to
DeliveryMode.PERSITENT). Is there a configuration I could set somewhere
that would make all messages persistent? I tried setting the DeliveryMode
on the pro
By the way, as a side note, its pretty weird this bug hadn't been discovered
before because UDP actually did not work at all. So, I think there is a
serious lack of UDP tests in the current test collection.
-Amir
--
View this message in context:
http://activemq.2283324.n4.nabble.com/UDP-Transpo
Thanks Gary,
Using the the pointer you gave me I found the bug in ActiveMQ that was
causing this problem. I'll submit a patch soon.
-Amir
--
View this message in context:
http://activemq.2283324.n4.nabble.com/UDP-Transport-connector-listens-on-a-random-port-number-tp3570237p3577408.
Thank you Prasad. It works.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Pure-Master-Slave-config-Synchronization-of-messages-tp3442845p3577243.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Durable topic subscription is the solution to your problem
See http://activemq.apache.org/how-do-durable-queues-and-topics-work.html for
some info
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in open source integration and messaging - http://fusesource.com
A
In case of an external broker you can connect to the broker
programmatically via JMX and query these broker JMX attributes.
If the broker runs embedded get a handle on the BrokerService from where
you can retrieve the BrokerView (via BrokerService.getAdminView()).
The BrokerView offers APIs such g
Assuming you don't have many producers sending to the same destination,
your producer could connect to the broker via JMX and query the
MemoryPercentUsage property of the destination. If that is above 70% you
might skip the creation of the msg.
So JMX does expose this information. Other than that I
Have a look at sendFailIfNoSpace property as part of configuring
ProducerFlowControl.
http://activemq.apache.org/producer-flow-control.html
Is there anyway in which i can get the current memory used by ActiveMQ from
my java code?
I am not telling about any apps (like Jconsole) which is used for
profiling..
Just need to know the current memory used by broker, how much available like
that.
Is ActiveMQ exposing any APIs/classes for getti
We have Glassfish sending messages to an activeMQ topic using an XA
Transaction. This seems to work correctly when transactions are committing.
However, *every* time we have a transaction rollback we have a slight memory
leak from activeMQ. After 1000 rollbacks our 1mb queue memory is full.
The l
Thanks a lot for sharing the link.
I went through that and it seems all these end up at a point where the
producer may slowdown processing or throw an exception (like
ResourceAllocation Exception etc).
But the scenario what i am trying to avoid is the unwanted processing of
constructing the messag
You can do this via flow-control.
See:
http://activemq.apache.org/producer-flow-control.html
Bye,
Norman
Am 06.06.2011 15:23, schrieb Aneesh:
Hi all,
I have a java class which produces the message and puts the message into the
queue.
I have a requirement where i should stop producing the me
Hi all,
I have a java class which produces the message and puts the message into the
queue.
I have a requirement where i should stop producing the message
programatically
depending on the memory usage of ActiveMQ..
How can i achieve this?
Is it through Advisory Messages? Or is there any other w
@Gary : thanks for the pointer, this looks like the ideal solution.
But I can't make it work, here is some code that does not work as expected :
(Note : this is some C# using the NMS API but this is very close to
Java+JMS)
[code]// Generate a new unique topic name
string retroactiveTopicName = "t
Hi,
ultimately what I am trying to do seems quite simple. I am wanting to use a
queue to decouple the front and backend of our system by putting a jms queue
in between. The information being put on the queue isn't 100% important, it
is more important that what is going on in the frontend is not bl
I was able to get all non-acknowledge messages from JConsole, but i can't
find a way to map those non-acknowledge message to each specific consumer.
By the way, i am using persistent message
--
View this message in context:
http://activemq.2283324.n4.nabble.com/How-can-we-know-the-last-acknowled
19 matches
Mail list logo