How can I get some information about a peer?

Hi, How can I get some information, such as peer IP address, connection type(TCP, SSL, ...), etc. about a peer producer? Thanks in advance! -- View this message in context: http://www.nabble.com/How-can-I-get-some-information-about-a-peer--tp18416498p18416498.html Sent from the ActiveMQ - User m

Broker detection of poison messages

I'm working on a consumer that might receive an OutOfMemoryError while processing a message. When that happens, I would like the consumer process to die (System.exit) so it will be restarted with a clean JVM. Is there a way for the broker to detect if a consumer dies without cleanly rolling back

Re: Specifying a timeout value for createTopicConnection() method

FWIW, I am using 5.1 and my createTopicConnection doesn't hang; it hurls a ConnectException if the target broker is not running. What version of AMQ are you using? Are you by any chance using failover transports? Joe www.ttmsolutions.com nabbleuser2008 wrote: > > I would have told this is

Re: New subscribers getting old messages

Check out retroactive consumers http://activemq.apache.org/retroactive-consumer.html Joe www.ttmsolutions.com kfritz wrote: > > Hello. I have an application that communicates to clients by publishing > ObjectMessages to an ActiveMQ topic. Any client that is subscribed to the > topic will r

New subscribers getting old messages

Hello. I have an application that communicates to clients by publishing ObjectMessages to an ActiveMQ topic. Any client that is subscribed to the topic will receive messages soon after they are published. Also, using durable subscriptions, a client that had subscribed earlier and disconnects, w

Re: ActiveMQ and Glassfish Realm

Thank you, In 4, I don't understand how I would plug Credential from Jetty in combination with the user.properties file or is that a completely new alternative you're proposing here? On Fri, Jul 11, 2008 at 4:33 PM, Joe Fernandez < [EMAIL PROTECTED]> wrote: > > 1. No, you can either develop your

Re: ActiveMQ and Glassfish Realm

1. No, you can either develop your own JAAS LoginModule or use the Glassfish LoginModule. The LoginModule gets picked up by the ActiveMQ JaasAuthenticationBroker. You specify what module to pick up via a combination of broker XML file and the login.config file. Keep in mind that this is for 'auth

Printing advisory messages in activemq logs

Hi I see in web console: NameNumber Of Consumers Messages Sent ActiveMQ.Advisory.TempTopic 26 1920 ActiveMQ.Advisory.Consumer.Topic.MD.C1 0

Re: ActiveMQ Disk usage

Good advice! On 11 Jul 2008, at 17:25, andrewh wrote: Solved. We have a queue that had no consumers, so messages from that queue were in the journal, but unfortunately all the data inbetween these messages is retained, due to how the journal indexes (I presume). Purging this queue bring

Re: Specifying a timeout value for createTopicConnection() method

I would have told this is a problem others would have run into also. Or, am I doing something wrong ? In my system, createTopicConnection() call hangs when the broker is not reachable, for example, when it is down. Appreciate any help. Thank you. -- View this message in context: http://www.

Re: ActiveMQ Disk usage

Solved. We have a queue that had no consumers, so messages from that queue were in the journal, but unfortunately all the data inbetween these messages is retained, due to how the journal indexes (I presume). Purging this queue brings the journal size back down. Moral of story - audit your queues

All messages in queue repeatedly vanish, but reappear after restart

I have been publishing 100,000 simple messages into a queue, and then having ~5 consumers pull them off the queue as fast as possible. I haven't been able to figure out exactly what triggers it, but usually the all the messages in the queue will disappear. The web console indicates that they are

ActiveMQ and Glassfish Realm

I have read the security page found at http://activemq.apache.org/security.html but I am somewhat confused by the information found there. 1. If I wanted ActiveMQ to work with a Glassfish realm, Glassfish does indeed use JAAS, would I need to code my own plugin based on BrokerPlugin? Or would it b

Re: ActiveMQ Message Broker shut down without Exception

Did that happen regardless of how you started up activemq? Can you provide any more details about the changes you made? Thanks Andy dolphin_cheng wrote: > > We login in a server remotely and found that when we exit the server > abnormally, AMQ broker will also shut down automatically. Now we

Re: ActiveMQ Message Broker shut down without Exception

We login in a server remotely and found that when we exit the server abnormally, AMQ broker will also shut down automatically. Now we changed some source code and recompiled to amq.jar, the broker became more steady. Andy Wu wrote: > > Hi Rob, > > Thanks for the reply. Appreciate any help you c

