org.graylog2.shared.messageq

Class AbstractMessageQueueAcknowledger<T>

java.lang.Object

org.graylog2.shared.messageq.AbstractMessageQueueAcknowledger<T>

All Implemented Interfaces:

MessageQueueAcknowledger

Direct Known Subclasses:

LocalKafkaMessageQueueAcknowledger

public abstract class AbstractMessageQueueAcknowledger<T>
extends Object
implements MessageQueueAcknowledger

Nested Class Summary

Nested classes/interfaces inherited from interface org.graylog2.shared.messageq.MessageQueueAcknowledger

MessageQueueAcknowledger.Metrics

Field Summary

Fields

Modifier and Type	Field and Description
protected MessageQueueAcknowledger.Metrics	metrics
protected Class<T>	queueIdClass

Constructor Summary

Constructors

Constructor and Description
AbstractMessageQueueAcknowledger(Class<T> queueIdClass, MessageQueueAcknowledger.Metrics metrics)

Method Summary

Modifier and Type	Method and Description
void	acknowledge(List<Message> messages)
void	acknowledge(Message message)
void	acknowledge(Object queueId)
protected abstract void	doAcknowledge(T queueId)
protected boolean	isValidMessageQueueId(Object object)

Methods inherited from class java.lang.Object

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

Field Detail

queueIdClass

protected final Class<T> queueIdClass

metrics

protected final MessageQueueAcknowledger.Metrics metrics

Constructor Detail

AbstractMessageQueueAcknowledger

public AbstractMessageQueueAcknowledger(Class<T> queueIdClass,
                                        MessageQueueAcknowledger.Metrics metrics)

Method Detail

acknowledge

public void acknowledge(Object queueId)

Specified by:

acknowledge in interface MessageQueueAcknowledger

acknowledge

public void acknowledge(Message message)

Specified by:

acknowledge in interface MessageQueueAcknowledger

acknowledge

public void acknowledge(List<Message> messages)

Specified by:

acknowledge in interface MessageQueueAcknowledger

doAcknowledge

protected abstract void doAcknowledge(T queueId)

isValidMessageQueueId

protected boolean isValidMessageQueueId(Object object)