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

Class InternalChannelRegistry

java.lang.Object

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

All Implemented Interfaces:

io.smallrye.reactive.messaging.ChannelRegistry

@ApplicationScoped
public class InternalChannelRegistry
extends Object
implements io.smallrye.reactive.messaging.ChannelRegistry

Constructor Summary

Constructors

Constructor	Description
InternalChannelRegistry()

Method Summary

Modifier and Type	Method	Description
org.eclipse.microprofile.reactive.messaging.Emitter<?>	getEmitter(String name)
<T> T	getEmitter(String name, Class<? super T> emitterType)
Set<String>	getEmitterNames()
Map<String,Boolean>	getIncomingChannels()
Set<String>	getIncomingNames()
io.smallrye.reactive.messaging.MutinyEmitter<?>	getMutinyEmitter(String name)
Map<String,Boolean>	getOutgoingChannels()
Set<String>	getOutgoingNames()
io.smallrye.reactive.messaging.PausableChannel	getPausable(String name)
List<Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>>	getPublishers(String name)
List<Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>>	getSubscribers(String name)
void	register(String name, io.smallrye.reactive.messaging.MutinyEmitter<?> emitter)
void	register(String name, io.smallrye.reactive.messaging.PausableChannel pausable)
<T> void	register(String name, Class<T> emitterType, T emitter)
Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>	register(String name, Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> stream, boolean broadcast)
Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>	register(String name, Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> subscriber, boolean merge)
void	register(String name, org.eclipse.microprofile.reactive.messaging.Emitter<?> emitter)

Methods inherited from class java.lang.Object

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

Constructor Details

InternalChannelRegistry

public InternalChannelRegistry()

Method Details

register

public Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> register(String name,
 Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> stream,
 boolean broadcast)

Specified by:

register in interface io.smallrye.reactive.messaging.ChannelRegistry

register

public Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> register(String name,
 Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>> subscriber,
 boolean merge)

Specified by:

register in interface io.smallrye.reactive.messaging.ChannelRegistry

register

public void register(String name,
 org.eclipse.microprofile.reactive.messaging.Emitter<?> emitter)

Specified by:

register in interface io.smallrye.reactive.messaging.ChannelRegistry

register

public void register(String name,
 io.smallrye.reactive.messaging.MutinyEmitter<?> emitter)

Specified by:

register in interface io.smallrye.reactive.messaging.ChannelRegistry

register

public <T> void register(String name,
 Class<T> emitterType,
 T emitter)

Specified by:

register in interface io.smallrye.reactive.messaging.ChannelRegistry

getPublishers

public List<Flow.Publisher<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>> getPublishers(String name)

Specified by:

getPublishers in interface io.smallrye.reactive.messaging.ChannelRegistry

getEmitter

public org.eclipse.microprofile.reactive.messaging.Emitter<?> getEmitter(String name)

Specified by:

getEmitter in interface io.smallrye.reactive.messaging.ChannelRegistry

getMutinyEmitter

public io.smallrye.reactive.messaging.MutinyEmitter<?> getMutinyEmitter(String name)

Specified by:

getMutinyEmitter in interface io.smallrye.reactive.messaging.ChannelRegistry

getEmitter

public <T> T getEmitter(String name,
 Class<? super T> emitterType)

Specified by:

getEmitter in interface io.smallrye.reactive.messaging.ChannelRegistry

getSubscribers

public List<Flow.Subscriber<? extends org.eclipse.microprofile.reactive.messaging.Message<?>>> getSubscribers(String name)

Specified by:

getSubscribers in interface io.smallrye.reactive.messaging.ChannelRegistry

getIncomingNames

public Set<String> getIncomingNames()

Specified by:

getIncomingNames in interface io.smallrye.reactive.messaging.ChannelRegistry

getOutgoingNames

public Set<String> getOutgoingNames()

Specified by:

getOutgoingNames in interface io.smallrye.reactive.messaging.ChannelRegistry

getEmitterNames

public Set<String> getEmitterNames()

Specified by:

getEmitterNames in interface io.smallrye.reactive.messaging.ChannelRegistry

getIncomingChannels

public Map<String,Boolean> getIncomingChannels()

Specified by:

getIncomingChannels in interface io.smallrye.reactive.messaging.ChannelRegistry

getOutgoingChannels

public Map<String,Boolean> getOutgoingChannels()

Specified by:

getOutgoingChannels in interface io.smallrye.reactive.messaging.ChannelRegistry

register

public void register(String name,
 io.smallrye.reactive.messaging.PausableChannel pausable)

Specified by:

register in interface io.smallrye.reactive.messaging.ChannelRegistry

getPausable

public io.smallrye.reactive.messaging.PausableChannel getPausable(String name)

Specified by:

getPausable in interface io.smallrye.reactive.messaging.ChannelRegistry