Interface PollStrategy
- All Known Implementing Classes:
AbstractPollStrategy,ArbitraryOrderingPollStrategy,BlockingObserverPollStrategy,CompositePollStrategy,DuplicatingPollStrategy,FilteringPollStrategy,RandomPollStrategy
public interface PollStrategy
This interface is used inside of the
MockInMemoryConsumerAdapter
in order to mess around with the way messages are delivered to the consuming code.
This is used in unit tests in order to control message deliver order, introduce duplicates, inject new
arbitrary messages, skip messages...-
Method Summary
Modifier and TypeMethodDescriptionpoll(InMemoryPubSubBroker broker, Map<PubSubTopicPartition, InMemoryPubSubPosition> offsets, long timeout)
-
Method Details
-
poll
Map<PubSubTopicPartition,List<DefaultPubSubMessage>> poll(InMemoryPubSubBroker broker, Map<PubSubTopicPartition, InMemoryPubSubPosition> offsets, long timeout)
-