Re: How can I convert message from MQTTTransport?
Hello, I'm using 5.10-SNAPSHOT. I think this issue is fixed around 9735806. Old version of MQTT plugin does not convert topic name properly. Regards, Masanori -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-convert-message-from-MQTTTransport-tp4680383p4680771.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: How can I convert message from MQTTTransport?
Here you are. https://github.com/apache/activemq/commit/973580603097f5e620e4d7f375dbb3581c84 -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-convert-message-from-MQTTTransport-tp4680383p4680773.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Shared File System Master/Slave with DRBD
Hey Mark, You should be able to use drbd with something like NFS without a problem. The LINBIT engineers are in the process publishing an NFS Tech guide... For current official documentation, feel free to contact me directly. Best Regards, Greg -- : Greg Eckert : g...@linbit.com : Not an Engineer : LINBIT | Your Way to High Availability : Web: http://www.linbit.com
Re: ActiveMQ 5.9.1 +MQTT
It is possible to implement IBM type of HA solution with ActiveMQ. 1. ActiveMQ MQTT has problem with same clientid reconnection. As per MQTT definition, same clientID should replace existing connection. When I tried MQTT client reconnection and failover, there were many challenges. 2. Problems of MQTT client getting disconnected over network of brokers. I couldn't find exact reason for it. Let me know if you find any specific problem. I might have faced before and can help. -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-5-9-1-MQTT-tp4680744p4680768.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Unable to connect when trying to use mqtt
Hi, As Tim told, use MQTT client instead of generic one. Try Mosquito pub/sub client. If you want JAVA try out Hiram's MQTT client / Eclipse Paho MQTT client. -- View this message in context: http://activemq.2283324.n4.nabble.com/Unable-to-connect-when-trying-to-use-mqtt-tp4680645p4680769.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: How can I convert message from MQTTTransport?
Can you please give me reference link ? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-convert-message-from-MQTTTransport-tp4680383p4680772.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: How can I convert message from MQTTTransport?
Hi, MQTT wildcard currently bypasses Authentication /Authorization. I created JIRA for it. https://issues.apache.org/jira/browse/AMQ-5160 Have you developed any patch ? -- View this message in context: http://activemq.2283324.n4.nabble.com/How-can-I-convert-message-from-MQTTTransport-tp4680383p4680770.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Upgrade from 5.5.1 to 5.9
Hi,I am working with AMQ 5.5.1 and want to upgrade to 5.9What is the procedure? -- View this message in context: http://activemq.2283324.n4.nabble.com/Upgrade-from-5-5-1-to-5-9-tp4680775.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Stomp websocket disconnect after 10 sec (first Ping)
Hi I need some assistance... my stomp client disconnect after the first ping (that happens in 10 seconds) and I can’t figure out why! Does anyone have an idea of what could be happening? The disconnection happens in any connection even in the Stomp websocket example (apache-activemq-5.9.1\examples\stomp\websocket\index.html). No matter what, after the first ping the connection is finished. Before the first ping it works perfectly fine to send and receive messages. The ativity I can see : In the ActiveMQ admin - the queue or topic is created and the consumer is there for the first 10 seconds (first ping) after that the number of consumers become 0 Problem reported in the Debug Log – after the ping it waits more 20 seconds and present the following message: “did not receive server activity for the last 20842ms Whoops! Lost connection to ws://localhost:61614/” Problem reported in the CMD – WARN | Transport Connection to: StompSocket_26536577 failed: java.io.IOException Exception in thread ActiveMQ InactivityMonitor Worker java.lang.NullPointerException at org.apache.activemq.transport.AbstractInactivityMonitor.onException(AbstractInactivityMonitor.java:314) at org.apache.activemq.transport.AbstractInactivityMonitor$4.run(AbstractInactivityMonitor.java:215) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) I have already tried to make “time out = 0” changing the wireFormat (bellow). I also have tried to find something to disable InactivityMonitor, ping or heartbeating but I couldn’t find anything else. transportConnector name=openwire uri=tcp://0.0.0.0:61616?wireFormat.maxInactivityDuration=0/ transportConnector name=amqp uri=amqp://0.0.0.0:5672/ transportConnector name=stomp uri=stomp://0.0.0.0:61613/ transportConnector name=mqtt uri=mqtt://0.0.0.0:1883/ transportConnector name=ws uri=ws://0.0.0.0:61614/ Environment/ system: • Activemq 5.9.1 • Windows 7 32bits • Jdk7 up 55 • Stomp • Jquery 1.7.2. Does anyone have an idea of what could be happening? -- View this message in context: http://activemq.2283324.n4.nabble.com/Stomp-websocket-disconnect-after-10-sec-first-Ping-tp4680767.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: delay failover transfer
Why would the client want to keep trying the master for a little while rather than immediately jump to the first available broker? If the client really needs custom logic on connection failure, sounds like using the failover transport may not be the answer. -- View this message in context: http://activemq.2283324.n4.nabble.com/delay-failover-transfer-tp4680504p4680788.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Shared File System Master/Slave with DRBD
Greg, Thanks for the reply. I just wanted to confirm a couple of things. 1) The NFS requirement is so that DRBD can be used in Primary/Primary mode as the file system needs to be writeable from both nodes? 2) With NFS I would also need to use Pacemaker to make the NFS server HA? 3) Is the NFS Tech Guide listed at http://www.linbit.com/en/downloads/tech-guides what you are referring to? Thanks, Mark On 1 May 2014 00:34, Greg Eckert g...@linbit.com wrote: Hey Mark, You should be able to use drbd with something like NFS without a problem. The LINBIT engineers are in the process publishing an NFS Tech guide... For current official documentation, feel free to contact me directly. Best Regards, Greg -- : Greg Eckert : g...@linbit.com : Not an Engineer : LINBIT | Your Way to High Availability : Web: http://www.linbit.com
can't see DLQ_DELIVERY_FAILURE_CAUSE_PROPERTY in webconsole.
Is there a way to see why message failed on listener and endup in DLQ. I dont see any property for message in webconsole. Is there a way to enable that. I also tried hawtio to view property but no luck. I also tried to set property for message in listner upon catching exception; still no luck.
AmqpProtocolException: Could not decode AMQP frame
My set up is as follows: 1. Broker - ActiveMQ running with amqp enabled mode 2. Publisher - using qpid jms client for AMQP 1.0 2. Consumer - using qpid jms client for AMQP 1.0 Intermittently if I see that when I start consumers, it is not able to connect to the broker. When I check ActiveMQ log, it shows the following stack trace ( I have looked all over and not able to find any hint). Note that it does not always happen: INFO | jvm 1| 2014/05/01 14:23:31 | WARN | Transport Connection to: tcp://127.0.0.1:49327 failed: java.io.IOException INFO | jvm 1| 2014/05/01 14:23:31 | org.apache.activemq.transport.amqp.AmqpProtocolException: Could not decode AMQP frame: hex: 003d025310c03004a12434383862363165632d646365362d343134612d626561342d62393834363364643164356640716000ff INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:227) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:217) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:96) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) INFO | jvm 1| 2014/05/01 14:23:31 | at java.lang.Thread.run(Unknown Source) INFO | jvm 1| 2014/05/01 14:23:31 | Caused by: org.apache.qpid.proton.engine.TransportException: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting 41. In state: HEADER0 INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.TransportResultFactory$TransportResultImpl.checkIsOk(TransportResultFactory.java:116) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.TransportImpl.input(TransportImpl.java:202) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:224) INFO | jvm 1| 2014/05/01 14:23:31 | ... 6 more INFO | jvm 1| 2014/05/01 14:23:31 | Caused by: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting 41. In state: HEADER0 INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.FrameParser.input(FrameParser.java:122) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.FrameParser.process(FrameParser.java:502) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.TransportImpl.process(TransportImpl.java:1213) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.TransportImpl.processInput(TransportImpl.java:1175) INFO | jvm 1| 2014/05/01 14:23:31 | ... 8 more -- View this message in context: http://activemq.2283324.n4.nabble.com/AmqpProtocolException-Could-not-decode-AMQP-frame-tp4680794.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: AmqpProtocolException: Could not decode AMQP frame
On 05/01/2014 06:22 PM, gurilubana wrote: My set up is as follows: 1. Broker - ActiveMQ running with amqp enabled mode 2. Publisher - using qpid jms client for AMQP 1.0 2. Consumer - using qpid jms client for AMQP 1.0 Intermittently if I see that when I start consumers, it is not able to connect to the broker. When I check ActiveMQ log, it shows the following stack trace ( I have looked all over and not able to find any hint). Note that it does not always happen: INFO | jvm 1| 2014/05/01 14:23:31 | WARN | Transport Connection to: tcp://127.0.0.1:49327 failed: java.io.IOException INFO | jvm 1| 2014/05/01 14:23:31 | org.apache.activemq.transport.amqp.AmqpProtocolException: Could not decode AMQP frame: hex: 003d025310c03004a12434383862363165632d646365362d343134612d626561342d62393834363364643164356640716000ff INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:227) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onAMQPData(AmqpProtocolConverter.java:217) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpTransportFilter.onCommand(AmqpTransportFilter.java:96) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) INFO | jvm 1| 2014/05/01 14:23:31 | at java.lang.Thread.run(Unknown Source) INFO | jvm 1| 2014/05/01 14:23:31 | Caused by: org.apache.qpid.proton.engine.TransportException: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting 41. In state: HEADER0 INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.TransportResultFactory$TransportResultImpl.checkIsOk(TransportResultFactory.java:116) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.TransportImpl.input(TransportImpl.java:202) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.activemq.transport.amqp.AmqpProtocolConverter.onFrame(AmqpProtocolConverter.java:224) INFO | jvm 1| 2014/05/01 14:23:31 | ... 6 more INFO | jvm 1| 2014/05/01 14:23:31 | Caused by: org.apache.qpid.proton.engine.TransportException: AMQP header mismatch value 0, expecting 41. In state: HEADER0 INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.FrameParser.input(FrameParser.java:122) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.FrameParser.process(FrameParser.java:502) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.TransportImpl.process(TransportImpl.java:1213) INFO | jvm 1| 2014/05/01 14:23:31 | at org.apache.qpid.proton.engine.impl.TransportImpl.processInput(TransportImpl.java:1175) INFO | jvm 1| 2014/05/01 14:23:31 | ... 8 more -- View this message in context: http://activemq.2283324.n4.nabble.com/AmqpProtocolException-Could-not-decode-AMQP-frame-tp4680794.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. What versions ? -- Tim Bish Sr Software Engineer | RedHat Inc. tim.b...@redhat.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/
Re: AmqpProtocolException: Could not decode AMQP frame
Versions: 1. ActiveMQ - 5.9.1 2. Qpid Jms Client for AMPQ 1.0 - version 0.26 -- View this message in context: http://activemq.2283324.n4.nabble.com/AmqpProtocolException-Could-not-decode-AMQP-frame-tp4680794p4680798.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: AmqpProtocolException: Could not decode AMQP frame
On 05/01/2014 06:47 PM, gurilubana wrote: Versions: 1. ActiveMQ - 5.9.1 2. Qpid Jms Client for AMPQ 1.0 - version 0.26 -- View this message in context: http://activemq.2283324.n4.nabble.com/AmqpProtocolException-Could-not-decode-AMQP-frame-tp4680794p4680798.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. That's an odd one, the tests are using the QPid 0.26 client and everything seems ok there. -- Tim Bish Sr Software Engineer | RedHat Inc. tim.b...@redhat.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/
