how to stop message from being sent to next solace topic while going through chain of function?

ajinkyasagar

how to stop message from being sent to next solace topic while going through chain of function?

e.g.

inTechVal|inFuncVal|map|persist|report-in-0: input
inTechVal|inFuncVal|map|persist|report-out-0: output

here message goes through inTechVal|inFuncVal|map|persist|report all of these functions but if i want to terminate and drop message in between how i can do it with solace streaming?

giri

Hi @ajinkyasagar

This is an interesting question indeed - first I want to draw the distinction between function composition and integration flows. If you would like to wield control over the flow in terms of message ack, drop or skip processing, Spring Integration would be a good choice. Spring Cloud Steam's function composition is just to sequence the execution via the use of one or more functions - and not necessarily a flow. If you notice the error channels are associated with the composed function (as a single entity), rather than at a function level.

Essentially, a function definition

inTechVal|inFuncVal|map|persist|report-in-0: input

would execute each of the functions before returning the outcome at the application level.

However, this can be managed at a logical level with custom property in the MesageHeader and Client Acknowledgement. The logic has to be composed entirely in the Spring boot application.

Please refer to the response to a similar question by Oleg Zhurakousky, a prominent member of Spring team here - https://stackoverflow.com/questions/70983396/spring-cloud-function-composition

I have put together a quick sample on how you might be able to manage this at the application level for function composition. Hope this helps.

uppercase|reverse|lowercase

This is just an approach - Let me know if this serves your purpose.

DemoApplication.txt