eu.hgross.blaubot.messaging

Class ProcessAllPickerStrategy

java.lang.Object

eu.hgross.blaubot.messaging.ProcessAllPickerStrategy

All Implemented Interfaces:

IBlaubotMessagePickerStrategy

public class ProcessAllPickerStrategy
extends java.lang.Object
implements IBlaubotMessagePickerStrategy

Picks messages from the given queue one by one and does no fancy things.

Field Summary

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

POLL_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
ProcessAllPickerStrategy()

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

ProcessAllPickerStrategy

public ProcessAllPickerStrategy()

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