public interface ITopic
Modifier and Type | Method and Description |
---|---|
void |
addMessage(IMessage<? extends java.lang.Object> message)
Adds the provided message to this topic
|
void |
addSubscriber(ITransformationStep subscriber)
Adds a new subscriber to this topic
|
java.util.List<IMessage<? extends java.lang.Object>> |
getMessages(ITransformationStep sub)
Returns every message sent to the given subscriber
|
java.lang.String |
getName() |
java.util.List<ITransformationStep> |
getSubscribers()
Returns the subscribers of this topic
|
void |
removeMessage(IMessage<?> message)
Removes the given message from every subscriber
|
void |
removeMessage(IMessage<?> message,
ITransformationStep sub)
Removes messages assigned to the given transformation step
|
void |
setName(java.lang.String name) |
java.lang.String getName()
void setName(java.lang.String name)
void addMessage(IMessage<? extends java.lang.Object> message)
message
- Message added to this topicvoid removeMessage(IMessage<?> message, ITransformationStep sub)
message
- Message to be removedsub
- Specified subscribervoid removeMessage(IMessage<?> message)
message
- java.util.List<IMessage<? extends java.lang.Object>> getMessages(ITransformationStep sub)
sub
- void addSubscriber(ITransformationStep subscriber)
subscriber
- java.util.List<ITransformationStep> getSubscribers()