Class: AngieCoreApi::Message::StompClient

Inherits:

Object

• Object
• AngieCoreApi::Message::StompClient

Includes:

Concurrent::Async

Defined in:

lib/angie-core-api/message/stomp_client.rb

Instance Method Summary

• #initialize ⇒ StompClient constructor

  A new instance of StompClient.

• #publish(queue, data) ⇒ Object
• #subscribe(queue) ⇒ Object

Constructor Details

#initialize ⇒ StompClient

Returns a new instance of StompClient.

# File 'lib/angie-core-api/message/stomp_client.rb', line 10

def initialize
  config  = HashWithIndifferentAccess.new(AngieCoreApi.configuration.activemq)
  @client = Stomp::Client.new(config)
end

Instance Method Details

#publish(queue, data) ⇒ Object

# File 'lib/angie-core-api/message/stomp_client.rb', line 15

def publish(queue, data)
  @client.publish(queue, data.to_json)
  @client.close
end

#subscribe(queue) ⇒ Object

# File 'lib/angie-core-api/message/stomp_client.rb', line 20

def subscribe(queue)
  @client.subscribe(queue) { |msg| yield JSON.parse(msg.body) }
end