Re: ActiveMQ: Advisory for MessageConsumed

2011-06-06 Thread karen
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

Re: Exception Channel was inactive for too long

2011-06-06 Thread Marcelo Jabali
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

Exception Channel was inactive for too long

2011-06-06 Thread agujral
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

Re: Unable to persist messages in DB when activeMQ embedded in JBoss 5.1

2011-06-06 Thread korg
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

Re: UDP Transport connector binds to a random port number.

2011-06-06 Thread Amir
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

Re: UDP Transport connector binds to a random port number.

2011-06-06 Thread Amir
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.

Re: Pure Master/Slave config. Synchronization of messages?

2011-06-06 Thread tkasire...@gmail.com
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.

Re: How can we know the last acknowledge message for each specific topic

2011-06-06 Thread Dejan Bosanac
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

Re: Getting ActiveMQ Memory statistics

2011-06-06 Thread Torsten Mielke
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

Re: Controlling Message generation based on ActiveMQ memory

2011-06-06 Thread Torsten Mielke
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

Re: Limiting the size of a queue

2011-06-06 Thread Torsten Mielke
Have a look at sendFailIfNoSpace property as part of configuring ProducerFlowControl. http://activemq.apache.org/producer-flow-control.html

Getting ActiveMQ Memory statistics

2011-06-06 Thread Aneesh
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

XA transaction rollback memory leak

2011-06-06 Thread geeky.diamond
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

Re: Controlling Message generation based on ActiveMQ memory

2011-06-06 Thread Aneesh
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

Re: Controlling Message generation based on ActiveMQ memory

2011-06-06 Thread Norman Maurer
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

Controlling Message generation based on ActiveMQ memory

2011-06-06 Thread 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 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

Re: Keeping the messages in a queue or topic during a day

2011-06-06 Thread serious
@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

Limiting the size of a queue

2011-06-06 Thread igrahami
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

Re: How can we know the last acknowledge message for each specific topic

2011-06-06 Thread Scott
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