eu.hgross.blaubot.messaging

Interface IBlaubotMessagePickerStrategy

All Known Implementing Classes:

DiscardNewPickerStrategy, DiscardOldPickerStrategy, ProcessAllPickerStrategy

public interface IBlaubotMessagePickerStrategy

A strategy to pick messages from a queue

Field Summary

Fields

Modifier and Type	Field and Description
static long	POLL_TIMEOUT The default timeout for polling operations on the blocking queue.

Method Summary

Modifier and Type	Method and Description
BlaubotChannelConfig.MessagePickerStrategy	getConstant()
BlaubotMessage	pickNextMessage(java.util.concurrent.BlockingQueue<BlaubotMessage> messageQueue) Picks a message from the given queue.

Field Detail

POLL_TIMEOUT

static final long POLL_TIMEOUT

The default timeout for polling operations on the blocking queue.

See Also:

Constant Field Values

Method Detail

pickNextMessage

BlaubotMessage pickNextMessage(java.util.concurrent.BlockingQueue<BlaubotMessage> messageQueue)

Picks a message from the given queue. The implementation has to ensure, that it returns regularly, even when there is no message available. The preferred time for this is specified by the POLL_TIMEOUT constant.

Parameters:

messageQueue - the queue to pick the next message from

Returns:

the picked message or null, if nothing is available to be sent.

getConstant

BlaubotChannelConfig.MessagePickerStrategy getConstant()

Returns:

the enum constant that fits tis implementation