Package io.smallrye.reactive.messaging.providers.impl

Class InternalChannelRegistry

java.lang.Object

io.smallrye.reactive.messaging.providers.impl.InternalChannelRegistry

All Implemented Interfaces:

ChannelRegistry

@ApplicationScoped
public class InternalChannelRegistry
extends Object
implements ChannelRegistry

Constructor Summary

Constructors

Constructor	Description
InternalChannelRegistry()

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)
Map<String,Boolean>	getOutgoingChannels()
Set<String>	getOutgoingNames()
List<org.reactivestreams.Publisher<? extends Message<?>>>	getPublishers(String name)
List<org.reactivestreams.Subscriber<? extends Message<?>>>	getSubscribers(String name)
void	register(String name, MutinyEmitter<?> emitter)
void	register(String name, Emitter<?> emitter)
org.reactivestreams.Publisher<? extends Message<?>>	register(String name, org.reactivestreams.Publisher<? extends Message<?>> stream, boolean broadcast)
org.reactivestreams.Subscriber<? extends Message<?>>	register(String name, org.reactivestreams.Subscriber<? extends Message<?>> subscriber, boolean merge)

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.reactivestreams.Publisher<? extends Message<?>> register(String name,
                                                                    org.reactivestreams.Publisher<? extends Message<?>> stream,
                                                                    boolean broadcast)

Specified by:

register in interface ChannelRegistry

register

public org.reactivestreams.Subscriber<? extends Message<?>> register(String name,
                                                                     org.reactivestreams.Subscriber<? extends Message<?>> subscriber,
                                                                     boolean merge)

Specified by:

register in interface ChannelRegistry

register

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

Specified by:

register in interface ChannelRegistry

register

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

Specified by:

register in interface ChannelRegistry

getPublishers

public List<org.reactivestreams.Publisher<? extends Message<?>>> getPublishers(String name)

Specified by:

getPublishers in interface ChannelRegistry

getEmitter

public Emitter<?> getEmitter(String name)

Specified by:

getEmitter in interface ChannelRegistry

getMutinyEmitter

public MutinyEmitter<?> getMutinyEmitter(String name)

Specified by:

getMutinyEmitter in interface ChannelRegistry

getSubscribers

public List<org.reactivestreams.Subscriber<? extends Message<?>>> 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

getIncomingChannels

public Map<String,Boolean> getIncomingChannels()

Specified by:

getIncomingChannels in interface ChannelRegistry

getOutgoingChannels

public Map<String,Boolean> getOutgoingChannels()

Specified by:

getOutgoingChannels in interface ChannelRegistry