org.masukomi.aspirin.core.store.queue

Class SimpleQueueStore

java.lang.Object

org.masukomi.aspirin.core.store.queue.SimpleQueueStore

All Implemented Interfaces:

QueueStore

public class SimpleQueueStore
extends Object
implements QueueStore

Author:

Laszlo Solova

Field Summary

Fields

Modifier and Type	Field and Description
private Configuration	configuration
private ListenerManager	listenerManager
private Object	lock
private Map<String,List<QueueInfo>>	queueInfoByMailid
private Map<String,QueueInfo>	queueInfoByMailidAndRecipient
private Map<String,List<QueueInfo>>	queueInfoByRecipient
private Comparator<QueueInfo>	queueInfoComparator
private List<QueueInfo>	queueInfoList

Constructor Summary

Constructors

Constructor and Description
SimpleQueueStore(Configuration configuration, ListenerManager listenerManager)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(String mailid, long expiry, Collection<javax.mail.internet.InternetAddress> recipients)
List<String>	clean() This method is called to clean QueueStore.
QueueInfo	createQueueInfo()
private String	createSearchKey(String mailid, String recipient)
long	getNextAttempt(String mailid, String recipient)
boolean	hasBeenRecipientHandled(String mailid, String recipient)
void	init()
boolean	isCompleted(String mailid)
QueueInfo	next() It gives back the next sendable QueueInfo object.
void	remove(String mailid)
void	removeRecipient(String recipient)
void	setSendingResult(QueueInfo qi)
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

configuration

private final Configuration configuration

listenerManager

private final ListenerManager listenerManager

queueInfoList

private List<QueueInfo> queueInfoList

queueInfoByMailidAndRecipient

private Map<String,QueueInfo> queueInfoByMailidAndRecipient

queueInfoByMailid

private Map<String,List<QueueInfo>> queueInfoByMailid

queueInfoByRecipient

private Map<String,List<QueueInfo>> queueInfoByRecipient

lock

private Object lock

queueInfoComparator

private Comparator<QueueInfo> queueInfoComparator

Constructor Detail

SimpleQueueStore

public SimpleQueueStore(Configuration configuration,
                ListenerManager listenerManager)

Method Detail

add

public void add(String mailid,
       long expiry,
       Collection<javax.mail.internet.InternetAddress> recipients)
         throws javax.mail.MessagingException

Specified by:

add in interface QueueStore

Throws:

javax.mail.MessagingException

clean

public List<String> clean()

Description copied from interface: QueueStore

This method is called to clean QueueStore. In cleaning process the QueueStore have to remove all completed mailid, and after finishing it gives back list of unfinished mailids.

Specified by:

clean in interface QueueStore

Returns:

List of used mailids.

createQueueInfo

public QueueInfo createQueueInfo()

Specified by:

createQueueInfo in interface QueueStore

getNextAttempt

public long getNextAttempt(String mailid,
                  String recipient)

Specified by:

getNextAttempt in interface QueueStore

hasBeenRecipientHandled

public boolean hasBeenRecipientHandled(String mailid,
                              String recipient)

Specified by:

hasBeenRecipientHandled in interface QueueStore

init

public void init()

Specified by:

init in interface QueueStore

isCompleted

public boolean isCompleted(String mailid)

Specified by:

isCompleted in interface QueueStore

next

public QueueInfo next()

Description copied from interface: QueueStore

It gives back the next sendable QueueInfo object. QueueInfo has - the next valid attempt time (attempt before current time and attemptcount is under limit) - valid expiry (expiry is unset or is after current time) - QUEUED status

Specified by:

next in interface QueueStore

Returns:

next sendable QueueInfo or null

remove

public void remove(String mailid)

Specified by:

remove in interface QueueStore

removeRecipient

public void removeRecipient(String recipient)

Specified by:

removeRecipient in interface QueueStore

setSendingResult

public void setSendingResult(QueueInfo qi)

Specified by:

setSendingResult in interface QueueStore

size

public int size()

Specified by:

size in interface QueueStore

createSearchKey

private String createSearchKey(String mailid,
                     String recipient)