You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2006/10/29 23:27:48 UTC
svn commit: r469018 - in
/incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file:
FileComponent.java FilePollingEndpoint.java
Author: gnodet
Date: Sun Oct 29 14:27:47 2006
New Revision: 469018
URL: http://svn.apache.org/viewvc?view=rev&rev=469018
Log:
Fix polling endpoint
Modified:
incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FileComponent.java
incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FilePollingEndpoint.java
Modified: incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FileComponent.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FileComponent.java?view=diff&rev=469018&r1=469017&r2=469018
==============================================================================
--- incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FileComponent.java (original)
+++ incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FileComponent.java Sun Oct 29 14:27:47 2006
@@ -95,7 +95,7 @@
file = path;
}
else {
- // must be an abssolute URI
+ // must be an absolute URI
file = uri.getSchemeSpecificPart();
}
}
Modified: incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FilePollingEndpoint.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FilePollingEndpoint.java?view=diff&rev=469018&r1=469017&r2=469018
==============================================================================
--- incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FilePollingEndpoint.java (original)
+++ incubator/servicemix/trunk/servicemix-file/src/main/java/org/apache/servicemix/file/FilePollingEndpoint.java Sun Oct 29 14:27:47 2006
@@ -205,6 +205,7 @@
String name = aFile.getCanonicalPath();
InputStream in = new BufferedInputStream(new FileInputStream(aFile));
InOnly exchange = getExchangeFactory().createInOnlyExchange();
+ configureExchangeTarget(exchange);
NormalizedMessage message = exchange.createMessage();
exchange.setInMessage(message);
marshaler.readMessage(exchange, message, in, name);