eu.hgross.blaubot.messaging

Class DiscardNewPickerStrategy

java.lang.Object

eu.hgross.blaubot.messaging.DiscardNewPickerStrategy

All Implemented Interfaces:

IBlaubotMessagePickerStrategy

public class DiscardNewPickerStrategy
extends java.lang.Object
implements IBlaubotMessagePickerStrategy

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

Field Summary

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

POLL_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DiscardNewPickerStrategy()

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

DiscardNewPickerStrategy

public DiscardNewPickerStrategy()

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