activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akhettar <ayache.khet...@gmail.com>
Subject I can connect successfully to Artemis using Stomp Ruby client but can't publish messages
Date Wed, 07 Oct 2015 20:49:22 GMT
Hi

I am using Artemis 1.1.0 version and I am unable to send/publish messages to
Artemis using Ruby stomp client - see below code snippet. I have also tried
other protocols such as AMQP, MQTT none are working. I can successfully
connect (connection is established), but when I publish the message nothing
gets published or sent to the queue. I am not seeing anything in the logs
visible  to indicate what's wrong. However if I switch to Apache ActiveMQ
(any version, the latest works too) the below client works fine. Also,
openwire connections works when using JMeter for example.

Have I missed anything? Your help is very much appreciated.

Regards,

Ayache


*Log output at the start up of Artemis:*

21:31:10,145 INFO  [org.apache.activemq.artemis.integration.bootstrap]
AMQ101000: Starting ActiveMQ Artemis Server
21:31:10,167 INFO  [org.apache.activemq.artemis.core.server] AMQ221000: live
Message Broker is starting with configuration Broker Configuration
(clustered=false,journalDirectory=./data/journal,bindingsDirectory=./data/bindings,largeMessagesDirectory=./data/large-messages,pagingDirectory=./data/paging)
21:31:10,199 INFO  [org.apache.activemq.artemis.core.server] AMQ221013:
Using NIO Journal
21:31:10,251 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-server]. Adding protocol support for: CORE
21:31:10,255 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-amqp-protocol]. Adding protocol support for:
AMQP
21:31:10,266 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-hornetq-protocol]. Adding protocol support
for: HORNETQ
21:31:10,268 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-mqtt-protocol]. Adding protocol support for:
MQTT
21:31:10,272 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-openwire-protocol]. Adding protocol support
for: OPENWIRE
21:31:10,402 INFO  [org.apache.activemq.artemis.core.server] AMQ221043:
Protocol module found: [artemis-stomp-protocol]. Adding protocol support
for: STOMP
21:31:10,990 INFO  [org.apache.activemq.artemis.core.server] AMQ221003:
trying to deploy queue jms.queue.DLQ
21:31:11,056 INFO  [org.apache.activemq.artemis.core.server] AMQ221003:
trying to deploy queue jms.queue.ExpiryQueue
21:31:11,181 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at 0.0.0.0:5672 for protocols [AMQP]
21:31:11,184 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at 0.0.0.0:5445 for protocols [STOMP,HORNETQ]
21:31:11,187 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at 0.0.0.0:1883 for protocols [MQTT]
21:31:11,189 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at 0.0.0.0:61616 for protocols
[STOMP,MQTT,AMQP,OPENWIRE,HORNETQ,CORE]
21:31:11,191 INFO  [org.apache.activemq.artemis.core.server] AMQ221020:
Started Acceptor at 0.0.0.0:61613 for protocols [STOMP]
21:31:11,191 INFO  [org.apache.activemq.artemis.core.server] AMQ221007:
Server is now live

*RUBY STOMP CLIENT*

require 'test/unit'
require 'openssl-extensions'
require 'amqp'
require 'onstomp'

class MyTest < Test::Unit::TestCase

  # Called before every test method runs. Can be used
  # to set up fixture information.

  def setup

  end

  # Called after every test method runs. Can be used to tear
  # down fixture information.

  def teardown
    # Do nothing
  end

  # Fake test
  # def test_artemis_mqtt
  #   EventMachine.run do
  #     connection = AMQP.connect(:host => '127.0.0.1', :user =>'admin',
:pass =>'admin')
  #     puts "Connected to AMQP broker. Running #{AMQP::VERSION} version of
the gem..."
  #
  #     channel  = AMQP::Channel.new(connection)
  #     queue    = channel.queue("PMR2MB", :auto_delete => true)
  #     exchange = channel.direct("")
  #
  #     queue.subscribe do |payload|
  #       puts "Received a message: #{payload}. Disconnecting..."
  #       connection.close { EventMachine.stop }
  #     end
  #
  #     exchange.publish "Hello, world!", :routing_key => queue.name
  #   end
  #
  # end

  def test_onStomp_client
    puts "Starting demo"
    puts "----------------------------"

    running = true
    client = OnStomp::Client.new("stomp://127.0.0.1:61613")
    client.connect

    puts "Connected to broker using protocol #{client.connection.version}"

    client.subscribe("/queue/onstomp_test") do |message|
      puts "Received: '#{message.body}'"
      if message.body == 'finished'
        running = false
      end
    end

    client.send("/queue/onstomp_test", "hello world")
    client.send("/queue/onstomp_test", "this is a simple demo of onstomp")
    client.send("/queue/onstomp_test", "finished")

    Thread.pass while running
    client.disconnect
    puts "----------------------------"
    puts "End of demo"
  end
end



--
View this message in context: http://activemq.2283324.n4.nabble.com/I-can-connect-successfully-to-Artemis-using-Stomp-Ruby-client-but-can-t-publish-messages-tp4702742.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.

Mime
View raw message