eu.hgross.blaubot.messaging

Class DiscardOldPickerStrategy

java.lang.Object

eu.hgross.blaubot.messaging.DiscardOldPickerStrategy

All Implemented Interfaces:

IBlaubotMessagePickerStrategy

public class DiscardOldPickerStrategy
extends java.lang.Object
implements IBlaubotMessagePickerStrategy

Picks messages from the given queue. On each pick, it picks the newest message and discards all older messages.

Field Summary

Fields inherited from interface eu.hgross.blaubot.messaging.IBlaubotMessagePickerStrategy

POLL_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DiscardOldPickerStrategy()

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DiscardOldPickerStrategy

public DiscardOldPickerStrategy()

Method Detail

pickNextMessage

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

Description copied from interface: IBlaubotMessagePickerStrategy

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.

Specified by:

pickNextMessage in interface IBlaubotMessagePickerStrategy

Parameters:

messageQueue - the queue to pick the next message from

Returns:

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

getConstant

public BlaubotChannelConfig.MessagePickerStrategy getConstant()

Specified by:

getConstant in interface IBlaubotMessagePickerStrategy

Returns:

the enum constant that fits tis implementation