co.cask.coopr.common.queue

Interface QueuedElement

public interface QueuedElement

Represents an Element that is queued.

Method Summary

Methods

Modifier and Type	Method and Description
String	getConsumerId() Get the consumer id of the consumer that has taken this element.
Element	getElement() Get the queued Element.
long	getStatusTime() Get the timestamp in milliseconds of the last time a status update was performed on the element.

Method Detail

getElement

Element getElement()

Get the queued Element.

Returns:

The queued Element.

getStatusTime

long getStatusTime()

Get the timestamp in milliseconds of the last time a status update was performed on the element.

Returns:

Timestamp in milliseconds of the last time a status update was performed on the element.

getConsumerId

String getConsumerId()

Get the consumer id of the consumer that has taken this element.

Returns:

consumerId of the consumer that has taken this element. Will be empty if not being consumed.