Module: ManageIQ::Messaging::Kafka::Queue

Included in:

Client

Defined in:

lib/manageiq/messaging/kafka/queue.rb

Constant Summary

GROUP_FOR_QUEUE_MESSAGES =

ENV['QUEUE_MESSAGES_GROUP_PREFIX'].freeze || 'manageiq_messaging_queue_group_'.freeze