Fix StreamingInboundTests

Author: artembilan

spring-integration-file/src/test/java/org/springframework/integration/file/remote/StreamingInboundTests.java

@@ -98,6 +98,7 @@ public void testExceptionOnFetch() {
 		streamer.setRemoteDirectory("/bad");
 		streamer.afterPropertiesSet();
 		streamer.start();
+		streamer.receive();
 	}
 
 	@Test
@@ -226,14 +227,9 @@ public StringRemoteFileTemplate(SessionFactory<String> sessionFactory) {
 
 	public static class StringSessionFactory implements SessionFactory<String> {
 
-		private Session<String> singletonSession;
-
 		@SuppressWarnings("unchecked")
 		@Override
 		public Session<String> getSession() {
-			if (this.singletonSession != null) {
-				return this.singletonSession;
-			}
 			try {
 				Session<String> session = mock(Session.class);
 				willReturn(new String[] { "/foo/foo", "/foo/bar" }).given(session).list("/foo");
@@ -253,9 +249,6 @@ public Session<String> getSession() {
 				willThrow(new IOException("No file")).given(session).readRaw("/bad/file2");
 
 				given(session.finalizeRaw()).willReturn(true);
-
-				this.singletonSession = session;
-
 				return session;
 			}
 			catch (Exception e) {