public class MessageBroker extends java.lang.Object implements IMessageBroker
Modifier and Type | Method and Description |
---|---|
static MessageBroker |
getInstance() |
java.util.List<IMessage<?>> |
getMessages(java.lang.String topicName,
ITransformationStep step)
Returns all messages sent to a topic that have not been processed by the specified transformation step.
|
void |
removeMessage(java.lang.String topicName,
ITransformationStep step,
IMessage<?> message)
Removes the specified message from the specified topic and the specified subscriber queue.
|
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.
|
public static MessageBroker getInstance()
public void subscribeTo(java.lang.String topicName, ITransformationStep step)
IMessageBroker
subscribeTo
in interface IMessageBroker
public void sendMessage(java.lang.String topicName, IMessage<?> message)
IMessageBroker
sendMessage
in interface IMessageBroker
public java.util.List<IMessage<?>> getMessages(java.lang.String topicName, ITransformationStep step)
getMessages
in interface IMessageBroker
public void removeMessage(java.lang.String topicName, ITransformationStep step, IMessage<?> message)
removeMessage
in interface IMessageBroker