I've attached a diff that should fix the parameter problems. The patch also updates the consumer with the ability to scan a file similar to the unix tail -f command.
Please review and change as necessary. http://www.nabble.com/file/p21341264/camel-stream-fix.zip camel-stream-fix.zip Stephen J wrote: > > It doesn't appear that the stream:file component works. It looks like it > doesn't recognize the file parameter. Here's the stack trace when you try > to use a uri like: stream:file?file=logTest.txt > > 125 [main] DEBUG org.apache.camel.impl.DefaultCamelContext - Adding > routes from: Routes: [Route[[From[stream:file?file=logTest.txt]] -> > [To[stream:out]]]] routes: [] > 125 [main] INFO org.apache.camel.impl.DefaultCamelContext - Apache > Camel (CamelContext:camel-1) is starting > 234 [main] DEBUG org.apache.camel.impl.DefaultComponentResolver - Found > component: stream via type: > org.apache.camel.component.stream.StreamComponent via: > META-INF/services/org/apache/camel/component/stream > 250 [main] DEBUG org.apache.camel.impl.DefaultComponent - Creating > endpoint uri=[stream:file?file=logTest.txt], path=[file], > parameters=[{file=logTest.txt}] > 265 [main] DEBUG org.apache.camel.impl.DefaultCamelContext - Failed to > resolve endpoint stream:file?file=logTest.txt. Reason: > org.apache.camel.ResolveEndpointFailedException: Failed to resolve > endpoint: stream:file?file=logTest.txt due to: There are 1 parameters that > couldn't be set on the endpoint. Check the uri if the parameters are spelt > correctly and that they are properties of the endpoint. Unknown > parameters=[{file=logTest.txt}] > org.apache.camel.ResolveEndpointFailedException: Failed to resolve > endpoint: stream:file?file=logTest.txt due to: There are 1 parameters that > couldn't be set on the endpoint. Check the uri if the parameters are spelt > correctly and that they are properties of the endpoint. Unknown > parameters=[{file=logTest.txt}] > at > org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:95) > at > org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:329) > at > org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:54) > at org.apache.camel.model.RouteType.resolveEndpoint(RouteType.java:96) > at > org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106) > at > org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112) > at org.apache.camel.model.FromType.resolveEndpoint(FromType.java:72) > at > org.apache.camel.impl.DefaultRouteContext.getEndpoint(DefaultRouteContext.java:81) > at org.apache.camel.model.RouteType.addRoutes(RouteType.java:239) > at org.apache.camel.model.RouteType.addRoutes(RouteType.java:86) > at > org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:660) > at > org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:650) > at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:49) > at cameltests.CometTest.main(CometTest.java:16) > Exception in thread "main" > org.apache.camel.ResolveEndpointFailedException: Failed to resolve > endpoint: stream:file?file=logTest.txt due to: > org.apache.camel.ResolveEndpointFailedException: Failed to resolve > endpoint: stream:file?file=logTest.txt due to: There are 1 parameters that > couldn't be set on the endpoint. Check the uri if the parameters are spelt > correctly and that they are properties of the endpoint. Unknown > parameters=[{file=logTest.txt}] > at > org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:349) > at > org.apache.camel.util.CamelContextHelper.getMandatoryEndpoint(CamelContextHelper.java:54) > at org.apache.camel.model.RouteType.resolveEndpoint(RouteType.java:96) > at > org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:106) > at > org.apache.camel.impl.DefaultRouteContext.resolveEndpoint(DefaultRouteContext.java:112) > at org.apache.camel.model.FromType.resolveEndpoint(FromType.java:72) > at > org.apache.camel.impl.DefaultRouteContext.getEndpoint(DefaultRouteContext.java:81) > at org.apache.camel.model.RouteType.addRoutes(RouteType.java:239) > at org.apache.camel.model.RouteType.addRoutes(RouteType.java:86) > at > org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:660) > at > org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:650) > at org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:49) > at cameltests.CometTest.main(CometTest.java:16) > Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to > resolve endpoint: stream:file?file=logTest.txt due to: There are 1 > parameters that couldn't be set on the endpoint. Check the uri if the > parameters are spelt correctly and that they are properties of the > endpoint. Unknown parameters=[{file=logTest.txt}] > at > org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:95) > at > org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:329) > ... 12 more > > > Claus Ibsen-2 wrote: >> >> Hi Stephen >> >> The @deprecated stuff might have been wrong in the wiki. The code is >> not @deprecated. >> >> Could you try using it. And let us know if it works nicely. >> The code is there to read from a file stream. >> >> And then we can remove the @deprecated stuff. >> >> And we could add a stream file consuming wiki sample that is missing. >> >> >> On Wed, Jan 7, 2009 at 2:59 PM, Stephen J <stephen.joy...@mclaneco.com> >> wrote: >>> >>> Is there a way to set up a file source as a stream instead of consuming >>> the >>> file? >>> >>> I've looked at the file component and it doesn't seem to support this >>> use. I >>> also looked at the stream component, but because the file feature of >>> that >>> component is deprecated I would be hesitant to use it. >>> >>> Basically I'd like something that would be similar to a unix "tail -f" >>> on a >>> text file. It would keep the file open, passing any content written by >>> other >>> programs through camel processors etc. to other camel defined endpoints. >>> >>> Is this possible? >>> -- >>> View this message in context: >>> http://www.nabble.com/File-Streaming-tp21331825s22882p21331825.html >>> Sent from the Camel - Users mailing list archive at Nabble.com. >>> >>> >> >> >> >> -- >> >> /Claus Ibsen >> Apache Camel Committer >> Blog: http://davsclaus.blogspot.com/ >> >> > > -- View this message in context: http://www.nabble.com/File-Streaming-tp21331825s22882p21341264.html Sent from the Camel - Users mailing list archive at Nabble.com.
