org.masukomi.aspirin.core.store.queue

Class QueueInfo

java.lang.Object

org.masukomi.aspirin.core.store.queue.QueueInfo

public class QueueInfo
extends Object

Author:

Laszlo Solova

Field Summary

Fields

Modifier and Type	Field and Description
private long	attempt
private int	attemptCount
private String	complexId
private Configuration	configuration
private long	expiry
private ListenerManager	listenerManager
private String	mailid
private boolean	notifiedAlready
private String	qiToString
private String	recipient
private String	resultInfo
private DeliveryState	state

Constructor Summary

Constructors

Constructor and Description
QueueInfo(Configuration configuration, ListenerManager listenerManager)

Method Summary

Methods

Modifier and Type	Method and Description
long	getAttempt()
int	getAttemptCount()
String	getComplexId()
long	getExpiry()
String	getMailid()
String	getRecipient()
String	getResultInfo()
DeliveryState	getState()
boolean	hasState(DeliveryState... states)
void	incAttemptCount()
boolean	isInTimeBounds()
boolean	isSendable()
void	setAttempt(long attempt)
void	setAttemptCount(int attemptCount)
void	setExpiry(long expiry)
void	setMailid(String mailid)
void	setRecipient(String recipient)
void	setResultInfo(String resultInfo)
void	setState(DeliveryState state) This method set original state, and notify all AspirinListener about the state change, if the new change is not QUEUED.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

configuration

private final Configuration configuration

listenerManager

private final ListenerManager listenerManager

mailid

private String mailid

recipient

private String recipient

resultInfo

private String resultInfo

attempt

private long attempt

attemptCount

private int attemptCount

expiry

private long expiry

state

private DeliveryState state

notifiedAlready

private transient boolean notifiedAlready

complexId

private transient String complexId

qiToString

private transient String qiToString

Constructor Detail

QueueInfo

public QueueInfo(Configuration configuration,
         ListenerManager listenerManager)

Method Detail

getComplexId

public String getComplexId()

getMailid

public String getMailid()

setMailid

public void setMailid(String mailid)

getRecipient

public String getRecipient()

setRecipient

public void setRecipient(String recipient)

getResultInfo

public String getResultInfo()

setResultInfo

public void setResultInfo(String resultInfo)

getAttempt

public long getAttempt()

setAttempt

public void setAttempt(long attempt)

getAttemptCount

public int getAttemptCount()

incAttemptCount

public void incAttemptCount()

setAttemptCount

public void setAttemptCount(int attemptCount)

getExpiry

public long getExpiry()

setExpiry

public void setExpiry(long expiry)

getState

public DeliveryState getState()

setState

public void setState(DeliveryState state)

This method set original state, and notify all AspirinListener about the state change, if the new change is not QUEUED. Please call only once, on persisting - if persisted - this item. For example in SimpleQueueStore we use only once: in the setSendingResult() method.

Parameters:

state - The new state.

hasState

public boolean hasState(DeliveryState... states)

isSendable

public boolean isSendable()

isInTimeBounds

public boolean isInTimeBounds()

toString

public String toString()

Overrides:

toString in class Object