Remove throws InterruptedException from sample main
This commit is contained in:
@@ -8,7 +8,7 @@ Here's a sample source module (output channel only):
|
||||
@ComponentScan(basePackageClasses=TimerSource.class)
|
||||
public class ModuleApplication {
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(ModuleApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
@@ -14,10 +14,10 @@ public class DoubleApplication implements AggregateConfigurer {
|
||||
@Override
|
||||
public void configure(AggregateBuilder builder) {
|
||||
builder.from(SourceModuleDefinition.class).as("source")
|
||||
.to(SinkModuleDefinition.class).as("sink");
|
||||
.to(SinkModuleDefinition.class).as("sink");
|
||||
}
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(DoubleApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
@@ -23,7 +23,7 @@ public class ExtendedApplication implements AggregateConfigurer {
|
||||
// @formatter:on
|
||||
}
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(ExtendedApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@ import sink.LogSink;
|
||||
@ComponentScan(basePackageClasses=LogSink.class)
|
||||
public class SinkApplication {
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(SinkApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@ import source.TimeSource;
|
||||
@ComponentScan(basePackageClasses=TimeSource.class)
|
||||
public class SourceApplication {
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(SourceApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@ import config.TappingLoggingSink;
|
||||
@ComponentScan(basePackageClasses= TappingLoggingSink.class)
|
||||
public class TapApplication {
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(TapApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
@@ -10,7 +10,7 @@ import transform.LoggingTransformer;
|
||||
@ComponentScan(basePackageClasses=LoggingTransformer.class)
|
||||
public class TransformApplication {
|
||||
|
||||
public static void main(String[] args) throws InterruptedException {
|
||||
public static void main(String[] args) {
|
||||
SpringApplication.run(TransformApplication.class, args);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user