используя ruby ​​и stomp для записи сообщений в ActiveMQ - PullRequest
Новая
       10

используя ruby ​​и stomp для записи сообщений в ActiveMQ

4 голосов
/ 08 ноября 2011

Я использую stomp для записи сообщений в ActiveMQ из Ruby.Я следую примеру на http://calliopesounds.blogspot.com/2009/07/working-ruby-stomp-example.html

Но я получаю ошибку ниже, не уверен, что не так 

/Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:462:in `write': Invalid argument (Errno::EINVAL)
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:462:in `puts'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:462:in `_transmit'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:462:in `each'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:462:in `_transmit'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:445:in `synchronize'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:445:in `_transmit'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:427:in `transmit'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/connection.rb:267:in `publish'
    from /Library/Ruby/Gems/1.8/gems/stomp-1.1.10/lib/stomp/client.rb:200:in `publish'
    from utils.rb:10

вот сценарий 

require 'rubygems'
require 'stomp'

queue = "/queue/msg.in"

puts "Producer for queue #{queue}"

client = Stomp::Client.open "stomp://localhost:61616"
puts client
client.publish queue, "hello!"
client.close

1 Ответ

5 голосов
/ 08 ноября 2011

Это может быть не вашей конкретной проблемой, но, поскольку код блокирует отправку, это может быть чем-то похожим.

По умолчанию localhost: 61616 - это место, где AMQ-брокер прослушивает соединения openwire. Вы поменяли брокера xml config на использование stomp на этом порту? Конфиг должен иметь такую ​​запись: 

<transportConnectors>
   <transportConnector name="stomp" uri="stomp://localhost:61613"/>
</transportConnectors>
...