[jboss-svn-commits] JBL Code SVN: r11827 - labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway.

[jboss-svn-commits at lists.jboss.org]

Author: derek.adams
Date: 2007-05-10 16:44:56 -0400 (Thu, 10 May 2007)
New Revision: 11827

Modified:
   labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java
Log:
Added property for original file name in messages created by file and FTP gateways.

Modified: labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java
===================================================================
--- labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java	2007-05-10 20:44:03 UTC (rev 11826)
+++ labs/jbossesb/trunk/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/AbstractFileGateway.java	2007-05-10 20:44:56 UTC (rev 11827)
@@ -48,6 +48,7 @@
 import org.jboss.soa.esb.listeners.lifecycle.AbstractThreadedManagedLifecycle;
 import org.jboss.soa.esb.listeners.lifecycle.ManagedLifecycleException;
 import org.jboss.soa.esb.listeners.lifecycle.ManagedLifecycleThreadState;
+import org.jboss.soa.esb.message.Message;
 import org.jboss.soa.esb.services.registry.RegistryException;
 import org.jboss.soa.esb.util.ClassUtil;
 import org.jboss.soa.esb.util.Util;
@@ -158,6 +159,8 @@
 						continue;
 					}
 					boolean bSent = false;
+                	Message outMessage = (Message) obj;
+                	outMessage.getProperties().setProperty(ORIGINAL_FILE_NAME_MSG_PROP, fileIn.getName());
 					for (EPR current : _targetEprs)
 					{
 						if (current instanceof FileEpr)
@@ -179,8 +182,7 @@
 						_courier = getCourier(current);
                                                 try
                                                 {
-                                                    if (_courier
-                                                    		.deliver((org.jboss.soa.esb.message.Message) obj))
+                                                    if (_courier.deliver(outMessage))
                                                     {
                                                     	bSent = true;
                                                     	break;
@@ -549,4 +551,7 @@
 			_errorSuffix;
 
 	protected FileFilter _fileFilter;
+	
+	/** Message property name for original filename */
+	public static final String ORIGINAL_FILE_NAME_MSG_PROP = "org.jboss.soa.esb.gateway.original.file.name";
 } // ____________________________________________________________________________