public abstract class QueueStoreTestCase extends AbstractMuleContextTestCase
Modifier and Type | Field and Description |
---|---|
static String |
ANOTHER_VALUE |
static int |
LONG_POLL_TIMEOUT |
static int |
NUMBER_OF_ITEMS |
static long |
OFFER_TIMEOUT |
static int |
SHORT_POLL_TIMEOUT |
org.junit.rules.TemporaryFolder |
temporaryFolder |
static String |
VALUE |
callbackCalled, CLASSNAME_ANNOTATIONS_CONFIG_BUILDER, IGNORED_DOT_MULE_DIRS, LOCK_TIMEOUT, muleContext, RECEIVE_TIMEOUT, TEST_MESSAGE, TEST_PAYLOAD, WORKING_DIRECTORY_SYSTEM_PROPERTY_KEY, workingDirectory
DEFAULT_TEST_TIMEOUT_SECS, globalTimeout, logger, name, TEST_TIMEOUT_SYSTEM_PROPERTY, TESTING_MODE_PROPERTY_NAME
Constructor and Description |
---|
QueueStoreTestCase() |
Modifier and Type | Method and Description |
---|---|
void |
allowOfferWhenThereIsCapacity() |
void |
clearEmptiesTheQueue() |
protected QueueStore |
createQueue() |
protected abstract QueueStore |
createQueueInfoDelegate(int capacity,
MuleContext mockMuleContext) |
protected QueueStore |
createQueueWithCapacity(int capacity) |
void |
failIfThereIsNoCapacity() |
void |
offerAndPollSingleValue() |
void |
offerAndPollTwice() |
void |
offerSeveralRetrieveAll() |
void |
offerSeveralRetrieveAllMuleEvents() |
void |
peekDoesNotRemoveElement() |
void |
pollDoesNotReturnsUntilPollTimeout() |
void |
untakeAddsElementFirst() |
addBuilders, configureMuleContext, createMuleContext, createObject, createObject, disposeContext, disposeContextPerTest, doSetUp, doSetUpBeforeMuleContextCreation, doTearDown, doTearDownAfterMuleContextDispose, getBuilder, getConfigurationResources, getFileInsideWorkingDirectory, getSensingNullMessageProcessor, getStartUpProperties, getTestConnector, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEvent, getTestEventContext, getTestEventContext, getTestEventUsingFlow, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestInboundEndpoint, getTestMuleMessage, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestOutboundEndpoint, getTestService, getTestService, getTestService, getTestSession, getTestTransactedInboundEndpoint, getTestTransformer, getTriggerableMessageSource, getTriggerableMessageSource, getWorkingDirectory, initialiseObject, isDisposeContextPerClass, isGracefulShutdown, isStartContext, setDisposeContextPerClass, setStartContext, setUpMuleContext
clearExcludedFlag, clearRequestContext, clearTestCaseName, createTestTimeoutRule, dumpFilteredThreadsInTest, getTestHeader, getTestTimeoutSecs, getTimeoutSystemProperty, initializeMuleTest, isDisabledInThisEnvironment, isDisabledInThisEnvironment, isExcluded, isFailOnTimeout, isOffline, isTestIncludedInExclusionFile, takeTestCaseName
public static final String VALUE
public static final String ANOTHER_VALUE
public static final long OFFER_TIMEOUT
public static final int NUMBER_OF_ITEMS
public static final int LONG_POLL_TIMEOUT
public static final int SHORT_POLL_TIMEOUT
public org.junit.rules.TemporaryFolder temporaryFolder
public void offerAndPollSingleValue() throws InterruptedException, ObjectStoreException
public void allowOfferWhenThereIsCapacity() throws Exception
Exception
public void pollDoesNotReturnsUntilPollTimeout() throws Exception
Exception
public void offerSeveralRetrieveAllMuleEvents() throws Exception
Exception
protected QueueStore createQueue()
protected QueueStore createQueueWithCapacity(int capacity)
protected abstract QueueStore createQueueInfoDelegate(int capacity, MuleContext mockMuleContext)
Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.