Enriching Header with the value from the Transformer












3















I have a spring integration flow. It reads the file. The file can belong to the consumer.Once I find the consumer I want to add that CONSUMER to the header so later on I can use e.g. In error handling I can check that did I even get the consumer looking at the header.



IntegrationsFlows.from(directorySource)
.transform(new ConsumerFinderTransformer()
.enrichHeaders(h -> h.header("CONSUMER" ,payload)


How do I get the payload in the enrichHeaders that's returned by the ConsumerFinderTransformer here.



I cannot find a way. Any help will be appreacited










share|improve this question



























    3















    I have a spring integration flow. It reads the file. The file can belong to the consumer.Once I find the consumer I want to add that CONSUMER to the header so later on I can use e.g. In error handling I can check that did I even get the consumer looking at the header.



    IntegrationsFlows.from(directorySource)
    .transform(new ConsumerFinderTransformer()
    .enrichHeaders(h -> h.header("CONSUMER" ,payload)


    How do I get the payload in the enrichHeaders that's returned by the ConsumerFinderTransformer here.



    I cannot find a way. Any help will be appreacited










    share|improve this question

























      3












      3








      3


      1






      I have a spring integration flow. It reads the file. The file can belong to the consumer.Once I find the consumer I want to add that CONSUMER to the header so later on I can use e.g. In error handling I can check that did I even get the consumer looking at the header.



      IntegrationsFlows.from(directorySource)
      .transform(new ConsumerFinderTransformer()
      .enrichHeaders(h -> h.header("CONSUMER" ,payload)


      How do I get the payload in the enrichHeaders that's returned by the ConsumerFinderTransformer here.



      I cannot find a way. Any help will be appreacited










      share|improve this question














      I have a spring integration flow. It reads the file. The file can belong to the consumer.Once I find the consumer I want to add that CONSUMER to the header so later on I can use e.g. In error handling I can check that did I even get the consumer looking at the header.



      IntegrationsFlows.from(directorySource)
      .transform(new ConsumerFinderTransformer()
      .enrichHeaders(h -> h.header("CONSUMER" ,payload)


      How do I get the payload in the enrichHeaders that's returned by the ConsumerFinderTransformer here.



      I cannot find a way. Any help will be appreacited







      java-8 spring-integration spring-integration-dsl






      share|improve this question













      share|improve this question











      share|improve this question




      share|improve this question










      asked Nov 18 '18 at 11:35









      MakkyMakky

      7,762144974




      7,762144974
























          1 Answer
          1






          active

          oldest

          votes


















          3














          This one is there for you:



              /**
          * Add a single header specification where the value is a String representation of a
          * SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
          * unless {@link #defaultOverwrite(boolean)} is true.
          * @param name the header name.
          * @param expression the expression.
          * @return the header enricher spec.
          */
          public HeaderEnricherSpec headerExpression(String name, String expression) {


          So, your code should be like:



          .enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)





          share|improve this answer
























          • Glad we have you on SO :) Thanks @Artem

            – Makky
            Nov 18 '18 at 16:11











          • But the normal API (Without expression) shouold have this method too

            – Makky
            Nov 18 '18 at 16:12











          • There is also a headerFunction() as variant

            – Artem Bilan
            Nov 18 '18 at 19:11











          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
          });


          }
          });














          draft saved

          draft discarded


















          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53360411%2fenriching-header-with-the-value-from-the-transformer%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









          3














          This one is there for you:



              /**
          * Add a single header specification where the value is a String representation of a
          * SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
          * unless {@link #defaultOverwrite(boolean)} is true.
          * @param name the header name.
          * @param expression the expression.
          * @return the header enricher spec.
          */
          public HeaderEnricherSpec headerExpression(String name, String expression) {


          So, your code should be like:



          .enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)





          share|improve this answer
























          • Glad we have you on SO :) Thanks @Artem

            – Makky
            Nov 18 '18 at 16:11











          • But the normal API (Without expression) shouold have this method too

            – Makky
            Nov 18 '18 at 16:12











          • There is also a headerFunction() as variant

            – Artem Bilan
            Nov 18 '18 at 19:11
















          3














          This one is there for you:



              /**
          * Add a single header specification where the value is a String representation of a
          * SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
          * unless {@link #defaultOverwrite(boolean)} is true.
          * @param name the header name.
          * @param expression the expression.
          * @return the header enricher spec.
          */
          public HeaderEnricherSpec headerExpression(String name, String expression) {


          So, your code should be like:



          .enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)





          share|improve this answer
























          • Glad we have you on SO :) Thanks @Artem

            – Makky
            Nov 18 '18 at 16:11











          • But the normal API (Without expression) shouold have this method too

            – Makky
            Nov 18 '18 at 16:12











          • There is also a headerFunction() as variant

            – Artem Bilan
            Nov 18 '18 at 19:11














          3












          3








          3







          This one is there for you:



              /**
          * Add a single header specification where the value is a String representation of a
          * SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
          * unless {@link #defaultOverwrite(boolean)} is true.
          * @param name the header name.
          * @param expression the expression.
          * @return the header enricher spec.
          */
          public HeaderEnricherSpec headerExpression(String name, String expression) {


          So, your code should be like:



          .enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)





          share|improve this answer













          This one is there for you:



              /**
          * Add a single header specification where the value is a String representation of a
          * SpEL {@link Expression}. If the header exists, it will <b>not</b> be overwritten
          * unless {@link #defaultOverwrite(boolean)} is true.
          * @param name the header name.
          * @param expression the expression.
          * @return the header enricher spec.
          */
          public HeaderEnricherSpec headerExpression(String name, String expression) {


          So, your code should be like:



          .enrichHeaders(h -> h.headerExpression(“CONSUMER" , “payload”)






          share|improve this answer












          share|improve this answer



          share|improve this answer










          answered Nov 18 '18 at 13:30









          Artem BilanArtem Bilan

          64.8k84668




          64.8k84668













          • Glad we have you on SO :) Thanks @Artem

            – Makky
            Nov 18 '18 at 16:11











          • But the normal API (Without expression) shouold have this method too

            – Makky
            Nov 18 '18 at 16:12











          • There is also a headerFunction() as variant

            – Artem Bilan
            Nov 18 '18 at 19:11



















          • Glad we have you on SO :) Thanks @Artem

            – Makky
            Nov 18 '18 at 16:11











          • But the normal API (Without expression) shouold have this method too

            – Makky
            Nov 18 '18 at 16:12











          • There is also a headerFunction() as variant

            – Artem Bilan
            Nov 18 '18 at 19:11

















          Glad we have you on SO :) Thanks @Artem

          – Makky
          Nov 18 '18 at 16:11





          Glad we have you on SO :) Thanks @Artem

          – Makky
          Nov 18 '18 at 16:11













          But the normal API (Without expression) shouold have this method too

          – Makky
          Nov 18 '18 at 16:12





          But the normal API (Without expression) shouold have this method too

          – Makky
          Nov 18 '18 at 16:12













          There is also a headerFunction() as variant

          – Artem Bilan
          Nov 18 '18 at 19:11





          There is also a headerFunction() as variant

          – Artem Bilan
          Nov 18 '18 at 19:11


















          draft saved

          draft discarded




















































          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.




          draft saved


          draft discarded














          StackExchange.ready(
          function () {
          StackExchange.openid.initPostLogin('.new-post-login', 'https%3a%2f%2fstackoverflow.com%2fquestions%2f53360411%2fenriching-header-with-the-value-from-the-transformer%23new-answer', 'question_page');
          }
          );

          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







          Popular posts from this blog

          How to pass form data using jquery Ajax to insert data in database?

          National Museum of Racing and Hall of Fame

          Guess what letter conforming each word