|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.camel.impl.DefaultEndpoint<Exchange>
org.apache.camel.component.mock.MockEndpoint
public class MockEndpoint
A Mock endpoint which provides a literate, fluent API for testing routes using a JMock style API.
Constructor Summary | |
---|---|
MockEndpoint(String endpointUri,
Component component)
|
Method Summary | |
---|---|
AssertionClause |
allMessages()
Adds an assertion to all the received messages |
protected void |
assertEquals(String message,
Object expectedValue,
Object actualValue)
|
Exchange |
assertExchangeReceived(int index)
Asserts that the given index of message is received (starting at zero) |
void |
assertIsNotSatisfied()
Validates that the assertions fail on this endpoint |
void |
assertIsSatisfied()
Validates that all the available expectations on this endpoint are satisfied; or throw an exception |
void |
assertIsSatisfied(long timeoutForEmptyEndpoints)
Validates that all the available expectations on this endpoint are satisfied; or throw an exception |
static void |
assertIsSatisfied(long timeout,
TimeUnit unit,
MockEndpoint... endpoints)
|
static void |
assertIsSatisfied(MockEndpoint... endpoints)
|
void |
assertMessagesAscending(Expression<Exchange> expression)
Asserts that the messages have ascending values of the given expression |
void |
assertMessagesDescending(Expression<Exchange> expression)
Asserts that the messages have descending values of the given expression |
protected void |
assertMessagesSorted(Expression<Exchange> expression,
boolean ascending)
|
void |
assertNoDuplicates(Expression<Exchange> expression)
|
protected void |
assertTrue(String message,
boolean predicate)
|
static void |
assertWait(long timeout,
TimeUnit unit,
MockEndpoint... endpoints)
|
void |
await()
|
boolean |
await(long timeout,
TimeUnit unit)
|
Consumer<Exchange> |
createConsumer(Processor processor)
Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor |
Exchange |
createExchange()
Create a new exchange for communicating with this endpoint |
Producer<Exchange> |
createProducer()
Creates a new producer which is used send messages into the endpoint |
void |
expectedBodiesReceived(List bodies)
Adds an expectation that the given body values are received by this endpoint |
void |
expectedBodiesReceived(Object... bodies)
Adds an expectation that the given body values are received by this endpoint |
void |
expectedMessageCount(int expectedCount)
Specifies the expected number of message exchanges that should be received by this endpoint |
void |
expectedMinimumMessageCount(int expectedCount)
Specifies the minimum number of expected message exchanges that should be received by this endpoint |
void |
expects(Runnable runnable)
Adds the expection which will be invoked when enough messages are received |
void |
expectsAscending(Expression<Exchange> expression)
Adds an expectation that messages received should have ascending values of the given expression such as a user generated counter value |
void |
expectsDescending(Expression<Exchange> expression)
Adds an expectation that messages received should have descending values of the given expression such as a user generated counter value |
static void |
expectsMessageCount(int count,
MockEndpoint... endpoints)
|
void |
expectsNoDuplicates(Expression<Exchange> expression)
Adds an expectation that no duplicate messages should be received using the expression to determine the message ID |
protected void |
fail(Object message)
|
long |
getDefaulResultWaitMillis()
|
int |
getExpectedCount()
|
int |
getExpectedMinimumCount()
|
List<Throwable> |
getFailures()
|
int |
getReceivedCounter()
|
List<Exchange> |
getReceivedExchanges()
|
long |
getSleepForEmptyTest()
|
boolean |
isSingleton()
Returns if the endpoint should be a CamelContext singleton. |
AssertionClause |
message(int messageIndex)
Adds an assertion to the given message index |
protected void |
onExchange(Exchange exchange)
|
void |
setDefaulResultWaitMillis(long defaulResultWaitMillis)
Sets the maximum amount of time the assertIsSatisfied() will
wait on a latch until it is satisfied |
void |
setSleepForEmptyTest(long sleepForEmptyTest)
Allows a sleep to be specified to wait to check that this endpoint really is empty when expectedMessageCount(int) is called with zero |
protected void |
waitForCompleteLatch()
|
Methods inherited from class org.apache.camel.impl.DefaultEndpoint |
---|
convertTo, createExchange, createExecutorService, createPollingConsumer, equals, getComponent, getContext, getEndpointUri, getExchangeType, getExecutorService, hashCode, setExecutorService, toExchangeType, toString |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public MockEndpoint(String endpointUri, Component component)
Method Detail |
---|
public static void assertWait(long timeout, TimeUnit unit, MockEndpoint... endpoints) throws InterruptedException
InterruptedException
public static void assertIsSatisfied(long timeout, TimeUnit unit, MockEndpoint... endpoints) throws InterruptedException
InterruptedException
public static void assertIsSatisfied(MockEndpoint... endpoints) throws InterruptedException
InterruptedException
public static void expectsMessageCount(int count, MockEndpoint... endpoints) throws InterruptedException
InterruptedException
public Exchange createExchange()
Endpoint
public Consumer<Exchange> createConsumer(Processor processor) throws Exception
Endpoint
Exception
public Producer<Exchange> createProducer() throws Exception
Endpoint
Exception
public void assertIsSatisfied() throws InterruptedException
InterruptedException
public void assertIsSatisfied(long timeoutForEmptyEndpoints) throws InterruptedException
timeoutForEmptyEndpoints
- the timeout in milliseconds that we
should wait for the test to be true
InterruptedException
public void assertIsNotSatisfied() throws InterruptedException
InterruptedException
public void expectedMessageCount(int expectedCount)
expectedCount
- the number of message exchanges that should be
expected by this endpointpublic void expectedMinimumMessageCount(int expectedCount)
expectedCount
- the number of message exchanges that should be
expected by this endpointpublic void expectedBodiesReceived(List bodies)
public void expectedBodiesReceived(Object... bodies)
public void expectsAscending(Expression<Exchange> expression)
expression
- public void expectsDescending(Expression<Exchange> expression)
expression
- public void expectsNoDuplicates(Expression<Exchange> expression)
expression
- the expression used to create a unique message ID for
message comparison (which could just be the message
payload if the payload can be tested for uniqueness using
Object.equals(Object)
and
Object.hashCode()
public void assertMessagesAscending(Expression<Exchange> expression)
public void assertMessagesDescending(Expression<Exchange> expression)
protected void assertMessagesSorted(Expression<Exchange> expression, boolean ascending)
public void assertNoDuplicates(Expression<Exchange> expression)
public void expects(Runnable runnable)
public AssertionClause message(int messageIndex)
messageIndex
- the number of the message
public AssertionClause allMessages()
public Exchange assertExchangeReceived(int index)
public List<Throwable> getFailures()
public int getReceivedCounter()
public List<Exchange> getReceivedExchanges()
public int getExpectedCount()
public long getSleepForEmptyTest()
public void setSleepForEmptyTest(long sleepForEmptyTest)
expectedMessageCount(int)
is called with zero
sleepForEmptyTest
- the milliseconds to sleep for to determine that
this endpoint really is emptypublic long getDefaulResultWaitMillis()
public void setDefaulResultWaitMillis(long defaulResultWaitMillis)
assertIsSatisfied()
will
wait on a latch until it is satisfied
protected void onExchange(Exchange exchange)
protected void waitForCompleteLatch() throws InterruptedException
InterruptedException
protected void assertEquals(String message, Object expectedValue, Object actualValue)
protected void assertTrue(String message, boolean predicate)
protected void fail(Object message)
public int getExpectedMinimumCount()
public void await() throws InterruptedException
InterruptedException
public boolean await(long timeout, TimeUnit unit) throws InterruptedException
InterruptedException
public boolean isSingleton()
Endpoint
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |