You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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? || !@producer.connected?
init_producer
end
L4E.log.debug "get_producer invoked @producer=#{@producer} connected=#{@producer.connected?}"
@producer
end
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.
Currently, the two methods always return false