Module: Philotic

Extended by:
Forwardable
Defined in:
lib/philotic.rb,
lib/philotic/config.rb,
lib/philotic/logging.rb,
lib/philotic/message.rb,
lib/philotic/version.rb,
lib/philotic/consumer.rb,
lib/philotic/constants.rb,
lib/philotic/publisher.rb,
lib/philotic/singleton.rb,
lib/philotic/connection.rb,
lib/philotic/subscriber.rb,
lib/philotic/dummy_message.rb,
lib/philotic/serialization.rb,
lib/philotic/logging/logger.rb,
lib/philotic/config/defaults.rb,
lib/philotic/logging/message.rb,
lib/philotic/serialization/json.rb,
lib/philotic/serialization/encryptor.rb,
lib/philotic/serialization/serializer.rb

Defined Under Namespace

Modules: Logging, Serialization Classes: Config, Connection, Consumer, DummyMessage, Message, Publisher, Subscriber

Constant Summary collapse

VERSION = 
'1.3.1'
MESSAGE_OPTIONS = 
[
  :routing_key,
  :persistent,
  :immediate,
  :mandatory,
  :content_type,
  :content_encoding,
  :priority,
  :message_id,
  :correlation_id,
  :reply_to,
  :type,
  :user_id,
  :app_id,
  :timestamp,
  :expiration,
]
PHILOTIC_HEADERS = 
[
  :philotic_firehose,
  :philotic_product,
  :philotic_component,
  :philotic_message_type,
  :philotic_serializations,

]
DEFAULT_NAMED_QUEUE_OPTIONS = 
{
  auto_delete: false,
  durable:     true
}
DEFAULT_ANONYMOUS_QUEUE_OPTIONS = 
{
  auto_delete: true,
  durable:     false
}
DEFAULT_SUBSCRIBE_OPTIONS = 
{}

Class Method Summary collapse

Class Method Details

.connection ⇒ Object 



7
8
9
 
# File 'lib/philotic/singleton.rb', line 7

def connection
  @connection ||= Philotic::Connection.new
end