Sha256: 578600f0c8887c65ae681b7e035c890eeb7b9b3d29b8cffe9252103b7ea7b4d0
Contents?: true
Size: 637 Bytes
Versions: 68
Compression:
Stored size: 637 Bytes
Contents
# frozen_string_literal: true
module Orchestration
module Services
module RabbitMQ
class Healthcheck
include HealthcheckBase
dependencies 'bunny'
def connection_errors
[
Bunny::TCPConnectionFailedForAllHosts,
AMQ::Protocol::EmptyResponseError,
Errno::ECONNRESET
]
end
def connect
host = @configuration.host
port = @configuration.port
connection = Bunny.new("amqp://#{host}:#{port}", log_file: devnull)
connection.start
connection.stop
end
end
end
end
end
Version data entries
68 entries across 68 versions & 1 rubygems