class MessageDriver::Adapters::ContextBase
Attributes
adapter[R]
valid[RW]
Public Class Methods
new(adapter)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 45 def initialize(adapter) @adapter = adapter @valid = true end
Public Instance Methods
ack_message(message, options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 66 def ack_message(message, options = {}) handle_ack_message(message, options) end
begin_transaction(options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 74 def begin_transaction(options = {}) handle_begin_transaction(options) end
commit_transaction(options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 78 def commit_transaction(options = {}) handle_commit_transaction(options) end
consumer_count(destination)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 90 def consumer_count(destination) handle_consumer_count(destination) end
create_destination(name, dest_options = {}, message_props = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 62 def create_destination(name, dest_options = {}, message_props = {}) handle_create_destination(name, dest_options, message_props) end
handle_ack_message(_message, _options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 142 def handle_ack_message(_message, _options = {}) if supports_client_acks? raise 'Must be implemented in subclass' else raise "#ack_message is not supported by #{adapter.class}" end end
handle_begin_transaction(_options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 158 def handle_begin_transaction(_options = {}) if supports_transactions? raise 'Must be implemented in subclass' else raise "transactions are not supported by #{adapter.class}" end end
handle_commit_transaction(_options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 166 def handle_commit_transaction(_options = {}) if supports_transactions? raise 'Must be implemented in subclass' else raise "transactions are not supported by #{adapter.class}" end end
handle_consumer_count(destination)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 186 def handle_consumer_count(destination) raise "#consumer_count is not supported by #{destination.class}" end
handle_create_destination(_name, _dest_options = {}, _message_props = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 122 def handle_create_destination(_name, _dest_options = {}, _message_props = {}) raise 'Must be implemented in subclass' end
handle_message_count(destination)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 182 def handle_message_count(destination) raise "#message_count is not supported by #{destination.class}" end
handle_nack_message(_message, _options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 150 def handle_nack_message(_message, _options = {}) if supports_client_acks? raise 'Must be implemented in subclass' else raise "#nack_message is not supported by #{adapter.class}" end end
handle_pop_message(_destination, _options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 130 def handle_pop_message(_destination, _options = {}) raise 'Must be implemented in subclass' end
handle_publish(_destination, _body, _headers = {}, _properties = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 126 def handle_publish(_destination, _body, _headers = {}, _properties = {}) raise 'Must be implemented in subclass' end
handle_rollback_transaction(_options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 174 def handle_rollback_transaction(_options = {}) if supports_transactions? raise 'Must be implemented in subclass' else raise "transactions are not supported by #{adapter.class}" end end
handle_subscribe(_destination, _options = {}, &_consumer)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 134 def handle_subscribe(_destination, _options = {}, &_consumer) if supports_subscriptions? raise 'Must be implemented in subclass' else raise "#subscribe is not supported by #{adapter.class}" end end
in_transaction?()
click to toggle source
# File lib/message_driver/adapters/base.rb, line 94 def in_transaction? if supports_transactions? raise 'must be implemented in subclass' else raise "#in_transaction? not supported by #{adapter.class}" end end
invalidate()
click to toggle source
# File lib/message_driver/adapters/base.rb, line 106 def invalidate @valid = false end
message_count(destination)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 86 def message_count(destination) handle_message_count(destination) end
nack_message(message, options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 70 def nack_message(message, options = {}) handle_nack_message(message, options) end
pop_message(destination, options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 54 def pop_message(destination, options = {}) handle_pop_message(destination, options) end
publish(destination, body, headers = {}, properties = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 50 def publish(destination, body, headers = {}, properties = {}) handle_publish(destination, body, headers, properties) end
rollback_transaction(options = {})
click to toggle source
# File lib/message_driver/adapters/base.rb, line 82 def rollback_transaction(options = {}) handle_rollback_transaction(options) end
subscribe(destination, options = {}, &consumer)
click to toggle source
# File lib/message_driver/adapters/base.rb, line 58 def subscribe(destination, options = {}, &consumer) handle_subscribe(destination, options, &consumer) end
supports_client_acks?()
click to toggle source
# File lib/message_driver/adapters/base.rb, line 114 def supports_client_acks? false end
supports_subscriptions?()
click to toggle source
# File lib/message_driver/adapters/base.rb, line 118 def supports_subscriptions? false end
supports_transactions?()
click to toggle source
# File lib/message_driver/adapters/base.rb, line 110 def supports_transactions? false end
valid?()
click to toggle source
# File lib/message_driver/adapters/base.rb, line 102 def valid? @valid end