From f69dc4572cbda55b8e900165c3c6b02ba76e4840 Mon Sep 17 00:00:00 2001
From: Mark Fisher <markfisher@vmware.com>
Date: Wed, 23 Jul 2008 12:18:26 +0000
Subject: [PATCH] Removed the 'messageCreator' instance (it exists in the
 parent class: AbstractDirectorySource) and the 'setMessageCreator' method
 (INT-312).

---
 .../integration/adapter/file/FileSource.java      | 15 +--------------
 1 file changed, 1 insertion(+), 14 deletions(-)

diff --git a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/file/FileSource.java b/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/file/FileSource.java
index f784f71652..e92058c71c 100644
--- a/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/file/FileSource.java
+++ b/org.springframework.integration.adapter/src/main/java/org/springframework/integration/adapter/file/FileSource.java
@@ -22,7 +22,6 @@ import java.io.FilenameFilter;
 import java.io.IOException;
 import java.util.Map;
 
-import org.springframework.beans.factory.InitializingBean;
 import org.springframework.core.io.Resource;
 import org.springframework.integration.ConfigurationException;
 import org.springframework.integration.message.MessageCreator;
@@ -37,12 +36,10 @@ import org.springframework.util.Assert;
  * @author Mark Fisher
  * @author Marius Bogoevici
  */
-public class FileSource extends AbstractDirectorySource implements MessageSource<Object>, InitializingBean, MessageDeliveryAware {
+public class FileSource extends AbstractDirectorySource implements MessageSource<Object>, MessageDeliveryAware {
 
 	private final File directory;
 
-	private volatile MessageCreator<File, ?> messageCreator;
-
 	private volatile FileFilter fileFilter;
 
 	private volatile FilenameFilter filenameFilter;
@@ -68,10 +65,6 @@ public class FileSource extends AbstractDirectorySource implements MessageSource
 	}
 
 
-	public void setMessageCreator(MessageCreator<File, ?> messageCreator) {
-		this.messageCreator = messageCreator;
-	}
-
 	public void setFileFilter(FileFilter fileFilter) {
 		this.fileFilter = fileFilter;
 	}
@@ -80,12 +73,6 @@ public class FileSource extends AbstractDirectorySource implements MessageSource
 		this.filenameFilter = filenameFilter;
 	}
 
-	public void afterPropertiesSet() {
-		if (null == this.messageCreator) {
-			this.messageCreator = new FileMessageCreator();
-		}
-	}
-
 	@Override
 	protected void disconnect() {
 		// No action is necessary