Module: QueueBus

Extended by:

Forwardable, Publishing

Defined in:

lib/queue_bus/dispatch.rb,
lib/queue-bus.rb,
lib/queue_bus/util.rb,
lib/queue_bus/local.rb,
lib/queue_bus/rider.rb,
lib/queue_bus/config.rb,
lib/queue_bus/driver.rb,
lib/queue_bus/worker.rb,
lib/queue_bus/matcher.rb,
lib/queue_bus/version.rb,
lib/queue_bus/heartbeat.rb,
lib/queue_bus/publisher.rb,
lib/queue_bus/middleware.rb,
lib/queue_bus/publishing.rb,
lib/queue_bus/subscriber.rb,
lib/queue_bus/application.rb,
lib/queue_bus/dispatchers.rb,
lib/queue_bus/subscription.rb,
lib/queue_bus/task_manager.rb,
lib/queue_bus/adapters/base.rb,
lib/queue_bus/adapters/data.rb,
lib/queue_bus/subscription_list.rb

Overview

a base adapter just for publishing and redis connection

Defined Under Namespace

Modules: Adapters, Middleware, Publishing, Subscriber, Util Classes: Application, Config, Dispatch, Dispatchers, Driver, Heartbeat, Local, Matcher, Publisher, Rider, Subscription, SubscriptionList, TaskManager, Worker

Constant Summary

VERSION =

"0.9.0"

Method Summary

Methods included from Publishing

delayed_enqueue_to, enqueue_to, generate_uuid, heartbeat!, publish, publish_at, publish_metadata, with_global_attributes