RE: Scala "Wire format" error on Receive from Queue

2020-02-25 Thread Justin Taylor
I (mistakenly) assumed that the ActiveMQ port was the same regardless of the client. I changed to port 61616 and it connected. Thank you -Original Message- From: Timothy Bish [mailto:tabish...@gmail.com] Sent: Tuesday, February 25, 2020 3:46 PM To: users@activemq.apache.org Subject:

Re: Scala "Wire format" error on Receive from Queue

2020-02-25 Thread Timothy Bish
On 2/25/20 4:32 PM, Justin Taylor wrote: I have ActiveMQ running on a server. I can connect from my PC using Python stomp. With Scala, I get this error: Exception in thread "main" javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. I copied the Scala

Scala "Wire format" error on Receive from Queue

2020-02-25 Thread Justin Taylor
I have ActiveMQ running on a server. I can connect from my PC using Python stomp. With Scala, I get this error: Exception in thread "main" javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. I copied the Scala "Receive from Queue" sample from the Cross

Re: ActiveMQ v5 plugin migration to Artemis

2020-02-25 Thread David Martin
Hi Justin, Having pulled the code and run some tests I found that, The good news is : 1. Can already override the Filter in beforeCreateConsumer() and verified this works 2. Can already override message content & headers in beforeSend() as per existing broker plugin example What's missing in or