com.atlassian.messagequeue.internal.scheduler

Class SchedulerMessageRunnerServiceTest

java.lang.Object

com.atlassian.messagequeue.internal.scheduler.SchedulerMessageRunnerServiceTest

public class SchedulerMessageRunnerServiceTest
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
org.mockito.junit.MockitoRule	mockitoRule

Constructor Summary

Constructors

Constructor and Description
SchedulerMessageRunnerServiceTest()

Method Summary

Modifier and Type	Method and Description
void	abortJobIfDeliveryCountParameterNotAnInt()
void	abortJobIfMissingRequiredParameter()
void	addMultipleMessagesConcurrently()
void	addMultipleMessagesSerially()
void	cancelAutoAcknowledgement()
void	failFastIfNoMessageRunnerRegisteredForMessage()
void	jobThatRunsLongerThanJobIntervalAllowedToCompleteOnce()
void	messageAckedEarlyDeliveredExactlyOnce()
void	messageAutoAcknowledgedAndNotRedeliveredAfterSuccessfulProcessing()
void	messageNotDeliveredAfterShutdown()
void	messageNotProcessedIfWorkContextNotAvailable()
void	messageProducedAfterSchedulerStopped()
void	messageProducedDuringSchedulerStandbyDeliveredWhenSchedulerStarted()
void	messageRunnerResponsiveToCancellation()
void	messageWithNullPayloadIsProcessedAtLeastOnce()
void	messageWithPayloadIsProcessedAtLeastOnce()
void	problematicJobThatRunsLongerThanJobIntervalAllowedToFailMaxDeliveryCountTimes()
void	problematicMessageDeliveredMaxDeliveryCountTimes()
void	setUp()
void	tearDown()

Methods inherited from class java.lang.Object

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

Field Detail

mockitoRule

public org.mockito.junit.MockitoRule mockitoRule

Constructor Detail

SchedulerMessageRunnerServiceTest

public SchedulerMessageRunnerServiceTest()

Method Detail

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

messageWithPayloadIsProcessedAtLeastOnce

public void messageWithPayloadIsProcessedAtLeastOnce()
                                              throws Exception

Throws:

Exception

messageWithNullPayloadIsProcessedAtLeastOnce

public void messageWithNullPayloadIsProcessedAtLeastOnce()
                                                  throws Exception

Throws:

Exception

messageAutoAcknowledgedAndNotRedeliveredAfterSuccessfulProcessing

public void messageAutoAcknowledgedAndNotRedeliveredAfterSuccessfulProcessing()
                                                                       throws Exception

Throws:

Exception

failFastIfNoMessageRunnerRegisteredForMessage

public void failFastIfNoMessageRunnerRegisteredForMessage()
                                                   throws Exception

Throws:

Exception

problematicMessageDeliveredMaxDeliveryCountTimes

public void problematicMessageDeliveredMaxDeliveryCountTimes()
                                                      throws Exception

Throws:

Exception

addMultipleMessagesSerially

public void addMultipleMessagesSerially()
                                 throws Exception

Throws:

Exception

addMultipleMessagesConcurrently

public void addMultipleMessagesConcurrently()
                                     throws Exception

Throws:

Exception

jobThatRunsLongerThanJobIntervalAllowedToCompleteOnce

public void jobThatRunsLongerThanJobIntervalAllowedToCompleteOnce()
                                                           throws Exception

Throws:

Exception

problematicJobThatRunsLongerThanJobIntervalAllowedToFailMaxDeliveryCountTimes

public void problematicJobThatRunsLongerThanJobIntervalAllowedToFailMaxDeliveryCountTimes()
                                                                                   throws Exception

Throws:

Exception

messageAckedEarlyDeliveredExactlyOnce

public void messageAckedEarlyDeliveredExactlyOnce()
                                           throws Exception

Throws:

Exception

abortJobIfMissingRequiredParameter

public void abortJobIfMissingRequiredParameter()
                                        throws Exception

Throws:

Exception

abortJobIfDeliveryCountParameterNotAnInt

public void abortJobIfDeliveryCountParameterNotAnInt()
                                              throws Exception

Throws:

Exception

messageNotDeliveredAfterShutdown

public void messageNotDeliveredAfterShutdown()
                                      throws Exception

Throws:

Exception

messageProducedDuringSchedulerStandbyDeliveredWhenSchedulerStarted

public void messageProducedDuringSchedulerStandbyDeliveredWhenSchedulerStarted()
                                                                        throws Exception

Throws:

Exception

messageProducedAfterSchedulerStopped

public void messageProducedAfterSchedulerStopped()
                                          throws Exception

Throws:

Exception

messageRunnerResponsiveToCancellation

public void messageRunnerResponsiveToCancellation()
                                           throws Exception

Throws:

Exception

cancelAutoAcknowledgement

public void cancelAutoAcknowledgement()
                               throws Exception

Throws:

Exception

messageNotProcessedIfWorkContextNotAvailable

public void messageNotProcessedIfWorkContextNotAvailable()
                                                  throws Exception

Throws:

Exception