How to safely consume a topic from INSIDE the broker?

I am writing a custom SubscriptionRecoveryPolicy and one of the things I need to do while recovering is create a temporary topic and consume messages from it. What is the right way to do this? I don't see a straightforward API for it (such as the one for sending messages: BrokerFilter.send). I

Re: BlobMessage 'name' attribute not transferring

Hi there, its a bug. I create a jira issue and attached a fix there: https://issues.apache.org/jira/browse/AMQ-3067 Bye, Norman Ps: Thx for reporting 2010/12/2 Brett Wooldridge brett.wooldri...@gmail.com: I have a producer creating BlobMessages, and a consumer that consumes them.  The

Re: ACTIVEMQ-CPP. Using ssl

Hi all, I've set the debug info to activemq and I'm seeing this: 2010-12-02 06:17:00,160 | DEBUG | Sending: WireFormatInfo { version=5, properties={CacheSize=1024, CacheEnabled=true, SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=1, TcpNoDelayEnabled=true,

Re: Durable Subscriber reconnect issue

Try using the failover transport, that broker check can be avoided if the failover transport is reconnecting, ie: if the openwire faultTolerant flag is set on a connection context. On 1 December 2010 17:06, mcolarusso mcolaru...@tabnetworks.us wrote: I am running 5.4.1.  Some of my durable

Re: ACTIVEMQ-CPP. Using ssl

The most common problem is that you are using an ip address instead of a the hostname that should be set in the commonName field in the Certificate. Regards Tim www.fusesource.com On Thu, Dec 2, 2010 at 6:16 AM, Oscar Pernas os...@pernas.es wrote: Hi all, I've set the debug info to activemq

Re: which release of NMS works with activemq 5.2.0?

There shouldn't be any issue using an older broker with the newer versions of NMS.ActiveMQ. You might want to check the URI in the code to ensure its pointing to the correct location. On Wed, Dec 1, 2010 at 4:33 PM, Peter Lin wool...@gmail.com wrote: I'm hoping someone knows the answer to

Re: which release of NMS works with activemq 5.2.0?

I found my error. when I copied the example, I left out { and } after the using( ) statement. that was causing the Nullpointer error I was getting. Reading the example on the website, it was hard to see. Even though it is valid in C# to have using( something) block without { } it was causing

What is the time period used in StatisticsPlugin?

Hello, I would like to know how the StatisticsPlugin track statistics. For example on ActiveMQ.Statistics.Broker or ActiveMQ.Statistics.Destination.QUEUE_NAME, it returns the statistics for averageEnqueueTime, maxEnqueueTime, and minEnqueueTime. What is the period used to calculate these

[ANNOUNCE] Apache ActiveMQ 5.4.2 released

The Apache ActiveMQ team is pleased to announce the release of Apache ActiveMQ 5.4.2. This is a maintenance release, bringing together 61 resolved issues. Full details and download link can be found in the release page: http://activemq.apache.org/activemq-542-release.html Thanks to everyone who

Re: [ANNOUNCE] Apache ActiveMQ 5.4.2 released

Any ETA for 5.4.2 to get deployed into maven repository? On 12/2/10 4:02 PM, Dejan Bosanac wrote: The Apache ActiveMQ team is pleased to announce the release of Apache ActiveMQ 5.4.2. This is a maintenance release, bringing together 61 resolved issues. Full details and download link can be

Re: [ANNOUNCE] Apache ActiveMQ 5.4.2 released

Its already there... http://repo1.maven.org/maven2/org/apache/activemq/activemq-core/ Bye, Norman 2010/12/2 develop d...@alegram.com: Any ETA for 5.4.2 to get deployed into maven repository? On 12/2/10 4:02 PM, Dejan Bosanac wrote: The Apache ActiveMQ team is pleased to announce the

Re: When persistent=false, still need kahadb jar file?

activemq 5.4.2 has fixed my problem. --- On Wed, 12/1/10, acec acec tomcata...@yahoo.ca wrote: From: acec acec tomcata...@yahoo.ca Subject: When persistent=false, still need kahadb jar file? To: users@activemq.apache.org Received: Wednesday, December 1, 2010, 11:15 AM After I upgraded

Re: What is the time period used in StatisticsPlugin?

up up Don Santillan wrote: Hello, I would like to know how the StatisticsPlugin track statistics. For example on ActiveMQ.Statistics.Broker or ActiveMQ.Statistics.Destination.QUEUE_NAME, it returns the statistics for averageEnqueueTime, maxEnqueueTime, and minEnqueueTime. What is the

Topic messages lost even when they are persistent - help!

Hi, I am a new user trying to use activemq for my ESB. I am trying to use the sample programs TopicPublisher and TopicLIstener. I am posting messages to ActiveMQ topics called topictest.messages , topictest.control. I am marking them as persistent in the following ways:

Re: Topic messages lost even when they are persistent - help!

can you post your consumer, are you specifying the same connection and subscription id on reconnect? On 2 December 2010 18:00, ncsridhar s...@uc4.com wrote: Hi, I am a new user trying to use activemq for my ESB. I am trying to use the sample programs TopicPublisher and TopicLIstener. I am

Re: What is the time period used in StatisticsPlugin?

they are computed from broker start or from the last reset which can be issued via the admin console or vi jmx. On 2 December 2010 14:46, Don Santillan donzym...@gmail.com wrote: Hello, I would like to know how the StatisticsPlugin track statistics. For example on ActiveMQ.Statistics.Broker

Re: How to safely consume a topic from INSIDE the broker?

You could create your connection and consumer in the initialization of the recovery policy rather than an the recover method, that may help. On 2 December 2010 08:35, adam adam.suss...@gmail.com wrote: I am writing a custom SubscriptionRecoveryPolicy and one of the things I need to do while