This repository was archived by the owner on Mar 10, 2025. It is now read-only.

Description
It is useful to check for producer.connected? or producer.errored? before publishing messages. Otherwise we may want to create a fresh instance of producer.
def get_producer
if @producer.nil? || @producer.errored? || [email protected]?
init_producer
end
L4E.log.debug "get_producer invoked @producer=#{@producer} connected=#{@producer.connected?}"
@producer
end
Currently, the two methods always return false
# No-op for now
def connected?
return false
end