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 wrote: > > I am writing a custom SubscriptionRecoveryPolicy and one of the things I need > to do while recovering is create

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 wrote: > Hello, > > I would like to know how the StatisticsPlugin track statistics. For example > on "ActiveMQ.Statistics.Broker" or > "ActiveMQ.

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 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 posting me

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: >> A

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.", it returns the statistics for "averageEnqueueTime", "maxEnqueueTime", and "minEnqueueTime". What is the period

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

activemq 5.4.2 has fixed my problem. --- On Wed, 12/1/10, acec acec wrote: > From: acec acec > 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 activemq 5.4.1, I > got the the follo

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 : > 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 Apach

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 foun

[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 c

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.", it returns the statistics for "averageEnqueueTime", "maxEnqueueTime", and "minEnqueueTime". What is the period used to calculate these numb

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 the

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 wrote: > I'm hoping someone knows the answer to this. > > I'm using a

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 wrote: > Hi all, > > I've set the debug info to activemq and I'm seein

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 wrote: > > I am running 5.4.1.  Some of my durable subscribers have trouble rec

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, MaxInactivityDuration=30

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 : > I have a producer creating BlobMessages, and a consumer that consumes them. >  The > producer is connected to Brok

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