public class PublishSubscribeSpec extends PublishSubscribeChannelSpec<PublishSubscribeSpec>
PublishSubscribeChannelSpec extension to configure as a general flow callback for sub-flows
as subscribers.channelPARSER, target| Modifier | Constructor and Description |
|---|---|
protected |
PublishSubscribeSpec() |
protected |
PublishSubscribeSpec(java.util.concurrent.Executor executor) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<java.lang.Object,java.lang.String> |
getComponentsToRegister() |
PublishSubscribeSpec |
id(java.lang.String id)
Configure the component identifier.
|
PublishSubscribeSpec |
subscribe(IntegrationFlow subFlow) |
applySequence, errorHandler, ignoreFailures, maxSubscribers, minSubscribersdatatype, doGet, interceptor, messageConverter, wireTap, wireTap, wireTap_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopprotected PublishSubscribeSpec()
protected PublishSubscribeSpec(@Nullable
java.util.concurrent.Executor executor)
public PublishSubscribeSpec id(java.lang.String id)
IntegrationComponentSpecbeanName to register the
bean in the application context for this component.id in class IntegrationComponentSpec<PublishSubscribeSpec,PublishSubscribeChannel>id - the id.public PublishSubscribeSpec subscribe(IntegrationFlow subFlow)
public java.util.Map<java.lang.Object,java.lang.String> getComponentsToRegister()
getComponentsToRegister in interface ComponentsRegistrationgetComponentsToRegister in class MessageChannelSpec<PublishSubscribeSpec,PublishSubscribeChannel>