proper shutdown of executor in AbstractChannelAdapter and EndpointExecutor
This commit is contained in:
@@ -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();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -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();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -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();
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user