@FunctionalInterface public interface MessageSource<T>
Messages
Message<T>
receive()
@Nullable Message<T> receive()
null