[jboss-svn-commits] JBL Code SVN: r8053 - labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway

jboss-svn-commits at lists.jboss.org jboss-svn-commits at lists.jboss.org
Mon Dec 4 16:08:46 EST 2006


Author: b_georges
Date: 2006-12-04 16:08:44 -0500 (Mon, 04 Dec 2006)
New Revision: 8053

Modified:
   labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FileGatewayListener.java
Log:


Modified: labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FileGatewayListener.java
===================================================================
--- labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FileGatewayListener.java	2006-12-04 17:26:41 UTC (rev 8052)
+++ labs/jbossesb/workspace/b_georges/product/core/listeners/src/org/jboss/soa/esb/listeners/gateway/FileGatewayListener.java	2006-12-04 21:08:44 UTC (rev 8053)
@@ -1,162 +1,162 @@
-/*
- * JBoss, Home of Professional Open Source
- * Copyright 2006, JBoss Inc., and individual contributors as indicated
- * by the @authors tag. See the copyright.txt in the distribution for a
- * full listing of individual contributors.
- *
- * This is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as
- * published by the Free Software Foundation; either version 2.1 of
- * the License, or (at your option) any later version.
- *
- * This software is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this software; if not, write to the Free
- * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
- * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */
-
-package org.jboss.soa.esb.listeners.gateway;
-
-import java.io.ByteArrayOutputStream;
-import java.io.File;
-import java.io.FileFilter;
-import java.io.FileInputStream;
-import java.io.IOException;
-
-import org.jboss.soa.esb.helpers.ConfigTree;
-import org.jboss.soa.esb.listeners.ListenerTagNames;
-import org.jboss.soa.esb.message.Message;
-import org.jboss.soa.esb.message.format.MessageFactory;
-import org.jboss.soa.esb.util.Util;
-
-public class FileGatewayListener extends AbstractFileGateway 
-{
-	protected FileGatewayListener() {}
-    public FileGatewayListener(GatewayListenerController commandListener, ConfigTree config)
-    	throws Exception
-    {
-    	super(commandListener,config);
-    	  _fileFilter = new FileEndsWith(_inputSuffix);
-    }
-
-    protected void checkMyParms() throws Exception 
-    {
-    	super.checkMyParms();
-    }
-
-	@Override
-    protected void seeIfOkToWorkOnDir (File p_oDir) throws GatewayException
-	{
-      if (! p_oDir.exists())   
-    	  throw new GatewayException ("Directory "+p_oDir.toString()+" not found");
-      if (!p_oDir.isDirectory())
-    	  throw new GatewayException(p_oDir.toString()+" is not a directory");
-      if (!p_oDir.canRead())
-    	  throw new GatewayException("Can't read directory "+p_oDir.toString());
-      if (! p_oDir.canWrite()) 
-    	  throw new GatewayException ("Can't write/rename in directory "+p_oDir.toString());
-	} //________________________________
-
-	@Override
-	boolean deleteFile(File file) throws GatewayException 
-	{
-		return file.delete();
-	}
-
-
-	@Override
-	byte[] getFileContents(File file) throws GatewayException 
-	{
-		try
-		{
-    		ByteArrayOutputStream out = new ByteArrayOutputStream();
-    		byte[] ba = new byte[1000];
-    		int iQread;
-			FileInputStream inp = new FileInputStream(file);
-			while (-1!= (iQread=inp.read(ba)))
-				if (iQread > 0)
-					out.write(ba,0,iQread);
-			inp.close();
-    		out.close();
-    		return out.toByteArray();
-		}
-		catch (IOException e) { throw new GatewayException(e); }
-	}
-
-
-	@Override
-	File[] getFileList(String suffix) throws GatewayException 
-	{
-		return _inputDirectory.listFiles(_fileFilter);
-	}
-
-
-	@Override
-	boolean renameFile(File from, File to) throws GatewayException 
-	{
-		return from.renameTo(to);
-	}
-	
-	@Override
-	void getDefaultComposer() throws GatewayException 
-	{
-    	_composerName = PackageFileContents.class.getName();
-    	_composerClass= PackageFileContents.class;
-    	_composer	= new PackageFileContents();
-    	_logger.warn("No <"+ListenerTagNames.ACTION_ELEMENT_TAG+"> element found in cofiguration"
-    			+" -  Using default composer class : "+_composerName);
-	}
-//______________________________________________________________________________
-    /**
-     * Default gateway action for files
-     * <p/>It will just drop the file contents into a Message
-     * @author <a href="mailto:schifest at heuristica.com.ar">schifest at heuristica.com.ar</a>
-     * @since Version 4.0
-     *
-     */
-    public class PackageFileContents
-    {
-    	public Message process (Object obj) throws Exception
-    	{
-    		if (! (obj instanceof File))
-    			throw new Exception ("Object must be instance of File");
-
-    		Message message = MessageFactory.getInstance().getMessage();
-    		message.getBody().setContents(getFileContent((File)obj));    		
-    		return message;
-    	}
-    	
-    	private byte[] getFileContent(File file) throws Exception
-    		{ return getFileContents(file); }
-    } //____________________________________________________
-    
-    /**
-     *  Simple file filter for local filesystem
-     *  Will accept only files that end with the String supplied at constructor time 
-     *
-     */
-    private class FileEndsWith implements FileFilter
-    {
-      String m_sSuffix;
-      FileEndsWith(String p_sEnd) throws Exception
-      {
-        m_sSuffix = p_sEnd;
-        if (Util.isNullString(m_sSuffix))
-          throw new Exception("Must specify file extension");
-      } //______________________________
-
-      public boolean accept(File p_f)
-      {	return (p_f.isFile())
-        	? p_f.toString().endsWith(m_sSuffix)
-        	: false;
-      } //______________________________
-    } //____________________________________________________
-
-    private FileFilter		_fileFilter;
-
-}
+/*
+ * JBoss, Home of Professional Open Source
+ * Copyright 2006, JBoss Inc., and individual contributors as indicated
+ * by the @authors tag. See the copyright.txt in the distribution for a
+ * full listing of individual contributors.
+ *
+ * This is free software; you can redistribute it and/or modify it
+ * under the terms of the GNU Lesser General Public License as
+ * published by the Free Software Foundation; either version 2.1 of
+ * the License, or (at your option) any later version.
+ *
+ * This software is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this software; if not, write to the Free
+ * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+ * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+ */
+
+package org.jboss.soa.esb.listeners.gateway;
+
+import java.io.ByteArrayOutputStream;
+import java.io.File;
+import java.io.FileFilter;
+import java.io.FileInputStream;
+import java.io.IOException;
+
+import org.jboss.soa.esb.helpers.ConfigTree;
+import org.jboss.soa.esb.listeners.ListenerTagNames;
+import org.jboss.soa.esb.message.Message;
+import org.jboss.soa.esb.message.format.MessageFactory;
+import org.jboss.soa.esb.util.Util;
+
+public class FileGatewayListener extends AbstractFileGateway 
+{
+	protected FileGatewayListener() {}
+    public FileGatewayListener(GatewayListenerController commandListener, ConfigTree config)
+    	throws Exception
+    {
+    	super(commandListener,config);
+    	  _fileFilter = new FileEndsWith(_inputSuffix);
+    }
+
+    protected void checkMyParms() throws Exception 
+    {
+    	super.checkMyParms();
+    }
+
+	@Override
+    protected void seeIfOkToWorkOnDir (File p_oDir) throws GatewayException
+	{
+      if (! p_oDir.exists())   
+    	  throw new GatewayException ("Directory "+p_oDir.toString()+" not found");
+      if (!p_oDir.isDirectory())
+    	  throw new GatewayException(p_oDir.toString()+" is not a directory");
+      if (!p_oDir.canRead())
+    	  throw new GatewayException("Can't read directory "+p_oDir.toString());
+      if (! p_oDir.canWrite()) 
+    	  throw new GatewayException ("Can't write/rename in directory "+p_oDir.toString());
+	} //________________________________
+
+	@Override
+	boolean deleteFile(File file) throws GatewayException 
+	{
+		return file.delete();
+	}
+
+
+	@Override
+	byte[] getFileContents(File file) throws GatewayException 
+	{
+		try
+		{
+    		ByteArrayOutputStream out = new ByteArrayOutputStream();
+    		byte[] ba = new byte[1000];
+    		int iQread;
+			FileInputStream inp = new FileInputStream(file);
+			while (-1!= (iQread=inp.read(ba)))
+				if (iQread > 0)
+					out.write(ba,0,iQread);
+			inp.close();
+    		out.close();
+    		return out.toByteArray();
+		}
+		catch (IOException e) { throw new GatewayException(e); }
+	}
+
+
+	@Override
+	File[] getFileList(String suffix) throws GatewayException 
+	{
+		return _inputDirectory.listFiles(_fileFilter);
+	}
+
+
+	@Override
+	boolean renameFile(File from, File to) throws GatewayException 
+	{
+		return from.renameTo(to);
+	}
+	
+	@Override
+	void getDefaultComposer() throws GatewayException 
+	{
+    	_composerName = PackageFileContents.class.getName();
+    	_composerClass= PackageFileContents.class;
+    	_composer	= new PackageFileContents();
+    	_logger.warn("No <"+ListenerTagNames.ACTION_ELEMENT_TAG+"> element found in cofiguration"
+    			+" -  Using default composer class : "+_composerName);
+	}
+//______________________________________________________________________________
+    /**
+     * Default gateway action for files
+     * <p/>It will just drop the file contents into a Message
+     * @author <a href="mailto:schifest at heuristica.com.ar">schifest at heuristica.com.ar</a>
+     * @since Version 4.0
+     *
+     */
+    public class PackageFileContents
+    {
+    	public Message process (Object obj) throws Exception
+    	{
+    		if (! (obj instanceof File))
+    			throw new Exception ("Object must be instance of File");
+
+    		Message message = MessageFactory.getInstance().getMessage();
+    		message.getBody().setContents(getFileContent((File)obj));    		
+    		return message;
+    	}
+    	
+    	private byte[] getFileContent(File file) throws Exception
+    		{ return getFileContents(file); }
+    } //____________________________________________________
+    
+    /**
+     *  Simple file filter for local filesystem
+     *  Will accept only files that end with the String supplied at constructor time 
+     *
+     */
+    private class FileEndsWith implements FileFilter
+    {
+      String m_sSuffix;
+      FileEndsWith(String p_sEnd) throws Exception
+      {
+        m_sSuffix = p_sEnd;
+        if (Util.isNullString(m_sSuffix))
+          throw new Exception("Must specify file extension");
+      } //______________________________
+
+      public boolean accept(File p_f)
+      {	return (p_f.isFile())
+        	? p_f.toString().endsWith(m_sSuffix)
+        	: false;
+      } //______________________________
+    } //____________________________________________________
+
+    private FileFilter		_fileFilter;
+
+}




More information about the jboss-svn-commits mailing list