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