ome.smuggler.core.msg

Class CountedSchedule

java.lang.Object

ome.smuggler.core.types.Schedule<PositiveN>

ome.smuggler.core.msg.CountedSchedule

public class CountedSchedule
extends Schedule<PositiveN>

Channel metadata to request the scheduling of a message and the sending of a counter to indicate how many times the message has been scheduled for delivery.

Constructor Summary

Constructors

Constructor and Description
CountedSchedule(FutureTimepoint when, PositiveN count) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
PositiveN	count()
boolean	equals(java.lang.Object x)
static CountedSchedule	first()
CountedSchedule	next(FutureTimepoint when) Creates a new schedule for the requested time with a counter increased by one with respect to the current counter.

Methods inherited from class ome.smuggler.core.types.Schedule

hashCode, toString, what, when

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

CountedSchedule

public CountedSchedule(FutureTimepoint when,
                       PositiveN count)

Creates a new instance.

Parameters:

when - at which future point in time deliver the message.

count - how many times the delivery has been requested.

Throws:

java.lang.NullPointerException - if any argument is null.

Method Detail

first

public static CountedSchedule first()

Returns:

an initial schedule for the current time point with a counter initialized to 1.

count

public PositiveN count()

Returns:

how many times the delivery has been requested.

next

public CountedSchedule next(FutureTimepoint when)

Creates a new schedule for the requested time with a counter increased by one with respect to the current counter.

Parameters:

when - at which future point in time deliver the message.

Returns:

the new schedule.

Throws:

java.lang.NullPointerException - if the argument is null.

equals

public boolean equals(java.lang.Object x)

Overrides:

equals in class Schedule<PositiveN>