|
||||||||||
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 |
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)
|
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 |
static void |
expectsMessageCount(int count,
MockEndpoint... endpoints)
|
protected void |
fail(Object message)
|
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 |
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 |
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
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 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 emptyprotected void onExchange(Exchange exchange)
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 |