LavinMQ::Shovel
Constants
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
Nested types
- LavinMQ::Shovel::AMQPDestination
- LavinMQ::Shovel::AMQPSource
- LavinMQ::Shovel::AckMode
- LavinMQ::Shovel::ConfigError
- LavinMQ::Shovel::DeleteAfter
- LavinMQ::Shovel::Destination
- LavinMQ::Shovel::Error
- LavinMQ::Shovel::HTTPDestination
- LavinMQ::Shovel::MultiDestination
- LavinMQ::Shovel::NullOutcomeListener
- LavinMQ::Shovel::Outcome
- LavinMQ::Shovel::OutcomeListener
- LavinMQ::Shovel::Runner
- LavinMQ::Shovel::Source
- LavinMQ::Shovel::State
- LavinMQ::Shovel::Store