Hiram and Christian, thanks for the replies and suggestions.
The messages that not get persisted was my fault, because the producer was
sending a non persistent messages.
I've corrected that behaviour and now the replication works perfectly.
I've also setup the total number of nodes as an odd
Client:mqttv3,Server:
apache-activemq-5.9.0.redhat-610-20130702.003414-4-bin.zip
code:
String clientId = mqtt_test;
MqttClient client = new
MqttClient(tcp://localhost:1883,clientId);
CallBack callback = new CallBack();
Hi,
I have set up ActiveMQ in a JDBC MasterSlave configuration. I have a use
case where it would be useful to mark a broker as the Master broker which
would always take a lock if it was owned by a slave. Is there anyway of
doing this or something similar, e.g. some sort of order of precedence
There isn't any eviction strategy or preferred master election strategy for
the current lock implementations. They effectively compete around some
shared mutex and first one to win is elected master. The lock
implementations are pluggable, however, so you can take a look
at
Hello, everyone.
I am just a student and I have a few question about using activemq...
1)this url:
brokerURL = failover://(discovery:(multicast://default));
while using this kind of composite url, will it work just the way I
thought, I mean, it will reconnect and discover another
the lease database locker may help, if you configure the slave lease
to be small relative to the master, then the master will take over
from the slave.
https://access.redhat.com/site/documentation/en-US/Fuse_MQ_Enterprise/7.1/html/Configuring_Broker_Persistence/files/MQLeaseDatabaseLocker.html
The problem is that you're using different broker name brokerDefault, which
will create a new embedded broker instead of using the one you created
earlier named brokerexample
Regards
--
Dejan Bosanac
--
Red Hat, Inc.
FuseSource is now part of Red Hat
dbosa...@redhat.com
Hi All,
I am getting the following exception intermittently.
Transport (tcp://127.0.0.1:61616) failed, reason: java.io.IOException:
Wire format negotiation timeout: peer did not send his wire format.,
attempting to automatically reconnect
Sometimes the code is able to connect to activeMQ
Maybe this is helpful:
http://activemq.2283324.n4.nabble.com/Wire-format-negotiation-timeout-tt4660272.html
http://activemq.2283324.n4.nabble.com/Wire-Format-Negotiation-Timeout-Say-what-tt4666972.html
On Wed, Jul 3, 2013 at 1:46 PM, Puneet puneet.ar...@insticator.com wrote:
Hi All,
On Wed, Jul 3, 2013 at 9:34 AM, situmin 772317...@qq.com wrote:
Hello, everyone.
I am just a student and I have a few question about using activemq...
1)this url:
brokerURL = failover://(discovery:(multicast://default));
while using this kind of composite url, will it work
I've tried many variations of the above, since the last post, and I do
not think there is a way to get it to accept more than one MessageID
specified like that at a time.
--
View this message in context:
yah may have to script it using JMX api and call remove message multiple
times in a loop
On Wed, Jul 3, 2013 at 2:31 PM, ccharbonneau ccharbonn...@mindoka.comwrote:
I've tried many variations of the above, since the last post, and I do
not think there is a way to get it to accept more
I am facing a small problem. Names of queues we are using are very big in
length like com.ibm.biztalk.jnbridge.DataResponse.We have many such big
length named queues. So when we try to move a message sent to ActiveMQ.DLQ
back to our queue having big name length using 'Move' Message action, the
That is what I will do, then. Thanks for the help.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Using-the-command-line-tools-to-delete-multiple-messages-at-once-tp4668643p4668854.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Hello:
I'm newbie with Apache ActiveMQ and
I've started using 5.8.0 release + Spring
I want that every session created in a servlet container ( Tomcat ),
subscribes itself as consumer/listener for message from a Topic ( created
into JMS broker by an admin )
I've got some questions:
If I've
or if you'd like you can patch the current tools and submit it :)
On Wed, Jul 3, 2013 at 2:53 PM, ccharbonneau ccharbonn...@mindoka.comwrote:
That is what I will do, then. Thanks for the help.
--
View this message in context:
Those might be good questions to ask in the Spring forum?
On Wed, Jul 3, 2013 at 3:11 PM, Jose María Zaragoza demablo...@gmail.comwrote:
Hello:
I'm newbie with Apache ActiveMQ and
I've started using 5.8.0 release + Spring
I want that every session created in a servlet container ( Tomcat
looks like the size is 80 for truncation.. your destination names longer
than 80 chars?
either can increase the length=80 size or use form:text
cheers
On Wed, Jul 3, 2013 at 2:51 PM, Prashant prash...@in.ibm.com wrote:
I am facing a small problem. Names of queues we are using are very big in
You're right.
I hoped an answer based on experience of ActiveMQ users
2013/7/3 Christian Posta christian.po...@gmail.com
Those might be good questions to ask in the Spring forum?
On Wed, Jul 3, 2013 at 3:11 PM, Jose María Zaragoza demablo...@gmail.com
wrote:
Hello:
I'm newbie with
Hello:
I'm using ActiveMQ 5.8.0
I'm confused about what cache means in PooledConnectionFactory?
For example
when it's said connection is cached, does it mean that the same
connection is shared between threads ? or it's only a pool of connection
what is borrowed by PooledConnectionFactory
to
Today I have tested STOMP suppport in apache-activemq-5.9-20130609.
Using jms-object-xml works fine, but when I try to receive a
jms-map-xml message, a org/xmlpull/v1/XmlPullParserException is thrown.
The same test code also works well with ActiveMQ 5.8.0.
Is there a way to get additional
21 matches
Mail list logo
