public class ReceiveMessageAction extends AbstractTestAction
Endpoint
to receive the message, this means that action is independent from any message transport.
The received message is validated using a MessageValidator
supporting expected
control message payload and header templates.description
Constructor and Description |
---|
ReceiveMessageAction()
Default constructor.
|
Modifier and Type | Method and Description |
---|---|
ReceiveMessageAction |
addVariableExtractors(VariableExtractor variableExtractor)
Adds a new variable extractor.
|
protected Message |
createControlMessage(TestContext context,
String messageType)
Create control message that is expected.
|
void |
doExecute(TestContext context)
Method receives a message via
Endpoint instance
constructs a validation context and starts the message validation
via MessageValidator . |
DataDictionary |
getDataDictionary()
Gets the data dictionary.
|
Endpoint |
getEndpoint()
Get the message endpoint.
|
String |
getEndpointUri()
Gets the endpoint uri.
|
MessageContentBuilder |
getMessageBuilder()
Gets the messageBuilder.
|
Map<String,Object> |
getMessageSelector()
Gets the messageSelector.
|
String |
getMessageSelectorString()
Gets the messageSelectorString.
|
String |
getMessageType()
Gets the message type for this receive action.
|
Endpoint |
getOrCreateEndpoint(TestContext context)
Creates or gets the endpoint instance.
|
long |
getReceiveTimeout()
Gets the receiveTimeout.
|
ValidationCallback |
getValidationCallback()
Gets the validationCallback.
|
List<ValidationContext> |
getValidationContexts()
Gets the validationContexts.
|
MessageValidator<? extends ValidationContext> |
getValidator()
Gets the validator.
|
List<VariableExtractor> |
getVariableExtractors()
Gets the variable extractors.
|
boolean |
isDisabled(TestContext context)
Checks if this test action is disabled.
|
ReceiveMessageAction |
setDataDictionary(DataDictionary dataDictionary)
Sets the data dictionary.
|
ReceiveMessageAction |
setEndpoint(Endpoint endpoint)
Set message endpoint instance.
|
ReceiveMessageAction |
setEndpointUri(String endpointUri)
Sets the endpoint uri.
|
ReceiveMessageAction |
setMessageBuilder(MessageContentBuilder messageBuilder)
Sets the message builder implementation.
|
ReceiveMessageAction |
setMessageSelector(Map<String,Object> messageSelector)
Setter for messageSelector.
|
ReceiveMessageAction |
setMessageSelectorString(String messageSelectorString)
Set message selector string.
|
ReceiveMessageAction |
setMessageType(String messageType)
Sets the expected message type for this receive action.
|
ReceiveMessageAction |
setReceiveTimeout(long receiveTimeout)
Set the receive timeout.
|
ReceiveMessageAction |
setValidationCallback(ValidationCallback validationCallback)
Sets the validationCallback.
|
ReceiveMessageAction |
setValidationContexts(List<ValidationContext> validationContexts)
Sets the list of available validation contexts for this action.
|
ReceiveMessageAction |
setValidator(MessageValidator<? extends ValidationContext> validator)
Set single message validator.
|
ReceiveMessageAction |
setVariableExtractors(List<VariableExtractor> variableExtractors)
Set the list of variable extractors.
|
protected void |
validateMessage(Message receivedMessage,
TestContext context)
Override this message if you want to add additional message validation
|
execute, getActor, getDescription, getName, setActor, setDescription, setName
public void doExecute(TestContext context)
Endpoint
instance
constructs a validation context and starts the message validation
via MessageValidator
.doExecute
in class AbstractTestAction
CitrusRuntimeException
protected void validateMessage(Message receivedMessage, TestContext context) throws IOException
receivedMessage
- IOException
protected Message createControlMessage(TestContext context, String messageType)
context
- messageType
- public boolean isDisabled(TestContext context)
AbstractTestAction
isDisabled
in interface TestAction
isDisabled
in class AbstractTestAction
context
- the current test context.public ReceiveMessageAction setMessageSelector(Map<String,Object> messageSelector)
messageSelector
- public ReceiveMessageAction setMessageSelectorString(String messageSelectorString)
messageSelectorString
- public ReceiveMessageAction setValidator(MessageValidator<? extends ValidationContext> validator)
validator
- the message validator to setpublic Endpoint getOrCreateEndpoint(TestContext context)
context
- public ReceiveMessageAction setEndpoint(Endpoint endpoint)
endpoint
- the message endpointpublic Endpoint getEndpoint()
public String getEndpointUri()
public ReceiveMessageAction setEndpointUri(String endpointUri)
endpointUri
- public ReceiveMessageAction setReceiveTimeout(long receiveTimeout)
receiveTimeout
- the receiveTimeout to setpublic ReceiveMessageAction addVariableExtractors(VariableExtractor variableExtractor)
variableExtractor
- the variableExtractor to setpublic ReceiveMessageAction setVariableExtractors(List<VariableExtractor> variableExtractors)
variableExtractors
- the variableExtractors to setpublic ReceiveMessageAction setValidationContexts(List<ValidationContext> validationContexts)
validationContexts
- the validationContexts to setpublic List<VariableExtractor> getVariableExtractors()
public ReceiveMessageAction setMessageType(String messageType)
messageType
- the messageType to setpublic String getMessageType()
public Map<String,Object> getMessageSelector()
public String getMessageSelectorString()
public long getReceiveTimeout()
public MessageValidator<? extends ValidationContext> getValidator()
public List<ValidationContext> getValidationContexts()
public ValidationCallback getValidationCallback()
public ReceiveMessageAction setValidationCallback(ValidationCallback validationCallback)
validationCallback
- the validationCallback to setpublic DataDictionary getDataDictionary()
public ReceiveMessageAction setDataDictionary(DataDictionary dataDictionary)
dataDictionary
- public MessageContentBuilder getMessageBuilder()
public ReceiveMessageAction setMessageBuilder(MessageContentBuilder messageBuilder)
messageBuilder
- the messageBuilder to setCopyright © 2008–2017 ConSol Software GmbH. All rights reserved.