From aee08797afe19de8a6c5697f6ffc733ef147511e Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Sat, 22 Dec 2007 16:27:33 +0000 Subject: [PATCH] proper shutdown of executor in AbstractChannelAdapter and EndpointExecutor --- .../integration/samples/helloworld/HelloWorldDemo.java | 1 + .../integration/samples/oddeven/OddEvenDemo.java | 3 +-- .../springframework/integration/samples/quote/QuoteDemo.java | 3 +-- 3 files changed, 3 insertions(+), 4 deletions(-) diff --git a/spring-integration-samples/src/main/java/org/springframework/integration/samples/helloworld/HelloWorldDemo.java b/spring-integration-samples/src/main/java/org/springframework/integration/samples/helloworld/HelloWorldDemo.java index 2615161ef9..60053ea54e 100644 --- a/spring-integration-samples/src/main/java/org/springframework/integration/samples/helloworld/HelloWorldDemo.java +++ b/spring-integration-samples/src/main/java/org/springframework/integration/samples/helloworld/HelloWorldDemo.java @@ -38,6 +38,7 @@ public class HelloWorldDemo { MessageChannel outputChannel = channelRegistry.lookupChannel("outputChannel"); inputChannel.send(new StringMessage(1, "World")); System.out.println(outputChannel.receive().getPayload()); + context.stop(); } } diff --git a/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/OddEvenDemo.java b/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/OddEvenDemo.java index a490f5f71c..e7e30eda61 100644 --- a/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/OddEvenDemo.java +++ b/spring-integration-samples/src/main/java/org/springframework/integration/samples/oddeven/OddEvenDemo.java @@ -24,10 +24,9 @@ import org.springframework.context.support.ClassPathXmlApplicationContext; */ public class OddEvenDemo { - public static void main(String[] args) throws Exception { + public static void main(String[] args) { AbstractApplicationContext context = new ClassPathXmlApplicationContext("oddEvenDemo.xml", OddEvenDemo.class); context.start(); - System.in.read(); } } diff --git a/spring-integration-samples/src/main/java/org/springframework/integration/samples/quote/QuoteDemo.java b/spring-integration-samples/src/main/java/org/springframework/integration/samples/quote/QuoteDemo.java index e48bd03bd5..09879c8711 100644 --- a/spring-integration-samples/src/main/java/org/springframework/integration/samples/quote/QuoteDemo.java +++ b/spring-integration-samples/src/main/java/org/springframework/integration/samples/quote/QuoteDemo.java @@ -24,9 +24,8 @@ import org.springframework.context.support.ClassPathXmlApplicationContext; */ public class QuoteDemo { - public static void main(String[] args) throws Exception { + public static void main(String[] args) { AbstractApplicationContext context = new ClassPathXmlApplicationContext("quoteDemo.xml", QuoteDemo.class); context.start(); - System.in.read(); } }