Sha256: 22a44247370a3cb557d1f281fbec2887b8aba3b06135cc724a3e1cf5f6c62b14
Contents?: true
Size: 668 Bytes
Versions: 31
Compression:
Stored size: 668 Bytes
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Rabbit
module Publisher
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
#
# # Publish message for keepalive thread
#
# The name to queue it's created automatically by Bunny GEM
#
# @see KeepaliveThread
class Keepalive < Base
def initialize(exchange)
@reply = exchange.queue('', exclusive: true)
super(exchange)
subscribe_to_queue
end
def publish(request)
super(request)
return_response
end
private
attr_reader :reply
end
end
end
end
Version data entries
31 entries across 31 versions & 1 rubygems