Hi guys
I am Wang and I facing problem when i configured MQTT master-slave using
activeMQ 5.12
I have three servers: 10.80.1.1, 10.80.1.2, 10.80.1.3
I deployed default activeMQ instance onto 10.80.1.2, 10.80.1.3.
And I added the following networkConnectors to server 10.80.1.1
twork connection between vm://10.80.1.3#180 and
tcp://10.80.1.1:61616 (10.80.1.1) has been established.
Thank you Tim.
Do you know why I got the error above?
Regards,
Wang
On 2015年09月01日 21:42, Tim Bain wrote:
Why have you configured 10.80.1.1 to connect to itself, and why are 2 and 3
default conf
donot know how to
configure a network of brokers, so I tried to use master/slave configure.
I want a network of brokers working with load balancer with single
outside IP address.
Thanks,
Wang
On 2015年09月01日 23:05, Tim Bain wrote:
Are you trying to have a master/slave cluster (where only
mqtt_03 10.80.1.3:1883 check
It works well as a cluster of mqtt brokers.
Thank you very much again.
Wang
On 2015年09月02日 00:26, Tim Bain wrote:
In that case, you'll want each broker connected simultaneously to both the
other two brokers (but not to themselves!), using the static transport
You can see more details here: https://apachecon.com/acasia2023/cfp.html.
Best,
Dianjin Wang
Environment: ActiveMQ 5.2, JBoss 5.1GA, JDK 5
I have configured the integration of JBoss and ActiveMQ(The embedded
broker), in my test, a db update and jms message sending will be acted in
one JTA transaction, I found the JMS message was still sent to ActiveMQ even
the DB update is failed, so the
I find it
only can't provide the XA interface, it only has the class of
"org.apache.activemq.ra.ActiveMQConnectionFactory", no XA related class
existed. So I am confused how to get the XA resources in RA. Hope someone
can help me.
Neo Wang wrote:
>
> Environment: ActiveMQ
gt; contracts will take care of the rest.
>
> 2009/8/31 Neo Wang
>
>>
>> Additional information:
>> I find the ActiveMQ provides the class of
>> "org.apache.activemq.ActiveMQXAConnectionFactory" to support XA, but for
>> me,
>> because I must i
In fact, I have read these documents and followed the related configuration,
but the result is still failed. The following is the details:
1. The content of activemq-ds.xml
http://www.jboss.org/j2ee/dtd/jboss-ds_1_5.dtd";>
trading/QueueConnectionFactory
a
I have the same problem as you, and our environment is same. I am also trying
to find out the reason. Any progress about it?
Seyfula I. Seyfula wrote:
>
> Environment: ActiveMQ 5.2, JBoss 5.1GA
>
> Hello
>
> I have problem trying to send messages from EJB 3.0 bean from JBoss to
> ActiveMQ. I
I have tried almost all of the ways, but the result is failed, can anyone
help me?
Neo Wang wrote:
>
> Environment: ActiveMQ 5.2, JBoss 5.1GA, JDK 5
>
> I have configured the integration of JBoss and ActiveMQ(The embedded
> broker), in my test, a db update and jms message
Have you commented the "org.jboss.ejb.plugins.MetricsInterceptor"
in jboss.xml?
Seyfula I. Seyfula wrote:
>
> Environment: ActiveMQ 5.2, JBoss 5.1GA
>
> Hello
>
> I have problem trying to send messages from EJB 3.0 bean from JBoss to
> ActiveMQ. I receive the following error: Transaction 'XI
Environment: JDK1.5, JBoss 5.1.0GA, ActiveMQ 5.2.0(Embedded broker in JBoss)
My test program is very simple, a MDB is deployed in JBoss to receive a
message from the queue, and send the message to a topic after receiving it.
I followed all of the configuration steps in apache
website[http://activ
Now I am using the ActiveMQ 5.2, but I found some issues in this version, how
can I get the updated patch from the SVN? Thanks.
--
View this message in context:
http://www.nabble.com/How-can-I-get-the-patch-from-the-SVN--tp25274139p25274139.html
Sent from the ActiveMQ - User mailing list archive
I have tried this version, but it doesn't work for some of XA transaction
problem integrated with JBoss AS 5, you can find my questions in the first
page of this forum, anyway, thanks a lot.
Neo Wang wrote:
>
> Now I am using the ActiveMQ 5.2, but I found some issues in this ver
Environment: JDK 1.5, ActiveMQ 5.2, JBoss 5.1 GA, Oracle 10g
My test case is send a message to queue and then save the data in DB in one
transaction, all of the them are finished a EJB2.1 stateless session bean,
the transaction is "Required", I have configured the AMQ as embedded broker,
all of
wise, the operation can't be finished successfully. One
exception like "you must close the ActiveMQ connection" is throw.
Neo Wang wrote:
>
> Environment: JDK 1.5, ActiveMQ 5.2, JBoss 5.1 GA, Oracle 10g
>
> My test case is send a message to queue and then save the dat
I want to send message to AMS and update date to DB in one transaction, so I
find the AMQ provides the RA to support it, but after searching all of the
documents, I only can find the configuration for embedded broker, my
question is, can I only use the RA to handle the XA transaction in the
config
Environment: JBoss 5.1GA, Active MQ 5.2 embeded broker configuration
I want to send a message to a topic when receiving one message in a MDB, but
it can't be successful all the time, any one can help me? I have struggled
in it about 2 weeks.
It is my sample code:
package com.trading.platform.ej
Thanks a lot for your information. I have found the solution to resolve the
problem, you can try to change the value of "UseInboundSession" to "true"
from "false" in ra.xml, then you will find it is OK. But the disadvantage of
this solution is you cannot use this configuration outside of MDB, othe
As we known, in a single AMQ node environment, we can set the value of
"" in " " to a physical IP in
activemq-ds.xml, for example, "tcp://10.10.135.212".
But for a cluster environment, for example , a broker cluster grouped by 2
nodes of 10.10.135.211 and 10.10.135.212, how to define it in configu
*as hints or suggestiones are more than weclome!*
*With below setting (at activemq.xml )*
*Set Time to Live does not work, *
*Set DeadLetterQueue for exceeding maximum redelivery also does not work *
*The settings are from below documents *
*http://activemq.apache.org/message-redelivery-and-d
i also changed code a little bit, first example code works, second example
code does not work
### it works for redelivery ###
RedeliveryPolicy queuePolicy =connectionFactory.getRedeliveryPolicy();
queuePolicy.setInitialRedeliveryDelay(0);
queuePolicy.setRedeliveryDelay(3000);
queuePolicy.setUseEx
Hi,
I am using Jboss 4.0.4, oracle, and activemq 4.1.1 JDBC master/salve.
I am using activemq-rar-4.1.1.rar under my deploy/ folder.
broker configuration is as:
My problem is : After master server launched successfully. My slave server
is halt when try to Attempting to acquire the exc
Hi,
I use jboss 4.0.4 + activemq 4.1.1 JDBC Master /slave without Journal
framework.
I noticed when there are a lot of data , just say 1000 rows in the table
"activemq_msgs", the broker will take long time to start up .
Could you tell me what the reason is and how to resolve this ?
Since i
Hi, I am a fresh to ActiveMQ, this is my first time to build it, hope anyone
can help me.
I checked out the code from the repository today, and use the command: mvn
-Dmaven.test.skip=true install to build the code, but it failed, the detail
error log is as follows:
[INFO]
Oh, I got the same error with you...
Is there anyone can help us?
liuxiaoming wrote:
>
> [INFO] Preparing eclipse:eclipse
> Downloading:
> http://agilejava.com/maven//com/agilejava/docbkx/docbkx-maven-plugi
> n/2.0.3-SNAPSHOT/docbkx-maven-plugin-2.0.3-SNAPSHOT.pom
> Downloading:
> http://people
hi, all~
i met "java.lang.OutOfMemoryError: Java heap space" error while
starting an activemq broker. I am using: apache-activemq-5.6.0-win
The broker was configured for persistent storage using oracle
database. The broker could start normally, then i mannally created an
queue and input some per
i'm using the 5.8.0-snapshot, my setting:
And i got:
2012-10-22 16:10:45,674 | DEBUG | SampleJavaV3_subscribe MQTT Connection
using heart beat of 60 secs |
org.apache.activemq.transport.mqtt.MQTTProtocolConverter | ActiveMQ
Transport: tcp:///124.127.108.134:7442@1883
2012-10-22 16:10:45,699 |
Thanks, i'm working on it.
On Oct 26, 2012, at 4:12 AM, ceposta [via ActiveMQ]
wrote:
> Charles,
> wireFormat.maxInactivityDuration won't work for MQTT
> Can you try on the latest snapshots using the KeepAlive setting in the
> client?
>
> On Mon, Oct 22, 2
If only the index files are stale you can try to remove all index files
(*.data) and restart the broker to rebuild the index.
The broker will get stopped when IO exception occurs so new messages are
unable to enqueue the broker in fact.
At 2013-03-10 00:59:13,jcamus wrote:
>Thanks for your answe
Yes, you can assume that works.
It seems you want your message flow to be split into two message flows, one
for
the lower priority messages while the other for the higher priority
messages
and you want they are stuck on two 'exclusive' consumers respectively.
For the sparse selector In one word ,
The non-durable retroactive consumer of Topic will do the trick.
http://activemq.apache.org/retroactive-consumer.html
Only one condition is not satisfied,messages can not survive from the
restart of the broker.
2013/5/2 Andrea Arcuri
> Hi,
> I am new to ActiveMQ. Reading documentation and pla
+1
2013/5/7 Yi Pan
> Hi, Christian,
>
> Thanks for the quick response. However, the stats and its explanation is
> still very confusing to me.
>
> The standard explanation of Enqueue Count - the total number of messages
> sent to the queue since the last restart. That's counting the action of
>
hi,everyone:
i have some problem to handle blobmessage.
My environments are:
Tomcat 6.0
Apache FTPServer 1.0.6
ActiveMQ 5.8.0
ActiveMQ message trans type is: publish/subcribe
now, i have a producer of publisher with topic and blobmessage,session mode
persistent,auto acknowledge.
the file size ab
hi,
The ICS's port is 61616, that is isolated.
And the ICS's port cant be changed.
so change ur ActiveMQ port to others..
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-start-failed-tp4670702p4670714.html
Sent from the ActiveMQ - User mailing list archive at Nab
hi,everyone:
i have some problems to handle blobmessage.
My environments are:
Tomcat 6.0
Apache FTPServer 1.0.6
ActiveMQ 5.8.0
ActiveMQ message trans type is: publish/subcribe
now, i have a producer of publisher with topic and blobmessage,session mode
persistent,auto acknowledge.
the file size a
all cusumers subcribe the topic,and then delete the file.
how can i do.
thanks again..
peek at the unit tests for example usage. in particular -
https://github.com/apache/activemq/blob/trunk/activemq-unit-tests/src/test/java/org/apache/activemq/blob/FTPBlobTest.java
On 27 August 2013 08:45, Jinglong
broker plugin if you can make it work.
On 29 August 2013 06:18, Jinglong Wang wrote:
thank u Tully
i have seen the test case before,but it not point to the producer how to get
the all of consumers' amount with consumed the message.
in our project, cusumers subcribe the topics, producer dont
haha!
在 2013-9-9 下午9:39，"HellKnight" 写道：
> I feel a little shamed...The problem is actually simple : I am using async
> sending , but I did not register any exception listener for the connection
> I
> used
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Is-there-
Pure master/slave is departed in later releases and wont get supported any
more.
You should consider other cluster topology.
2013/12/3 赵振华 ZhenhuaZhao
> hi,all
> I’m a newbie in activemq.
>I use active-5.5.5 on rhel5.4 X86_64 in pure master/slave mode.
> I leave master’s config
NoSpaceException is also a response come from broker.
when asyn send is used,client will not expect response for request.
You can try to use non-transactional session or enforce sync send and that
should work.
2014-02-20 7:04 GMT+08:00 Gary Tully :
> It looks like you are using async send so th
What's message ack mode you're using?
If your consumer does not acknowledge messages that have been processed,
eg, you may forget to manual ack message when using client ack mode or
forget to commit session when using transaction,
those messages will be redelivered when consumer or broker gets rest
It's hard to enumerate differences between them, even for developers.
You'd better to create a similar test case to see what's up inside broker,
here are some examples,
https://git-wip-us.apache.org/repos/asf?p=activemq.git;a=blob_plain;f=activemq-core/src/test/java/org/apache/activemq/transport/di
Yes,that help performance but once broker gets restarted,it will take
longer time to complete index recovery.
Here is a guide that may help you to tune performance,
https://access.redhat.com/site/documentation/en-US/JBoss_A-MQ/6.0/html/Tuning_Guide/files/PersTuning-KahaDB.html
2014-02-13 19:49 GM
Seems what you really want to solve is to distribute real task messages
evenly between consumers.
As default a consumer has a prefetch to allow broker to push messages to it
in batch manner,
if a consumer is slow to process message then many pending messages will be
accumulated
and other consumers
BTW,AUTO_ACKNOWLEDGE can not guarantee once and only once semantic since
the ack is sent async.
You can image such a case when your consumer has succeeded in processing a
message
while the consumer application is crashed before the ack is sent, you will
receive that message again if your applicatio
Can you try to disable cache consumer option?
Or can you use a plain jms consumer to try to reproduce the issue?
Just guess it's maybe related with cache consumer and spring jms template.
2014-03-29 4:19 GMT+08:00 lookers :
> Just checked the queuesize and it is increasing when it is blocked.
>
If you have existing messages in the broker and add consumers at a later
stage, it is a good idea to delay message dispatch start until all
consumers are present (or at least to give enough time for them to
subscribe). If you don't do that the first consumer will probably acquire
all message groups
Hi,
I have a user case:
our data is time sensitive, and I need to store every 10 minutes data into
a separate queue(topic?) so that at the end of each 10 minute, multiple
consumers can start to process only that past 10 minutes queue.
I have a central webservice that is responsible for the
manage
d 1:1
Best regards,
Leung Wang Hei
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Network-bridge-throughput-capped-at-default-Socket-buffer-size-tp4696643.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Tim,
I have used "transport.socketBufferSize=x" in transport connector broker A
and only "?socketBufferSize=x" in broker B network connector. When x=-1,
warning is raised in MQ log:
/[WARN ] org.apache.activemq.network.DiscoveryNetworkConnector - Could not
start network bridge between:
vm://acti
Hi Tim,
Here are the OS config:
*Broker A*
$ cat /proc/sys/net/ipv4/tcp_rmem
409687380 16777216
$ cat /proc/sys/net/ipv4/tcp_wmem
409687380 16777216
*Broker B*
$ cat /proc/sys/net/ipv4/tcp_rmem
409687380 16777216
$ cat /proc/sys/net/ipv4/tcp_wmem
409687380 16777216
As in
Anyone else encountered the same problem?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Static-network-connector-with-message-selector-tp4664389p4664657.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
We have a tool to hook to a well-known topics to receive logging from all
applications. Now we would like to reuse this topic to monitor some special
logging (e.g. network bridge down) of ActiveMQ itself.
Enabling jms appender in log4j.properties (see below) always causes start up
error:
*log4
55 matches
Mail list logo
