Module io.helidon.messaging

Package io.helidon.messaging

Class Channel<PAYLOAD>

java.lang.Object

io.helidon.messaging.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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Channel.Builder<PAYLOAD>	Channel builder.

Constructor Summary

Constructors

Constructor	Description
Channel()

Method Summary

Modifier and Type	Method	Description
static <PAYLOAD> Channel.Builder<PAYLOAD>	builder()	New builder for configuring new channel.
static <PAYLOAD> Channel<PAYLOAD>	create()	Create new empty channel with random name.
static <PAYLOAD> Channel<PAYLOAD>	create(String name)	Create new empty channel with given name.
String	name()	Channel name, used to pair configuration of connectors vs.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Channel

public Channel()

Method Details

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