AC.close() in file and ftp tests

basic/ftp/src/test/java/org/springframework/integration/samples/ftp/FtpOutboundChannelAdapterSample.java

@@ -75,7 +75,7 @@ public void runDemo() throws Exception{
 		assertTrue(new File(TestSuite.FTP_ROOT_DIR + File.separator + "b.txt").exists());
 
 		LOGGER.info("Successfully transfered file 'a.txt' and 'b.txt' to a remote FTP location.");
-
+		ctx.close();
 	}
 
 	@After

basic/mongodb/src/main/java/org/springframework/integration/samples/mongodb/util/DemoUtils.java

@@ -15,19 +15,20 @@
  */
 package org.springframework.integration.samples.mongodb.util;
 
+import com.mongodb.MongoClient;
+
 import org.springframework.data.mongodb.MongoDbFactory;
 import org.springframework.data.mongodb.core.MongoTemplate;
 import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
 
-import com.mongodb.Mongo;
 /**
  *
  * @author Oleg Zhurakousky
  */
 public class DemoUtils {
 
 	public static MongoDbFactory prepareMongoFactory(String... additionalCollectionToDrop) throws Exception{
-		MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(new Mongo(), "test");
+		MongoDbFactory mongoDbFactory = new SimpleMongoDbFactory(new MongoClient(), "test");
 		MongoTemplate template = new MongoTemplate(mongoDbFactory);
 		template.dropCollection("messages");
 		template.dropCollection("data");

intermediate/file-processing/src/test/java/org/springframework/integration/samples/fileprocessing/FileProcessingTest.java

@@ -10,7 +10,8 @@
 import org.apache.log4j.Logger;
 import org.junit.Before;
 import org.junit.Test;
-import org.springframework.context.ApplicationContext;
+
+import org.springframework.context.ConfigurableApplicationContext;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 import org.springframework.messaging.PollableChannel;
 
@@ -42,13 +43,14 @@ public void testSequentialFileProcessing() throws Exception {
 		    out.close();
 		}
 		logger.info("Populated directory with files");
-		Thread.sleep(5000);
+		Thread.sleep(2000);
 		logger.info("Starting Spring Integration Sequential File processing");
-		ApplicationContext ac = new ClassPathXmlApplicationContext("META-INF/spring/integration/sequentialFileProcessing-config.xml");
+		ConfigurableApplicationContext ac = new ClassPathXmlApplicationContext("META-INF/spring/integration/sequentialFileProcessing-config.xml");
 		PollableChannel filesOutChannel = ac.getBean("filesOutChannel", PollableChannel.class);
 		for (int i = 0; i < fileCount; i++) {
-			logger.info("Finished processing " + filesOutChannel.receive(20000).getPayload());
+			logger.info("Finished processing " + filesOutChannel.receive(10000).getPayload());
 		}
+		ac.stop();
 	}
 	@Test
 	public void testConcurrentFileProcessing() throws Exception {
@@ -63,10 +65,11 @@ public void testConcurrentFileProcessing() throws Exception {
 		logger.info("Populated directory with files");
 		Thread.sleep(2000);
 		logger.info("Starting Spring Integration Sequential File processing");
-		ApplicationContext ac = new ClassPathXmlApplicationContext("/META-INF/spring/integration/concurrentFileProcessing-config.xml");
+		ConfigurableApplicationContext ac = new ClassPathXmlApplicationContext("/META-INF/spring/integration/concurrentFileProcessing-config.xml");
 		PollableChannel filesOutChannel = ac.getBean("filesOutChannel", PollableChannel.class);
 		for (int i = 0; i < fileCount; i++) {
 			logger.info("Finished processing " + filesOutChannel.receive(10000).getPayload());
 		}
+		ac.stop();
 	}
 }