public class SourceDeclarer extends ExecutableComponentDeclarer<SourceDeclarer,SourceDeclaration>
SourceDeclaration
through a fluent APIdeclaration
Modifier and Type | Method and Description |
---|---|
SourceDeclarer |
hasResponse(boolean hasResponse)
Allows to specify if the declared source emits responses
|
SourceCallbackDeclarer |
onBackPressure()
Allows to declare a callback which is triggered when the runtime applies back pressure on a message
generated by the source
|
SourceCallbackDeclarer |
onError()
Allows to declare a callback which will listen for errors that occurred in the flow
processing a Source generated message.
|
SourceCallbackDeclarer |
onSuccess()
Allows to declare a callback which will listen to all the successful results of the dispatched
Source messages to the flow.
|
SourceCallbackDeclarer |
onTerminate()
Allows to declare a callback which will listen to all the results of the dispatched
Source messages to the flow.
|
SourceDeclarer |
runsOnPrimaryNodeOnly(boolean primaryNodeOnly)
Allows to specify whether the declared source should only run in the primary node when in cluster mode
|
requiresConnection, supportsStreaming, transactional, withNotificationModel, withOutput, withOutputAttributes
withChain, withChain, withComponent, withErrorModel, withModelProperty, withOptionalComponent, withRoute, withStereotype
describedAs, onDefaultParameterGroup, onParameterGroup
getDeclaration
public SourceDeclarer hasResponse(boolean hasResponse)
hasResponse
- Whether the declared source emits a responsethis
declarerpublic SourceDeclarer runsOnPrimaryNodeOnly(boolean primaryNodeOnly)
primaryNodeOnly
- whether to only run on the primary node or notthis
declarerpublic SourceCallbackDeclarer onSuccess()
SourceCallbackDeclarer
public SourceCallbackDeclarer onError()
SourceCallbackDeclarer
public SourceCallbackDeclarer onBackPressure()
SourceCallbackDeclarer
public SourceCallbackDeclarer onTerminate()
onSuccess()
()} and onError()
callbacks.SourceCallbackDeclarer
Copyright © 2018. All rights reserved.