Class: MessageDriver::Adapters::InMemoryAdapter::InMemoryContext

Inherits:
ContextBase
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/message_driver/adapters/in_memory_adapter.rb

Instance Attribute Summary

Attributes inherited from ContextBase

#adapter, #valid

Instance Method Summary collapse

Methods inherited from ContextBase

#ack_message, #begin_transaction, #commit_transaction, #consumer_count, #create_destination, #handle_ack_message, #handle_begin_transaction, #handle_commit_transaction, #handle_create_destination, #handle_nack_message, #handle_rollback_transaction, #in_transaction?, #initialize, #invalidate, #message_count, #nack_message, #pop_message, #publish, #rollback_transaction, #subscribe, #supports_client_acks?, #supports_transactions?, #valid?

Constructor Details

This class inherits a constructor from MessageDriver::Adapters::ContextBase

Instance Method Details

#handle_consumer_count(destination) ⇒ Object 



132
133
134
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 132

def handle_consumer_count(destination)
  adapter.consumer_count_for(destination.name)
end

#handle_message_count(destination) ⇒ Object 



128
129
130
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 128

def handle_message_count(destination)
  destination.handle_message_count
end

#handle_pop_message(destination, options = {}) ⇒ Object 



120
121
122
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 120

def handle_pop_message(destination, options = {})
  destination.handle_pop_message(self, options)
end

#handle_publish(destination, body, headers = {}, properties = {}) ⇒ Object 



116
117
118
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 116

def handle_publish(destination, body, headers = {}, properties = {})
  destination.handle_publish(body, headers, properties)
end

#handle_subscribe(destination, options = {}, &consumer) ⇒ Object 



124
125
126
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 124

def handle_subscribe(destination, options = {}, &consumer)
  destination.handle_subscribe(options, &consumer)
end

#supports_subscriptions? ⇒ Boolean

Returns:

  • (Boolean) 


136
137
138
 
# File 'lib/message_driver/adapters/in_memory_adapter.rb', line 136

def supports_subscriptions?
  true
end