Author: bsnyder
Date: Thu Jan 10 12:46:58 2008
New Revision: 610925

URL: http://svn.apache.org/viewvc?rev=610925&view=rev
Log:
SM-1058 - Allow the File Binding Component to work in append mode.

Modified:
    
servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-file/src/main/java/org/apache/servicemix/file/FileSenderEndpoint.java

Modified: 
servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-file/src/main/java/org/apache/servicemix/file/FileSenderEndpoint.java
URL: 
http://svn.apache.org/viewvc/servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-file/src/main/java/org/apache/servicemix/file/FileSenderEndpoint.java?rev=610925&r1=610924&r2=610925&view=diff
==============================================================================
--- 
servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-file/src/main/java/org/apache/servicemix/file/FileSenderEndpoint.java
 (original)
+++ 
servicemix/smx3/trunk/deployables/bindingcomponents/servicemix-file/src/main/java/org/apache/servicemix/file/FileSenderEndpoint.java
 Thu Jan 10 12:46:58 2008
@@ -40,13 +40,16 @@
     private String tempFilePrefix = "servicemix-";
     private String tempFileSuffix = ".xml";
     private boolean autoCreateDirectory = true;
+    private boolean append = true;
 
 
     public FileSenderEndpoint() {
+        append = false;
     }
 
     public FileSenderEndpoint(FileComponent component, ServiceEndpoint 
endpoint) {
         super(component, endpoint);
+        append = false;
     }
 
     public void validate() throws DeploymentException {
@@ -79,7 +82,7 @@
             if (logger.isDebugEnabled()) {
                 logger.debug("Writing to file: " + newFile.getCanonicalPath());
             }
-            out = new BufferedOutputStream(new FileOutputStream(newFile));
+            out = new BufferedOutputStream(new FileOutputStream(newFile, 
append));
             marshaler.writeMessage(exchange, in, out, name);
             success = true;
         } finally {
@@ -145,6 +148,14 @@
 
     public void setAutoCreateDirectory(boolean autoCreateDirectory) {
         this.autoCreateDirectory = autoCreateDirectory;
+    }
+
+    public boolean isAppend() {
+        return append;
+    }
+
+    public void setAppend(boolean append) {
+        this.append = append;
     }
 
 }


Reply via email to