Delayed messages not delivered when master goes down.

Here is my setup I have a master/slave (apache-activemq-5.8.0) configuration using MySql database as a shared storage. Next a client connects to the current master broker via failover:(tcp://host1:61616,tcp://int-host2:61616)?randomize=false and posts a message with a delayed delivery to a queu

Delayed messages not delivered when master goes down.

Here is my setup I have a master/slave (apache-activemq-5.8.0) configuration using MySql database as a shared storage. Next a client connects to the current master broker via failover:(tcp://host1:61616,tcp://int-host2:61616)?randomize=false and posts a message with a delayed delivery to a queu

Re: Adding custom made plugins not possible in 5.8?

Yes, that works. Thanks a lot Torsten! On Thu, Sep 12, 2013 at 4:03 PM, Torsten Mielke wrote: > Hello, > > Can you try > > > > > http://www.springframework.org/schema/beans"; > id="myPlugin" class="org.myorg.MyPlugin"/> > > > > > instead? > I recently got a destination interceptor to

Dropping slow consumers

Dear Distinguished Colleagues: I would like to be able to drop slow consumers . If a slow consumer is detected, I want it gone, and I want an advisory message to say "this consumer was dropped". I can't find good documentation for this. Any ideas ? -- Regards, Oleg Dulin http://www.olegdulin

Activemq + Stomp queue gets stuck

Hi, We're having issues using activemq 5.8.0 with PHP stomp. In our live environment we were noticing that the queue would stop processing, and readFrame would return false even though there were still messages in the queue. When it hands, restarting stomp usually fixes the problem and new messag

Re: useJmx=false, two brokers, getting exception due to jmx

Is it using the config you think it's using? On Thu, Sep 12, 2013 at 9:25 AM, ariskk wrote: > 2 test cases use two brokers. One is configured to not use jmx: > > xmlns="http://www.springframework.org/schema/beans"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-in

Re: Activemq + Stomp queue gets stuck

Interestingly, hasFrame does acknowledge that a frame is there, it's just that readFrame returns a null/blank message. -- View this message in context: http://activemq.2283324.n4.nabble.com/Activemq-Stomp-queue-gets-stuck-tp4671453p4671455.html Sent from the ActiveMQ - User mailing list archive

Clarification requested regarding topic subscription management in 5.8.0

Hi, Using ActiveMQ 5.8.0 on RHEL 6.1 I'd like some clarification as to what is the expected behavior when one follows these steps: 1. Using the web console create a durable topic subscriber. In my case it was for an existing (and busy) topic (let's call it foo), the selector was blank a

useJmx=false, two brokers, getting exception due to jmx

2 test cases use two brokers. One is configured to not use jmx: http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema

Re: Interceptors/Phases like in Apache CXF

Yes there are interceptors in ActiveMQ. In AMQ land I don't think we distinguish between interceptors and broker plugins. The terms are used interchangeably. However there are broker plugins (or interceptors) and destination interceptors. Broker plugins are documented at http://fusesource.com

Re: Best configuration for a network of 3 brokers

The answers really depends on your use case and how you want to leverage the brokers. However the most typical topologies in general are a full mesh (every broker connected to all other brokers) and hub-and-spoke (one hub broker and multiple store brokers that connect to the hub). But again t

Re: Adding custom made plugins not possible in 5.8?

Hello, Can you try > > http://www.springframework.org/schema/beans"; id="myPlugin" > class="org.myorg.MyPlugin"/> > instead? I recently got a destination interceptor to work that way and had to specify the namespace for correctly. Regards, Torsten Mielke tmie...@redhat.com tmi

Re: Best Protocol For ActiveMQ

Broker networks generally use the openwire transport (i.e. tcp://host:port). In the network connector most people either use static: or masterslave: The latter if they want to connect to a master/slave broker pair. I have not seem multicast being used a lot. http://activemq.apache.org/networks-

Adding custom made plugins not possible in 5.8?

Hello, I made a new BrokerPlugin as described here: http://fusesource.com/docs/mirrors/activemq/features/interceptors.html I edited activemq.xml to add a "plugins" element to "broker" like this: http://activemq.org/config/1.0"; brokerName="localhost" dataDirectory="${activemq.base}/data" plugins

Re: Need help - Messages lost when using failover network connection with failback

I've tried the masterslave discovery agent on broker amq3 & the failover from master (amq1) to slave (amq2) works. However, masterslave doesn't seem to support priorityBackup=true & so the broker doesn't fail-back from slave to master when the master comes back online. My original issue is that

Re: MDB config settings ignored

Well, before read your reply, yesterday we went to this page http://activemq.apache.org/activation-spec-properties.html and we saw the "maxSessions", "maxMessagesPerSessions" and "maxMessagesPerBatch" properties. Apparently this is the solution we were looking for, because changing its value our MD

Interceptors/Phases like in Apache CXF

Hi, is there in ActiveMQ a concept like Interceptors and Phases like in Apache CXF? I'd like to plug in some custom functionality in the sending and receiving part of the messaging. In CXF I would do something like Is there