Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Next Next commit
Reduces checkstyle errors in eip-aggregator
  • Loading branch information
anuragagarwal561994 committed Nov 9, 2019
commit 4e89d4c74e39929357ec78ffcf183038110a8591
Original file line number Diff line number Diff line change
Expand Up @@ -30,21 +30,20 @@
import org.springframework.context.ConfigurableApplicationContext;

/**
* Sometimes in enterprise systems there is a need to group incoming data in order to process it as a whole. For example
* you may need to gather offers and after defined number of offers has been received you would like to choose the one
* with the best parameters.
*
* <p>
* Aggregator allows you to merge messages based on defined criteria and parameters. It gathers original messages,
* applies aggregation strategy and upon fulfilling given criteria, releasing merged messages.
* </p>
* Sometimes in enterprise systems there is a need to group incoming data in order to process it as
* a whole. For example you may need to gather offers and after defined number of offers has been
* received you would like to choose the one with the best parameters.
*
* <p>Aggregator allows you to merge messages based on defined criteria and parameters. It gathers
* original messages, applies aggregation strategy and upon fulfilling given criteria, releasing
* merged messages.
*/
@SpringBootApplication
public class App {

/**
* Program entry point. It starts Spring Boot application and using Apache Camel it auto-configures routes.
* Program entry point. It starts Spring Boot application and using Apache Camel it
* auto-configures routes.
*
* @param args command line args
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,16 +30,15 @@
/**
* Sample aggregator route definition.
*
* <p>
* It consumes messages out of the <i>direct:entry</i> entry point and forwards them to <i>direct:endpoint</i>.
* Route accepts messages containing String as a body, it aggregates the messages based on the settings and forwards
* them as CSV to the output chanel.
* <p>It consumes messages out of the <i>direct:entry</i> entry point and forwards them to
* <i>direct:endpoint</i>. Route accepts messages containing String as a body, it aggregates the
* messages based on the settings and forwards them as CSV to the output chanel.
*
* Settings for the aggregation are: aggregate until 3 messages are bundled or wait 2000ms before sending bundled
* messages further.
* </p>
* <p>Settings for the aggregation are: aggregate until 3 messages are bundled or wait 2000ms
* before sending bundled messages further.
*
* In this example input/output endpoints names are stored in <i>application.properties</i> file.
* <p>In this example input/output endpoints names are stored in <i>application.properties</i>
* file.
*/
@Component
public class AggregatorRoute extends RouteBuilder {
Expand All @@ -48,7 +47,8 @@ public class AggregatorRoute extends RouteBuilder {
private MessageAggregationStrategy aggregator;

/**
* Configures the route
* Configures the route.
*
* @throws Exception in case of exception during configuration
*/
@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,8 +28,8 @@
import org.springframework.stereotype.Component;

/**
* Aggregation strategy joining bodies of messages. If message is first one <i>oldMessage</i> is null. All changes are
* made on IN messages.
* Aggregation strategy joining bodies of messages. If message is first one <i>oldMessage</i> is
* null. All changes are made on IN messages.
*/
@Component
public class MessageAggregationStrategy implements AggregationStrategy {
Expand Down