How to use Aggregator EIP using Spring and Apache Camel?

แชร์
ฝัง
  • เผยแพร่เมื่อ 22 ต.ค. 2024

ความคิดเห็น • 11

  • @jasongoossens
    @jasongoossens 14 วันที่ผ่านมา +1

    I had to implement aggregation, and spent an afternoon trying it myself - this made it clear in 36mins!! Great tutorial!! I should always check your Camel playlist before getting started 😅

  • @sid-gcpb6493
    @sid-gcpb6493 2 ปีที่แล้ว +1

    This is a good example sir ... salute..

  • @rajkhare5949
    @rajkhare5949 ปีที่แล้ว +1

    very nice video with useful information...thanks!

  • @SuperAdilMorocco
    @SuperAdilMorocco ปีที่แล้ว +1

    Great ❤

  • @ranjithn6040
    @ranjithn6040 2 ปีที่แล้ว +1

    Very Clear explanation

  • @babai5655
    @babai5655 2 ปีที่แล้ว

    Спасибо! Очень полезный курс!

  • @AnilChauhan-kw2qh
    @AnilChauhan-kw2qh 3 ปีที่แล้ว +1

    Fantastic video
    Could you please explain how to read xml file and process the multiple record and based on the some status of the records perform specific action.
    How can we perform iteration and conditions on the records

  • @santoshvaraghanti
    @santoshvaraghanti 2 ปีที่แล้ว

    excellent example. Not related to aggregation but splitter , how to use tokenize trim option in dsl.

  • @khasimpathan7284
    @khasimpathan7284 2 ปีที่แล้ว +1

    Nice presentation

  • @onnoschmidt2859
    @onnoschmidt2859 7 หลายเดือนก่อน

    Is it also possible to consume different related messages from different endpoint's which slight different message format and have completion on the second message arrived?

    • @SagguUK
      @SagguUK  6 หลายเดือนก่อน

      Yes, you can aggregate messages from different endpoints with slightly different message formats. The Aggregate EIP allows you to combine multiple related messages into a single message based on certain criteria, such as a correlation identifier.
      This example will help you to understand:
      from("direct:endpoint1")
      .process(new Preprocessor1())
      .to("direct:aggregate");
      from("direct:endpoint2")
      .process(new Preprocessor2())
      .to("direct:aggregate");
      from("direct:aggregate")
      .aggregate(constant(true), new MyAggregationStrategy())
      .completionSize(2) // Wait for the arrival of 2 messages
      .to("direct:result");
      from("direct:result")
      .process(new ResultProcessor()); // Process the aggregated message