Module: RabbitmqClient

Extended by:

ActiveSupport::Autoload

Includes:

ActiveSupport::Configurable, ActiveSupport::JSON

Defined in:

lib/rabbitmq_client.rb,
lib/rabbitmq_client/plugin.rb,
lib/rabbitmq_client/version.rb,
lib/rabbitmq_client/callback.rb,
lib/rabbitmq_client/exchange.rb,
lib/rabbitmq_client/lifecycle.rb,
lib/rabbitmq_client/publisher.rb,
lib/rabbitmq_client/tags_filter.rb,
lib/rabbitmq_client/publisher_job.rb,
lib/rabbitmq_client/json_formatter.rb,
lib/rabbitmq_client/logger_builder.rb,
lib/rabbitmq_client/text_formatter.rb,
lib/rabbitmq_client/exchange_registry.rb,
lib/rabbitmq_client/message_publisher.rb,
lib/rabbitmq_client/json_log_subscriber.rb,
lib/rabbitmq_client/log_subscriber_base.rb,
lib/rabbitmq_client/plain_log_subscriber.rb

Overview

:nodoc:

Defined Under Namespace

Classes: Callback, EmptyPlugin, Exchange, ExchangeRegistry, InvalidCallback, JsonFormatter, JsonLogSubscriber, Lifecycle, LogSubscriberBase, LoggerBuilder, MessagePublisher, PlainLogSubscriber, Plugin, Publisher, PublisherJob, TagsFilter, TextFormatter

Constant Summary

VERSION =

'0.0.3'

Class Method Summary

• .add_exchange(name, type, options = {}) ⇒ Object
• .lifecycle ⇒ Object
• .logger ⇒ Object
• .publish(payload, options = {}) ⇒ Object

Class Method Details

.add_exchange(name, type, options = {}) ⇒ Object

# File 'lib/rabbitmq_client.rb', line 70

def add_exchange(name, type, options = {})
  @exchange_registry.add(name, type, options)
end

.lifecycle ⇒ Object

# File 'lib/rabbitmq_client.rb', line 78

def lifecycle
  @lifecycle ||= setup_lifecycle
end

.logger ⇒ Object

# File 'lib/rabbitmq_client.rb', line 82

def logger
  @logger ||= setup_logger
end

.publish(payload, options = {}) ⇒ Object

# File 'lib/rabbitmq_client.rb', line 74

def publish(payload, options = {})
  publisher.publish(payload, options)
end