Interface InMemorySource<T>
-
- Type Parameters:
T
- the type of payload or message.
public interface InMemorySource<T>
Allows interacting with an in-memory source. An in-memory source is a channel in which you can inject messages using this API.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
complete()
Sends the completion event.void
fail(Throwable failure)
Sends a failure.String
name()
InMemorySource<T>
send(T messageOrPayload)
Sends a message or a payload to the channel.
-
-
-
Method Detail
-
name
String name()
- Returns:
- the channel name.
-
send
InMemorySource<T> send(T messageOrPayload)
Sends a message or a payload to the channel.- Parameters:
messageOrPayload
- the message or payload to send. In the case of a payload, a simple message is created. Must not benull
- Returns:
- this to allow chaining calls.
-
complete
void complete()
Sends the completion event.
-
fail
void fail(Throwable failure)
Sends a failure.- Parameters:
failure
- the failure, must not benull
-
-