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

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.smallrye.reactive.messaging.ChannelRegistry

register

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,
                                                                                                           boolean broadcast)

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

register

public void register(String name,
                     MutinyEmitter<?> 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

getMutinyEmitter

public MutinyEmitter<?> getMutinyEmitter(String name)

Specified by:

getMutinyEmitter 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

getIncomingChannels

public Map<String,Boolean> getIncomingChannels()

Specified by:

getIncomingChannels in interface ChannelRegistry