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 52 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, logid="") { |m| ... }
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 56 def listen(queue, logid="") NebulousStomp.logger.info(__FILE__) {log_helper logid, "Subscribing to #{queue} (on Null)"} @fake_messages.each{|m| yield m } end
listen_with_timeout(queue, timeout, logid="") { |m| ... }
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 61 def listen_with_timeout(queue, timeout, logid="") NebulousStomp.logger.info(__FILE__) {log_helper logid, "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=[], logid="")
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 34 def respond_error(nebMess,err,fields=[], logid="") NebulousStomp.logger.info(__FILE__) do log_helper logid, "Responded to #{nebMess} with 'error' verb: #{err} (to Null)" end end
respond_success(nebMess, logid="")
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 28 def respond_success(nebMess, logid="") NebulousStomp.logger.info(__FILE__) do log_helper logid, "Responded to #{nebMess} with 'success' verb (to Null)" end end
send_message(queue, nebMess, logid="")
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 72 def send_message(queue, nebMess, logid="") nebMess end
stomp_connect(logid="")
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 40 def stomp_connect(logid="") NebulousStomp.logger.info(__FILE__) {log_helper logid, "Connecting to STOMP (Null)"} @client = true self end
stomp_disconnect(logid="")
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 46 def stomp_disconnect(logid="") NebulousStomp.logger.info(__FILE__) {log_helper logid, "STOMP Disconnect (Null)"} @client = nil self end
Private Instance Methods
log_helper(logid, message)
click to toggle source
# File lib/nebulous_stomp/stomp_handler_null.rb, line 80 def log_helper(logid, message) "[N#{logid}|#{Thread.object_id}] #{message}" end