io.smallrye.reactive.messaging

Interface ChannelRegistry

All Known Implementing Classes:

InternalChannelRegistry

public interface ChannelRegistry

Method Summary

Modifier and Type	Method and Description
Emitter<?>	getEmitter(String name)
Set<String>	getEmitterNames()
Set<String>	getIncomingNames()
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, Emitter<?> emitter)
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.SubscriberBuilder<? extends Message<?>,Void>	register(String name, org.eclipse.microprofile.reactive.streams.operators.SubscriberBuilder<? extends Message<?>,Void> subscriber)

Method Detail

register

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.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)

getPublishers

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

getEmitter

Emitter<?> getEmitter(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()