java - Cannot publish to Queue on ActiveMQ on Linux -
I am trying to publish a message in a queue on ActiveMac installed on Ubuntu 12.04. I can publish ActiveMQ on Windows without any problem, but I can not publish it on Ubuntu if I am creating a message from the console, I can consume it.
When I look at the AMQP dump on the wirehark, I see the following message: "Trying to get an unsigned integer with 42 latitude". And the server is running on JDK 1.6
Here is my code:
Public Zero addMessage (string text) Exception {TextMessage msg = session.createTextMessage (text) throws; Msg.setStringProperty ("weird", "no"); MsgProducer.send (MSG); } Private zero init () throws exceptions {ConnectionFactoryImpl factory = new connectionfitter IMPL (host, port, user, password); Connection = factory.createConnection (user, password); Connection.start (); Session = connection.create session (false, session. AUTO_ACKNOWLEDGE); Destination destination = new qiimple (queue); MsgProducer = session.createProducer (dest); MsgProducer.setDeliveryMode (DeliveryMode.PERSISTENT); }
Problems by copying your working version of ActiveMac on Windows (5 .10.0) My Linux server (which was version 5.10.1 installed), and it worked I still do not know what the original problem was ...
Comments
Post a Comment