Sha256: 1e4ee5e7508ed0fb47df740e25a70df102d850718f5f12d2125152bea9c9ce9c
Contents?: true
Size: 372 Bytes
Versions: 10
Compression:
Stored size: 372 Bytes
Contents
require 'queuel/base/queue'
require 'forwardable'
module Queuel
module SNS
class Queue < Base::Queue
extend Forwardable
def push(message, options = {})
queue_connection.publish build_push_message(message, options)
end
private
def queue_connection
@queue_connection ||= client.topics[name]
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems