org.springframework.cloud.stream.aggregate

Class SharedChannelRegistry

java.lang.Object

org.springframework.cloud.stream.aggregate.SharedChannelRegistry

public class SharedChannelRegistry
extends Object

A registry for channels that can be shared between modules, used for module aggregation.

Author:

Marius Bogoevici

Constructor Summary

Constructors

Constructor and Description
SharedChannelRegistry()

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageChannel	get(String id)
Map<String,org.springframework.messaging.MessageChannel>	getAll()
void	register(String id, org.springframework.messaging.MessageChannel messageChannel)

Methods inherited from class java.lang.Object

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

Constructor Detail

SharedChannelRegistry

public SharedChannelRegistry()

Method Detail

get

public org.springframework.messaging.MessageChannel get(String id)

register

public void register(String id,
                     org.springframework.messaging.MessageChannel messageChannel)

getAll

public Map<String,org.springframework.messaging.MessageChannel> getAll()