Sha256: 6aaef98eb8e1f33799005f1cd603cb6f8f8d89a50d4f2dbfd3e34a3c1726c958
Contents?: true
Size: 433 Bytes
Versions: 17
Compression:
Stored size: 433 Bytes
Contents
module Hermes
class Publisher::InMemoryAdapter
attr_reader :store
def self.connect
end
def initialize
@store = []
end
def publish(routing_key, payload, properties = {}, options = {})
message = { routing_key: routing_key, payload: payload }
message[:properties] = properties if properties.any?
message[:options] = options if options.any?
@store << message
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems