public interface IMessageBroker
Modifier and Type | Method and Description |
---|---|
java.util.List<IMessage<?>> |
getMessages(java.lang.String topicName,
ITransformationStep step)
Returns messages sent to the transformation step subscription.
|
void |
removeMessage(java.lang.String topicName,
ITransformationStep step,
IMessage<?> message)
Removes the message from the queue of the specified subscription.
|
void |
sendMessage(java.lang.String topicName,
IMessage<?> message)
Send the specified message to the topic whose name is matching the @param topicName parameter.
|
void |
subscribeTo(java.lang.String topicName,
ITransformationStep step)
Subscribes the given transformation step to the Topic whose name matches the @param topicName parameter.
|
void subscribeTo(java.lang.String topicName, ITransformationStep step)
step
- void sendMessage(java.lang.String topicName, IMessage<?> message)
message
- java.util.List<IMessage<?>> getMessages(java.lang.String topicName, ITransformationStep step)
topicName
- step
- void removeMessage(java.lang.String topicName, ITransformationStep step, IMessage<?> message)
topicName
- step
- message
-