module LavinMQ::Shovel

Defined in:

lavinmq/shovel/shovel.cr

Constant Summary

DEFAULT_ACK_MODE = AckMode::OnConfirm

DEFAULT_BATCH_ACK_TIMEOUT = 3.seconds

DEFAULT_DELETE_AFTER = DeleteAfter::Never

DEFAULT_PREFETCH = 1000_u16

DEFAULT_RECONNECT_DELAY = 5.seconds

Log = LavinMQ::Log.for("shovel")