public interface ISubscribeTo
Modifier and Type | Method and Description |
---|---|
ITransformationStep |
getParent() |
int |
getPriority() |
IMessageProcessor<? extends java.lang.Object,? extends IMessage<? extends java.lang.Object>> |
getProcessor() |
java.lang.String |
getTopicName() |
void |
processMessages() |
void |
setParent(ITransformationStep parent) |
void |
setPriority(java.lang.String priority) |
void |
setProcessor(IMessageProcessor<? extends java.lang.Object,? extends IMessage<? extends java.lang.Object>> processor) |
void |
setTopicName(java.lang.String name) |
java.lang.String getTopicName()
void setTopicName(java.lang.String name)
int getPriority()
void setPriority(java.lang.String priority)
ITransformationStep getParent()
void setParent(ITransformationStep parent)
IMessageProcessor<? extends java.lang.Object,? extends IMessage<? extends java.lang.Object>> getProcessor()
void setProcessor(IMessageProcessor<? extends java.lang.Object,? extends IMessage<? extends java.lang.Object>> processor)
void processMessages()