Sha256: 4a8ec88bfa618e8c199df98de0677e3da516841c05a9215736418b8aa2d275f5
Contents?: true
Size: 1.02 KB
Versions: 12
Compression:
Stored size: 1.02 KB
Contents
require 'stomp'
# TODO: Recover from a disconnect!
initialization do
user = COMPONENTS.stomp_gateway[:user] || ""
pass = COMPONENTS.stomp_gateway[:pass] || ""
host = COMPONENTS.stomp_gateway[:host] || "localhost"
port = COMPONENTS.stomp_gateway[:port] || 61613
::StompGatewayConnection = Stomp::Client.open(user, pass, host, port)
subscriptions = COMPONENTS.stomp_gateway["subscriptions"]
ahn_log.stomp_gateway "Connection established. Subscriptions: #{subscriptions.inspect}"
Events.register_namespace_name "/stomp"
subscriptions.each do |subscription|
Events.register_namespace_name "/stomp/#{subscription}"
::StompGatewayConnection.subscribe subscription do |event|
Adhearsion::Events.trigger ["stomp", subscription], event
end
end
end
methods_for :global do
def send_stomp(destination, message, headers={})
::StompGatewayConnection.send(destination, message, headers)
end
end
# In the future, I may add a methods_for(:events) method which allows synchronous messaging.
Version data entries
12 entries across 12 versions & 6 rubygems