Ok... I figured out what was going on. I will file a ticket on this shortly.
When the master broker is undergoing a controlled shutdown, the
BrokerService.stop() method stops in this order:
* services
* connectors
* registered vm transports
* broker
So there is a period where the broker will
Hi all,
I try to use ActiveMQ 5.5.0 embedded in JBoss. Everything works fine except
for the persistence. I followed all the steps described
http://ttlnews.blogspot.com/2010/10/jboss-4551-and-activemq-54-integration.html
here and messages are sent to the queue, I can consume them, but they're
n
Think so, it has low impact and gives you value, so go ahead.
On 3 Jun 2011 20:22, "Jeremy Levy" wrote:
> Is this useful enough for me to submit a JIRA ticket with the patch?
>
> On Wed, Jun 1, 2011 at 1:25 PM, Jeremy Levy wrote:
>
>> Gary-
>>
>> Right, exclusive consumer won't work as I still wa
Is this useful enough for me to submit a JIRA ticket with the patch?
On Wed, Jun 1, 2011 at 1:25 PM, Jeremy Levy wrote:
> Gary-
>
> Right, exclusive consumer won't work as I still want to have multiple
> consumers.
>
> I don't have a requirement to start these consumers after the container is
>
For what it's worth, I found the issue. I didn't realize that when ActiveMQ
is running in ServiceMix you need to update the "activemq.xml" bundle to get
changes in the file to be loaded. Once I did that, I can see the
statisticsBrokerPlugin load up.
-john
--
View this message in context:
http://
Yes, I tried going to ActiveMQ.Statistics.Broker. I assume that using
the in Camel takes care of setting the replyTo.
I finally created a unit test to run. This led to realize that it
doesn't look like I get a statistics for a queue response back if no
messages have been sent to the queue or i
ActiveMQ keeps open socket connection to all clients, as that's the nature
of JMS communication.
Sure there's a limit in number of open sockets underlying system can take,
that's where other scaling techniques (horizontal and hybrid) comes into
play.
You can also implement some kind of polling in
We are using the ActiveMQ in an embedded mode in our application. It may be
difficult to reproduce in a test case because of the intermittent nature...
On inspection of the code below (from MasterBroker.java), it seems that an
exception syncing to the slave is logged but otherwise ignored. Doesn
Hi Dejan,
Thank you for the answer. The slides helped to understand how to scale
ActiveMQ.. But some questions remains:
- How ActiveMQ handle the subscribers of a non-persistent topic? Does it
consider all connected users at the same moment (with a tcp socket opened)?
Or is there some strategy for
On Thu, 2011-06-02 at 15:04 -0400, Joe Wade wrote:
> Forgive me if this is the wrong place to ask this question. Not sure if
> questions about ActiveMQ-cpp wrappers should be directed to the mailing
> list, but I kept getting here through the website.
>
> I have a simple producer/consumer setup w
Any chance you can create a test case to reproduce this?
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in open source integration and messaging - http://fusesource.com
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
Connect
Sorry, the master exception log message includes a modification we made to
the logging on slave failure to distinguish failure conditions (see
AMQ-2459).
Normally it would say "Slave Failed" with the exception. Full exception
trace returned from slave:
java.net.SocketException: socket closed
Hi,
I have a pure master/slave configuration. I am using 5.3.2 but have
observed the same problem in testing 5.5.0.
I have an intermittent issue where a message will appear to be successfully
sent (the producer send() method returns without error) but will be lost.
This occurs sometimes during
that is a little odd. All I can think of is that the underlying
connection is dropped in the exception case, wonder if that is the
case. It would cause any unprepared transactions to be rolledback.
Also, the xa start is sent async to the broker, but the timing from
the logs does not indicate a race
Have a peek at the source: doBind in
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/udp/UdpTransportFactory.java?view=markup
You may be able to easily see what is going on, or not going on :-)
Please open an issue to track this and if you hav
If you post a thread dump when you are blocked on the stop call, from
something like kill -3 or jstack we may be able to spot the problem
On 2 June 2011 19:18, ravimbhatt wrote:
> Hi All,
>
> I am facing a very strange problem with ActiveMQ.
>
> I have a java class that attaches itself to a queue
Well, its for research purposes. We've developed an end-to-end reliability
protocol for unreliable pub/sub and we've decided to evaluate the protocol
with ActiveMQ in unreliable settings. (UDP).
At this point I'm almost certain this is a bug in ActiveMQ. I was hoping 5.5
would fix the bug but it st
Hi,
some useful scalability resources:
- ${ACTIVEMQ_HOME}/conf/activemq-scalability.xml
-
http://www.slideshare.net/dejanb/advanced-messaging-with-apache-activemq?from=ss_embed
-
have some slides on scaling
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in
Hi,
any particular reason for using UDP protocol?
Regards
--
Dejan Bosanac - http://twitter.com/dejanb
-
The experts in open source integration and messaging - http://fusesource.com
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
Connect at Ca
Hi all,
I'm having problem getting ActiveMQ 5.4.* and 5.5 to run properly with UDP
transport connector. What happens is that the broker listens to a random UDP
port number instead of the one I configure in the URI. The port number seems
to be randomly chosen, since it changes each time the broker
have you tried sending a message to ActiveMQ.Statistics.Broker - to see if you
get a response (you need to set the replyTo destination on the message) ?
On 2 Jun 2011, at 21:13, john wrote:
> I'm running the fuse 4.2.0-fuse-02-00 release.
>
> It includes activemq 5.3.1 along with Camel 2.2 all
21 matches
Mail list logo
