Package com.mimecast.robin.queue

Class RelayDequeue

java.lang.Object

com.mimecast.robin.queue.RelayDequeue

public class RelayDequeue
extends Object

Processes claimed relay queue items.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.logging.log4j.Logger	log
private final PooledLmtpDelivery	pooledLmtpDelivery
private final PersistentQueue<RelaySession>	queue
private static final AtomicLong	RESCHEDULE_COUNT
private final StalwartDirectDelivery	stalwartDirectDelivery

Constructor Summary

Constructors

Constructor	Description
RelayDequeue(PersistentQueue<RelaySession> queue)
RelayDequeue(PersistentQueue<RelaySession> queue, PooledLmtpDelivery pooledLmtpDelivery)
RelayDequeue(PersistentQueue<RelaySession> queue, PooledLmtpDelivery pooledLmtpDelivery, StalwartDirectDelivery stalwartDirectDelivery)

Method Summary

Modifier and Type	Method	Description
(package private) void	attemptDelivery(RelaySession relaySession)
(package private) void	cleanupSuccessfulEnvelopes(List<MessageEnvelope> successfulEnvelopes)
(package private) List<Path>	collectCleanupPaths(List<MessageEnvelope> successfulEnvelopes)
(package private) int	countRecipients(RelaySession relaySession)
(package private) RelaySession	createBounceSession(RelaySession originalSession, String recipient)
(package private) void	deleteEnvelopeFiles(List<Path> paths)
private String	deriveLastError(RelaySession relaySession)
(package private) List<RelaySession>	generateBounces(RelaySession relaySession)
static long	getRescheduleCount()
(package private) boolean	hasPermanentFailuresOnly(RelaySession relaySession)	Checks if all errors are permanent 5xx SMTP failures (ESMTP protocol only).
(package private) boolean	isReadyForRetry(RelaySession relaySession, long currentEpochSeconds)
private void	logSessionInfo(RelaySession relaySession)
RelayQueueWorkResult	processClaimedItem(QueueItem<RelaySession> queueItem, long currentEpochSeconds)	Processes one claimed queue item and returns a deferred mutation result.
(package private) RelayDeliveryResult	processDeliveryResults(RelaySession relaySession)
(package private) RelayQueueWorkResult	retrySession(QueueItem<RelaySession> queueItem, RelaySession relaySession, long currentEpochSeconds, List<Path> cleanupPaths)

Methods inherited from class java.lang.Object

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

Field Details

log

private static final org.apache.logging.log4j.Logger log

RESCHEDULE_COUNT

private static final AtomicLong RESCHEDULE_COUNT

queue

private final PersistentQueue<RelaySession> queue

pooledLmtpDelivery

private final PooledLmtpDelivery pooledLmtpDelivery

stalwartDirectDelivery

private final StalwartDirectDelivery stalwartDirectDelivery

Constructor Details

RelayDequeue

public RelayDequeue(PersistentQueue<RelaySession> queue)

RelayDequeue

RelayDequeue(PersistentQueue<RelaySession> queue,
 PooledLmtpDelivery pooledLmtpDelivery)

RelayDequeue

RelayDequeue(PersistentQueue<RelaySession> queue,
 PooledLmtpDelivery pooledLmtpDelivery,
 StalwartDirectDelivery stalwartDirectDelivery)

Method Details

processClaimedItem

public RelayQueueWorkResult processClaimedItem(QueueItem<RelaySession> queueItem,
 long currentEpochSeconds)

Processes one claimed queue item and returns a deferred mutation result.

isReadyForRetry

boolean isReadyForRetry(RelaySession relaySession,
 long currentEpochSeconds)

countRecipients

int countRecipients(RelaySession relaySession)

attemptDelivery

void attemptDelivery(RelaySession relaySession)

processDeliveryResults

RelayDeliveryResult processDeliveryResults(RelaySession relaySession)

collectCleanupPaths

List<Path> collectCleanupPaths(List<MessageEnvelope> successfulEnvelopes)

cleanupSuccessfulEnvelopes

void cleanupSuccessfulEnvelopes(List<MessageEnvelope> successfulEnvelopes)

deleteEnvelopeFiles

void deleteEnvelopeFiles(List<Path> paths)

retrySession

RelayQueueWorkResult retrySession(QueueItem<RelaySession> queueItem,
 RelaySession relaySession,
 long currentEpochSeconds,
 List<Path> cleanupPaths)

getRescheduleCount

public static long getRescheduleCount()

generateBounces

List<RelaySession> generateBounces(RelaySession relaySession)

createBounceSession

RelaySession createBounceSession(RelaySession originalSession,
 String recipient)

hasPermanentFailuresOnly

boolean hasPermanentFailuresOnly(RelaySession relaySession)

Checks if all errors are permanent 5xx SMTP failures (ESMTP protocol only). When true, the item should be marked dead without retry.

Parameters:

relaySession - The relay session to check.

Returns:

True if all failures are permanent 5xx.

logSessionInfo

private void logSessionInfo(RelaySession relaySession)

deriveLastError

private String deriveLastError(RelaySession relaySession)