Class PublishSubscribeSpec
java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
org.springframework.integration.dsl.IntegrationComponentSpec<S,C>
org.springframework.integration.dsl.MessageChannelSpec<S,PublishSubscribeChannel>
org.springframework.integration.dsl.PublishSubscribeChannelSpec<PublishSubscribeSpec>
org.springframework.integration.dsl.PublishSubscribeSpec
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanClassLoaderAware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.FactoryBean<PublishSubscribeChannel>,org.springframework.beans.factory.InitializingBean,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,ComponentsRegistration
public class PublishSubscribeSpec extends PublishSubscribeChannelSpec<PublishSubscribeSpec>
The
PublishSubscribeChannelSpec extension to configure as a general flow callback for sub-flows
as subscribers.- Since:
- 5.0
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
PARSER, target -
Constructor Summary
Constructors Modifier Constructor Description protectedPublishSubscribeSpec()protectedPublishSubscribeSpec(java.util.concurrent.Executor executor) -
Method Summary
Modifier and Type Method Description java.util.Map<java.lang.Object,java.lang.String>getComponentsToRegister()PublishSubscribeSpecid(java.lang.String id)Configure the component identifier.PublishSubscribeSpecsubscribe(IntegrationFlow subFlow)Methods inherited from class org.springframework.integration.dsl.PublishSubscribeChannelSpec
applySequence, errorHandler, ignoreFailures, maxSubscribers, minSubscribersMethods inherited from class org.springframework.integration.dsl.MessageChannelSpec
datatype, doGet, interceptor, messageConverter, wireTap, wireTap, wireTapMethods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
-
Constructor Details
-
PublishSubscribeSpec
protected PublishSubscribeSpec() -
PublishSubscribeSpec
protected PublishSubscribeSpec(@Nullable java.util.concurrent.Executor executor)
-
-
Method Details
-
id
Description copied from class:IntegrationComponentSpecConfigure the component identifier. Used as thebeanNameto register the bean in the application context for this component.- Overrides:
idin classIntegrationComponentSpec<PublishSubscribeSpec,PublishSubscribeChannel>- Parameters:
id- the id.- Returns:
- the spec.
-
subscribe
-
getComponentsToRegister
public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()- Specified by:
getComponentsToRegisterin interfaceComponentsRegistration- Overrides:
getComponentsToRegisterin classMessageChannelSpec<PublishSubscribeSpec,PublishSubscribeChannel>
-