public class SimpleQueueStore extends Object implements QueueStore
| 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 and Description |
|---|
SimpleQueueStore(Configuration configuration,
ListenerManager listenerManager) |
| 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() |
private final Configuration configuration
private final ListenerManager listenerManager
private Object lock
private Comparator<QueueInfo> queueInfoComparator
public SimpleQueueStore(Configuration configuration, ListenerManager listenerManager)
public void add(String mailid, long expiry, Collection<javax.mail.internet.InternetAddress> recipients) throws javax.mail.MessagingException
add in interface QueueStorejavax.mail.MessagingExceptionpublic List<String> clean()
QueueStoreclean in interface QueueStorepublic QueueInfo createQueueInfo()
createQueueInfo in interface QueueStorepublic long getNextAttempt(String mailid, String recipient)
getNextAttempt in interface QueueStorepublic boolean hasBeenRecipientHandled(String mailid, String recipient)
hasBeenRecipientHandled in interface QueueStorepublic void init()
init in interface QueueStorepublic boolean isCompleted(String mailid)
isCompleted in interface QueueStorepublic QueueInfo next()
QueueStorenext in interface QueueStorepublic void remove(String mailid)
remove in interface QueueStorepublic void removeRecipient(String recipient)
removeRecipient in interface QueueStorepublic void setSendingResult(QueueInfo qi)
setSendingResult in interface QueueStorepublic int size()
size in interface QueueStoreCopyright © 2013. All Rights Reserved.