class NebulousStomp::StompHandlerNull
Behaves just like StompHandler
, except, does nothing and expects no stomp connection
Attributes
fake_messages[R]
Public Class Methods
new(hash={})
click to toggle source
Calls superclass method
NebulousStomp::StompHandler::new
# File lib/nebulous_stomp/stomp_handler_null.rb, line 19 def initialize(hash={}) super(hash) @fake_messages = [] end
Public Instance Methods
calc_reply_id()
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 76 def calc_reply_id; 'ABCD123456789'; end
connected?()
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 40 def connected? @fake_messages != [] end
insert_fake(message)
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 24 def insert_fake(message) @fake_messages << message end
listen(queue) { |m| ... }
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 44 def listen(queue) NebulousStomp.logger.info(__FILE__) {"Subscribing to #{queue} (on Null)"} @fake_messages.each{|m| yield m } end
listen_with_timeout(queue, timeout) { |m| ... }
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 49 def listen_with_timeout(queue, timeout) NebulousStomp.logger.info(__FILE__) {"Subscribing to #{queue} (on Null)"} if @fake_messages != [] @fake_messages.each{|m| yield m } else sleep timeout raise NebulousStomp::NebulousTimeout end end
respond_error(nebMess,err,fields=[])
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 70 def respond_error(nebMess,err,fields=[]) NebulousStomp.logger.info(__FILE__) do "Responded to #{nebMess} with 'error' verb: #{err} (to Null)" end end
respond_success(nebMess)
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 64 def respond_success(nebMess) NebulousStomp.logger.info(__FILE__) do "Responded to #{nebMess} with 'success' verb (to Null)" end end
send_message(queue, nebMess)
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 60 def send_message(queue, nebMess) nebMess end
stomp_connect()
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 28 def stomp_connect NebulousStomp.logger.info(__FILE__) {"Connecting to STOMP (Null)"} @client = true self end
stomp_disconnect()
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 34 def stomp_disconnect NebulousStomp.logger.info(__FILE__) {"STOMP Disconnect (Null)"} @client = nil self end