Package io.smallrye.reactive.messaging

Interface ChannelRegistry

All Known Implementing Classes:

InternalChannelRegistry

public interface ChannelRegistry

Method Summary

Modifier and Type	Method	Description
Emitter<?>	getEmitter(String name)
Set<String>	getEmitterNames()
Map<String,Boolean>	getIncomingChannels()
Set<String>	getIncomingNames()
MutinyEmitter<?>	getMutinyEmitter(String name)
Set<String>	getOutgoingNames()
List<org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>>	getPublishers(String name)
List<org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>>	getSubscribers(String name)
void	register(String name, MutinyEmitter<?> emitter)
void	register(String name, Emitter<?> emitter)
default org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream)
org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>	register(String name, org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream, boolean broadcast)
org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>	register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber)

Method Detail

register

default org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> register(String name,
                                                                                                            org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream)

register

org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> register(String name,
                                                                                                    org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>> stream,
                                                                                                    boolean broadcast)

register

org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> register(String name,
                                                                                                                org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber)

register

void register(String name,
              Emitter<?> emitter)

register

void register(String name,
              MutinyEmitter<?> emitter)

getPublishers

List<org.eclipse.microprofile.reactive.streams.operators.PublisherBuilder<? extends Message<?>>> getPublishers(String name)

getEmitter

Emitter<?> getEmitter(String name)

getMutinyEmitter

MutinyEmitter<?> getMutinyEmitter(String name)

getSubscribers

List<org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void>> getSubscribers(String name)

getIncomingNames

Set<String> getIncomingNames()

getOutgoingNames

Set<String> getOutgoingNames()

getEmitterNames

Set<String> getEmitterNames()

getIncomingChannels

Map<String,Boolean> getIncomingChannels()