Package io.awspring.cloud.sqs.listener.errorhandler

Class ErrorHandlerVisibilityHelper

java.lang.Object

io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper

public class ErrorHandlerVisibilityHelper
extends Object

Utility methods for Error Handler.

Author:

Bruno Garcia, Rafael Pavarini

Constructor Summary

Constructors

Constructor	Description
ErrorHandlerVisibilityHelper()

Method Summary

Modifier and Type	Method	Description
static int	calculateVisibilityTimeoutExponentially(long receiveMessageCount, int initialVisibilityTimeoutSeconds, double multiplier, int maxVisibilityTimeoutSeconds)
static int	calculateVisibilityTimeoutLinearly(long receiveMessageCount, int initialVisibilityTimeoutSeconds, int increment, int maxVisibilityTimeoutSeconds)
static <T> Collection<Message<?>>	castMessages(Collection<Message<T>> messages)
static void	checkVisibilityTimeout(long visibilityTimeout)
static <T> long	getReceiveMessageCount(Message<T> message)
static <T> BatchVisibility	getVisibility(Collection<Message<T>> messages)
static <T> Visibility	getVisibility(Message<T> message)
static <T> Map<Long,List<Message<T>>>	groupMessagesByReceiveMessageCount(Collection<Message<T>> messages)

Methods inherited from class java.lang.Object

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

Constructor Details

ErrorHandlerVisibilityHelper

public ErrorHandlerVisibilityHelper()

Method Details

groupMessagesByReceiveMessageCount

public static <T> Map<Long,List<Message<T>>> groupMessagesByReceiveMessageCount(Collection<Message<T>> messages)

castMessages

public static <T> Collection<Message<?>> castMessages(Collection<Message<T>> messages)

getVisibility

public static <T> Visibility getVisibility(Message<T> message)

getVisibility

public static <T> BatchVisibility getVisibility(Collection<Message<T>> messages)

getReceiveMessageCount

public static <T> long getReceiveMessageCount(Message<T> message)

calculateVisibilityTimeoutExponentially

public static int calculateVisibilityTimeoutExponentially(long receiveMessageCount,
 int initialVisibilityTimeoutSeconds,
 double multiplier,
 int maxVisibilityTimeoutSeconds)

calculateVisibilityTimeoutLinearly

public static int calculateVisibilityTimeoutLinearly(long receiveMessageCount,
 int initialVisibilityTimeoutSeconds,
 int increment,
 int maxVisibilityTimeoutSeconds)

checkVisibilityTimeout

public static void checkVisibilityTimeout(long visibilityTimeout)