Package-level declarations
Types
The class Channel
represents an individual named channel within the data pipeline. It is used to track subscribers and to publish messages when there are subscribers present. It exists as a separate object to avoid channel lookups at publish time, enabling very fast publish speeds and allowing for heavy use while incurring very minimal cost. Channels are created with {@link channel}, constructing a channel directly with new Channel(name)
is not supported.
The class TracingChannel
is a collection of TracingChannel Channels
which together express a single traceable action. It is used to formalize and simplify the process of producing events for tracing application flow. {@link tracingChannel} is used to construct a TracingChannel
. As with Channel
it is recommended to create and reuse a single TracingChannel
at the top-level of the file rather than creating them dynamically.
Functions
Check if there are active subscribers to the named channel. This is helpful if the message you want to send might be expensive to prepare.
Register a message handler to subscribe to this channel. This message handler will be run synchronously whenever a message is published to the channel. Any errors thrown in the message handler will trigger an 'uncaughtException'
.
Creates a TracingChannel
wrapper for the given TracingChannel Channels
. If a name is given, the corresponding tracing channels will be created in the form of tracing:${name}:${eventType}
where eventType
corresponds to the types of TracingChannel Channels
.
Remove a message handler previously registered to this channel with {@link subscribe}.