io.smallrye.reactive.messaging.impl

Class InternalChannelRegistry

java.lang.Object

io.smallrye.reactive.messaging.impl.InternalChannelRegistry

All Implemented Interfaces:

ChannelRegistry

@ApplicationScoped
public class InternalChannelRegistry
extends Object
implements ChannelRegistry

Constructor Summary

Constructors

Constructor and Description
InternalChannelRegistry()

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalChannelRegistry

public InternalChannelRegistry()

Method Detail

register

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

Specified by:

register in interface ChannelRegistry

register

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

Specified by:

register in interface ChannelRegistry

register

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

Specified by:

register in interface ChannelRegistry

getPublishers

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

Specified by:

getPublishers in interface ChannelRegistry

getEmitter

public Emitter<?> getEmitter(String name)

Specified by:

getEmitter in interface ChannelRegistry

getSubscribers

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

Specified by:

getSubscribers in interface ChannelRegistry

getIncomingNames

public Set<String> getIncomingNames()

Specified by:

getIncomingNames in interface ChannelRegistry

getOutgoingNames

public Set<String> getOutgoingNames()

Specified by:

getOutgoingNames in interface ChannelRegistry

getEmitterNames

public Set<String> getEmitterNames()

Specified by:

getEmitterNames in interface ChannelRegistry