Re: JMS consumer is not receiving any messages. am i missing something ?

You should only close those resources when your app no longer wants to receive messages. On 11 Jul 2008, at 13:02, Jigar Naik wrote: Jigar Naik wrote: Hi The uploaded file contains the consumer code. but the consumer is not receiving any messages even though there are 10 messages in the

Re: JMS consumer is not receiving any messages. am i missing something ?

Jigar Naik wrote: > > Hi The uploaded file contains the consumer code. but the consumer is not > receiving any messages even though there are 10 messages in the queue. I > have tried to debug the code. but i found it is not calling the > onMessage() method. > > Am i missing something ? > > h

Spring JmsTemplate receive() returns null with messages in Queue

Hi, I tried to use JmsTemplate's receive() method for synchronous consumption of a Queue, but the method returns 'null', even when there are messages in the queue. The JmsTemplate (with a time out of two seconds) successfully receives first messages, but after a while, it is not able to consume

JMS consumer is not receiving any messages. am i missing something ?

Hi The uploaded file contains the consumer code. but the consumer is not receiving any messages even though there are 10 messages in the queue. I have tried to debug the code. but i found it is not calling the onMessage() method. Am i missing something ? http://www.nabble.com/file/p18401944/JCon

Re: ActiveMQ disk usage

Hi, Thanks for your response.Then what i should do?we cant expect to have a space for this huge chunk of data.Its growing something around 3G per day. Regards Sushovan rajdavies wrote: > > > On 11 Jul 2008, at 07:50, shovan wrote: > >> >> Hi we are using using activemq for our application.B

Re: ActiveMQ Message Broker shut down without Exception

Hi Rob, Thanks for the reply. Appreciate any help you can provide. I start activemq with the following command: > bin/activemq & I intially thought it was related to my shell closing but it's definitely set to run as a background process and the last time it shutdown didn't correlate to my clo

Re: Producer Stops Sending messages

Hi Dejan Thanks for your reply and sorry I've took so long to get back but I got sent onto another project for 2 weeks. I was using the Pooledconnection and it would seem that the Gotacha's did infact get me!. I've changed this around and am using JMS not the Spring JMS template for the publis

Re: ActiveMQ Message Broker shut down without Exception

This is really weird - would love to get to the bottom of it too. How do you start activemq ? there's been problems in the past with the parent shell timing out when started remotely, for example. cheers, Rob On 11 Jul 2008, at 10:18, Andy Wu wrote: I'm seeing a similar issue here. I'm

Re: How is the number of Consumers counted ?

Don't set maxInactivityDuration at all - then at least the clients will get cleaned up - when they disapear (the default is 3ms) - which is actually the interval between keep alives if there's no activity. With the default - the broker will eventually detect the client is dead after abo

Re: problems with memory usage

Sorry about this, this is another attempt at better formatting: Hi, we have a problem with memory problem that seems pretty usual on forums on 4.1.1. Currently we plan to increase the userManager memory, and eventually switch to 5.1. But... Going by log on broker we get to this: DEBUG UsageMan

problems with memory usage

Hi, we have a problem with memory problem that seems pretty usual on forums on 4.1.1. Currently we plan to increase the userManager memory, and eventually switch to 5.1. But... Going by log on broker we get to this: DEBUG UsageManager - Memory usage change. from: 99, to: 100

Re: ActiveMQ Message Broker shut down without Exception

I'm seeing a similar issue here. I'm using a standard 5.1 distribution and simply starting it up and sending a couple hundred messsages a minute on 1 topic with 6 subscribers. After some arbitrary length of time - it managed just over a day last time round - the server shuts down with no explana

RE: How is the number of Consumers counted ?

On 10 Jul 2008, at 15:00, Rob Davies wrote: > On 10 Jul 2008, at 13:01, Borer Reynald wrote: > > > Hello, > > > > I am using activeMQ for one of our projects where a Java applet is > > used > > to consume messages from JMS queues. During our tests, we discovered > > that the number of consum

Re: ActiveMQ disk usage

On 11 Jul 2008, at 07:50, shovan wrote: Hi we are using using activemq for our application.But the trouble here is its size is increasing at an alarming rate(to be specific the Seg0 folder(i think its used for persistence purpose)).But i am not sure whether to keep these data in the form