Class: QueueingRabbit::JSONBus

Inherits:

AbstractBus

• Object
• AbstractBus
• QueueingRabbit::JSONBus

Extended by:

Serializer

Defined in:

lib/queueing_rabbit/buses/json_bus.rb

Instance Attribute Summary

Attributes included from Bus

#shared_exchange

Class Method Summary

• .publish(payload, metadata = {}) ⇒ Object

Methods included from Serializer

deserialize, serialize

Methods included from Bus

#batch_publishing?, #channel, #channel_options, #demand_batch_publishing!, #exchange, #exchange_name, #exchange_options, extended, #publish, #publish_with, #publishing_defaults

Class Method Details

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

# File 'lib/queueing_rabbit/buses/json_bus.rb', line 7

def self.publish(payload, metadata = {})
  super serialize(payload), metadata
end