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