How to parameterize an object in integration flow?Spring Integration - how to pass parameters into service activatorSpring IntegrationFlow for multiple JSON object patternsUsing header to build url in http outbound channel adapterSpring Integration Usage and Approach ValidationHow change default channel on Spring Integration Flow with Java DSLhow to send message to both kafka channel and jdbc with spring integration?Object Method Reference within Spring Integration FlowGateway not setting the replyChannel headerspring-integration: how to deliver deferred details as SSEHandling MessageHandlingException with advice and continue the flow spring integration dsl
Why does trim() NOT remove char 160?
Are modern clipless shoes and pedals that much better than toe clips and straps?
Is a player able to change alignment midway through an adventure?
In the MCU, why does Mjölnir retain its enchantments after Ragnarok?
Why do all fields in a QFT transform like *irreducible* representations of some group?
Why did MS-DOS applications built using Turbo Pascal fail to start with a division by zero error on faster systems?
Who was president?
Why is Boris Johnson visiting only Paris & Berlin if every member of the EU needs to agree on a withdrawal deal?
What is the hex versus octal timeline?
Photoshop CS6 - Remove glare/hue from image
What is the history of the university asylum law?
Why is less being run unnecessarily by git?
If the first law of thermodynamics ensures conservation of energy, why does it allow systems to lose energy?
Can pay be witheld for hours cleaning up after closing time?
Compelling story with the world as a villain
Is there any way to keep a player from killing an NPC?
What to say to a student who has failed?
What does どうかと思う mean?
Are there account age or level requirements for obtaining special research?
Is there a known non-euclidean geometry where two concentric circles of different radii can intersect? (as in the novel "The Universe Between")
Irish Snap: Variant Rules
How do I request a longer than normal leave of absence period for my wedding?
Is it safe to remove the bottom chords of a series of garage roof trusses?
Why does The Ancient One think differently about Doctor Strange in Endgame than the film Doctor Strange?
How to parameterize an object in integration flow?
Spring Integration - how to pass parameters into service activatorSpring IntegrationFlow for multiple JSON object patternsUsing header to build url in http outbound channel adapterSpring Integration Usage and Approach ValidationHow change default channel on Spring Integration Flow with Java DSLhow to send message to both kafka channel and jdbc with spring integration?Object Method Reference within Spring Integration FlowGateway not setting the replyChannel headerspring-integration: how to deliver deferred details as SSEHandling MessageHandlingException with advice and continue the flow spring integration dsl
.everyoneloves__top-leaderboard:empty,.everyoneloves__mid-leaderboard:empty,.everyoneloves__bot-mid-leaderboard:empty margin-bottom:0;
I has integration flow for polling data from database. I set up message source which return list of object, this list I want to pass to method handle in subFlow.
It's code for this goals, but I get a compilation error: incompatible types Message to List.
@Bean
public IntegrationFlow integrationFlow(
DataSource dataSource,
MessageHandler amqpHandler,
PersonService personService,
PersonChecker personChecker)
return IntegrationFlows
.from(getMessageSource(personService::getPersons), e -> e.poller(getPollerSpec()))
.wireTap(subFlow -> subFlow.handle(personChecker::checkPerson))
.split()
.publishSubscribeChannel(pubSub -> pubSub
.subscribe(flow -> flow.bridge()
.transform(Transformers.toJson())
.handle(amqpHandler))
.subscribe(flow -> flow.bridge()
.handle(personService::markAsSent)))
.get();
I know about solution to pass service and name of method handle(personChecker, checkPerson), but it's not suitable for me.
Is exists possibility to pass in wireTap subflow in method handle list with objects Person instead Message message?
spring-integration spring-integration-dsl
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
add a comment |
I has integration flow for polling data from database. I set up message source which return list of object, this list I want to pass to method handle in subFlow.
It's code for this goals, but I get a compilation error: incompatible types Message to List.
@Bean
public IntegrationFlow integrationFlow(
DataSource dataSource,
MessageHandler amqpHandler,
PersonService personService,
PersonChecker personChecker)
return IntegrationFlows
.from(getMessageSource(personService::getPersons), e -> e.poller(getPollerSpec()))
.wireTap(subFlow -> subFlow.handle(personChecker::checkPerson))
.split()
.publishSubscribeChannel(pubSub -> pubSub
.subscribe(flow -> flow.bridge()
.transform(Transformers.toJson())
.handle(amqpHandler))
.subscribe(flow -> flow.bridge()
.handle(personService::markAsSent)))
.get();
I know about solution to pass service and name of method handle(personChecker, checkPerson), but it's not suitable for me.
Is exists possibility to pass in wireTap subflow in method handle list with objects Person instead Message message?
spring-integration spring-integration-dsl
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
add a comment |
I has integration flow for polling data from database. I set up message source which return list of object, this list I want to pass to method handle in subFlow.
It's code for this goals, but I get a compilation error: incompatible types Message to List.
@Bean
public IntegrationFlow integrationFlow(
DataSource dataSource,
MessageHandler amqpHandler,
PersonService personService,
PersonChecker personChecker)
return IntegrationFlows
.from(getMessageSource(personService::getPersons), e -> e.poller(getPollerSpec()))
.wireTap(subFlow -> subFlow.handle(personChecker::checkPerson))
.split()
.publishSubscribeChannel(pubSub -> pubSub
.subscribe(flow -> flow.bridge()
.transform(Transformers.toJson())
.handle(amqpHandler))
.subscribe(flow -> flow.bridge()
.handle(personService::markAsSent)))
.get();
I know about solution to pass service and name of method handle(personChecker, checkPerson), but it's not suitable for me.
Is exists possibility to pass in wireTap subflow in method handle list with objects Person instead Message message?
spring-integration spring-integration-dsl
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
I has integration flow for polling data from database. I set up message source which return list of object, this list I want to pass to method handle in subFlow.
It's code for this goals, but I get a compilation error: incompatible types Message to List.
@Bean
public IntegrationFlow integrationFlow(
DataSource dataSource,
MessageHandler amqpHandler,
PersonService personService,
PersonChecker personChecker)
return IntegrationFlows
.from(getMessageSource(personService::getPersons), e -> e.poller(getPollerSpec()))
.wireTap(subFlow -> subFlow.handle(personChecker::checkPerson))
.split()
.publishSubscribeChannel(pubSub -> pubSub
.subscribe(flow -> flow.bridge()
.transform(Transformers.toJson())
.handle(amqpHandler))
.subscribe(flow -> flow.bridge()
.handle(personService::markAsSent)))
.get();
I know about solution to pass service and name of method handle(personChecker, checkPerson), but it's not suitable for me.
Is exists possibility to pass in wireTap subflow in method handle list with objects Person instead Message message?
spring-integration spring-integration-dsl
spring-integration spring-integration-dsl
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
asked Mar 27 at 16:44
RomanRoman
316 bronze badges
316 bronze badges
add a comment |
add a comment |
1 Answer
1
active
oldest
votes
.handle((p, h) -> personService.checkPerson(p))
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
add a comment |
Your Answer
StackExchange.ifUsing("editor", function ()
StackExchange.using("externalEditor", function ()
StackExchange.using("snippets", function ()
StackExchange.snippets.init();
);
);
, "code-snippets");
StackExchange.ready(function()
var channelOptions =
tags: "".split(" "),
id: "1"
;
initTagRenderer("".split(" "), "".split(" "), channelOptions);
StackExchange.using("externalEditor", function()
// Have to fire editor after snippets, if snippets enabled
if (StackExchange.settings.snippets.snippetsEnabled)
StackExchange.using("snippets", function()
createEditor();
);
else
createEditor();
);
function createEditor()
StackExchange.prepareEditor(
heartbeatType: 'answer',
autoActivateHeartbeat: false,
convertImagesToLinks: true,
noModals: true,
showLowRepImageUploadWarning: true,
reputationToPostImages: 10,
bindNavPrevention: true,
postfix: "",
imageUploader:
brandingHtml: "Powered by u003ca class="icon-imgur-white" href="https://imgur.com/"u003eu003c/au003e",
contentPolicyHtml: "User contributions licensed under u003ca href="https://creativecommons.org/licenses/by-sa/3.0/"u003ecc by-sa 3.0 with attribution requiredu003c/au003e u003ca href="https://stackoverflow.com/legal/content-policy"u003e(content policy)u003c/au003e",
allowUrls: true
,
onDemand: true,
discardSelector: ".discard-answer"
,immediatelyShowMarkdownHelp:true
);
);
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55382457%2fhow-to-parameterize-an-object-in-integration-flow%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
1 Answer
1
active
oldest
votes
1 Answer
1
active
oldest
votes
active
oldest
votes
active
oldest
votes
.handle((p, h) -> personService.checkPerson(p))
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
add a comment |
.handle((p, h) -> personService.checkPerson(p))
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
add a comment |
.handle((p, h) -> personService.checkPerson(p))
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
.handle((p, h) -> personService.checkPerson(p))
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
answered Mar 27 at 17:00
Gary RussellGary Russell
93.3k9 gold badges58 silver badges85 bronze badges
93.3k9 gold badges58 silver badges85 bronze badges
add a comment |
add a comment |
Got a question that you can’t ask on public Stack Overflow? Learn more about sharing private information with Stack Overflow for Teams.
Got a question that you can’t ask on public Stack Overflow? Learn more about sharing private information with Stack Overflow for Teams.
Thanks for contributing an answer to Stack Overflow!
- Please be sure to answer the question. Provide details and share your research!
But avoid …
- Asking for help, clarification, or responding to other answers.
- Making statements based on opinion; back them up with references or personal experience.
To learn more, see our tips on writing great answers.
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
StackExchange.ready(
function ()
StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f55382457%2fhow-to-parameterize-an-object-in-integration-flow%23new-answer', 'question_page');
);
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Sign up or log in
StackExchange.ready(function ()
StackExchange.helpers.onClickDraftSave('#login-link');
);
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Sign up using Google
Sign up using Facebook
Sign up using Email and Password
Post as a guest
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
Required, but never shown
