Class Channel<PAYLOAD>

  • Type Parameters:
    PAYLOAD - payload type wrapped in Message being emitted by publisher and received by subscriber.

    public final class Channel<PAYLOAD>
    extends Object
    Channel representing publisher - subscriber relationship.
    • Constructor Detail

      • Channel

        public Channel()
    • Method Detail

      • name

        public String name()
        Channel name, used to pair configuration of connectors vs. channel configuration.
        Returns:
        channel name
      • create

        public static <PAYLOAD> Channel<PAYLOAD> create​(String name)
        Create new empty channel with given name.
        Type Parameters:
        PAYLOAD - message payload type
        Parameters:
        name - channel name
        Returns:
        new channel
      • create

        public static <PAYLOAD> Channel<PAYLOAD> create()
        Create new empty channel with random name.
        Type Parameters:
        PAYLOAD - message payload type
        Returns:
        new channel
      • builder

        public static <PAYLOAD> Channel.Builder<PAYLOAD> builder()
        New builder for configuring new channel.
        Type Parameters:
        PAYLOAD - message payload type
        Returns:
        channel builder