Class: CfMessageBus::MockMessageBus

Inherits:
Object
  • Object
show all
Defined in:
lib/cf_message_bus/mock_message_bus.rb

Instance Method Summary collapse

Constructor Details

#initialize(config = {}) ⇒ MockMessageBus

Returns a new instance of MockMessageBus.



3
4
5
6
7
8
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 3

def initialize(config = {})
  @logger = config[:logger]
  @subscriptions = Hash.new { |hash, key| hash[key] = [] }
  @requests = {}
  @published_messages = []
end

Instance Method Details

#clear_published_messages ⇒ Object 



60
61
62
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 60

def clear_published_messages
  @published_messages.clear
end

#connected? ⇒ Boolean

Returns:

  • (Boolean) 


43
44
45
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 43

def connected?
  true
end

#do_recovery ⇒ Object 



52
53
54
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 52

def do_recovery
  @recovery.call if @recovery
end

#has_published?(subject) ⇒ Boolean

Returns:

  • (Boolean) 


64
65
66
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 64

def has_published?(subject)
  @published_messages.find { |message| message[:subject] == subject }
end

#has_published_with_message?(subject, message) ⇒ Boolean

Returns:

  • (Boolean) 


68
69
70
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 68

def has_published_with_message?(subject, message)
  @published_messages.find { |publication| publication[:subject] == subject && publication[:message] == message }
end

#publish(subject, message = nil, &callback) ⇒ Object 



15
16
17
18
19
20
21
22
23
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 15

def publish(subject, message = nil, &callback)
  @subscriptions[subject].each do |subscription|
    subscription.call(symbolize_keys(message))
  end

  @published_messages.push({subject: subject, message: message, callback: callback})

  callback.call if callback
end

#published_messages ⇒ Object 



56
57
58
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 56

def published_messages
  @published_messages
end

#recover(&block) ⇒ Object 



39
40
41
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 39

def recover(&block)
  @recovery = block
end

#request(subject, data = nil, options = {}, &blk) ⇒ Object 



25
26
27
28
29
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 25

def request(subject, data=nil, options={}, &blk)
  @requests[subject] = blk
  publish(subject, data)
  subject
end

#respond_to_request(request_subject, data) ⇒ Object 



47
48
49
50
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 47

def respond_to_request(request_subject, data)
  block = @requests.fetch(request_subject) { lambda { |data| nil } }
  block.call(symbolize_keys(data))
end

#subscribe(subject, opts = {}, &blk) ⇒ Object 



10
11
12
13
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 10

def subscribe(subject, opts = {}, &blk)
  @subscriptions[subject] << blk
  subject
end

#synchronous_request(subject, data = nil, options = {}) ⇒ Object 



31
32
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 31

def synchronous_request(subject, data=nil, options={})
end

#unsubscribe(subscription_id) ⇒ Object 



34
35
36
37
 
# File 'lib/cf_message_bus/mock_message_bus.rb', line 34

def unsubscribe(subscription_id)
  @subscriptions.delete(subscription_id)
  @requests.delete(subscription_id)
end