Okay, I think I almost got it working, however when I run my test class I get the following exception:
ERROR 2009-07-01 11:54:47,404 [sftpConnector.receiver.1] org.mule.DefaultExceptionStrategy:
********************************************************************************
Message : Cannot route event as component "testComponent" is stopped. Component that caused exception is: SedaService{testComponent}. Message payload is of type: SftpInputStream
Type : org.mule.api.service.ServiceException
Code : MULE_ERROR--2
JavaDoc :
http://www.mulesource.org/docs/site/current2/apidocs/org/mule/api/service/ServiceException.htmlPayload : org.mule.transport.sftp.SftpInputStream@1ba64d
********************************************************************************
Exception stack is:
1. Cannot route event as component "testComponent" is stopped. Component that caused exception is: SedaService{testComponent}. Message payload is of type: SftpInputStream (org.mule.api.service.ServiceException)
org.mule.service.AbstractService:434 (
http://www.mulesource.org/docs/site/current2/apidocs/org/mule/api/service/ServiceException.html)
********************************************************************************
Root Exception stack trace:
org.mule.api.service.ServiceException: Cannot route event as component "testComponent" is stopped. Component that caused exception is: SedaService{testComponent}. Message payload is of type: SftpInputStream
at org.mule.service.AbstractService.dispatchEvent(AbstractService.java:434)
at org.mule.DefaultMuleSession.dispatchEvent(DefaultMuleSession.java:274)
at org.mule.routing.inbound.DefaultInboundRouterCollection.dispatch(DefaultInboundRouterCollection.java:223)
at org.mule.routing.inbound.DefaultInboundRouterCollection.route(DefaultInboundRouterCollection.java:192)
at org.mule.transport.AbstractMessageReceiver$DefaultInternalMessageListener.onMessage(AbstractMessageReceiver.java:364)
at org.mule.transport.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:252)
at org.mule.transport.AbstractMessageReceiver.routeMessage(AbstractMessageReceiver.java:175)
at org.mule.transport.sftp.SftpMessageReceiver.routeFile(SftpMessageReceiver.java:137)
at org.mule.transport.sftp.SftpMessageReceiver.poll(SftpMessageReceiver.java:60)
at org.mule.transport.PollingReceiverWorker.run(PollingReceiverWorker.java:47)
at org.mule.work.WorkerContext.run(WorkerContext.java:310)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1061)
at edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:575)
at java.lang.Thread.run(Thread.java:613)
********************************************************************************
From the debug info I see that the sftp is picking up a file from my remote machine but is somehow unable to pass it back to the running Mule instance?!?!
Here is some debug info just before the error occurs:
DEBUG 2009-07-01 12:04:32,787 [sftpConnector.receiver.1] org.mule.transport.sftp.SftpMessageReceiver: File is stable (not growing), ready for retrieval: 1.xml
INFO 2009-07-01 12:04:32,933 [sftpConnector.receiver.1] org.mule.transport.sftp.SftpConnector: Successfully connected to: sftp://user:
pswd@...:22/home/user/test/
INFO 2009-07-01 12:04:32,933 [sftpConnector.receiver.1] org.mule.transport.sftp.SftpClient: wd = /home/user/test/
DEBUG 2009-07-01 12:04:32,935 [sftpConnector.receiver.1] org.mule.transport.sftp.SftpMessageReceiver: Routing file: 1.xml
DEBUG 2009-07-01 12:04:32,945 [sftpConnector.receiver.1] org.mule.transport.sftp.SftpMessageReceiver: Message Received from: sftp://user:
pswd@...:22/home/user/test/
DEBUG 2009-07-01 12:04:32,947 [sftpConnector.receiver.1] org.mule.DefaultMuleSession: There is no session id on the request using key: ID. Generating new session id: 930b38e4-6626-11de-a5e9-056ef93084aa
DEBUG 2009-07-01 12:04:32,953 [sftpConnector.receiver.1] org.mule.DefaultMuleSession: dispatching event to service: testComponent, event is: MuleEvent: 930bae15-6626-11de-a5e9-056ef93084aa, sync=false, stop processing=false, DefaultInboundEndpoint{endpointUri=sftp://user:<password>@192.31.12.23/home/user/test/, connector=SftpConnector{this=93b3c, started=false, initialised=true, name='sftpConnector', disposed=false, numberOfConcurrentTransactedReceivers=4, createMultipleTransactedReceivers=true, connected=false, supportedProtocols=[sftp], serviceOverrides=null}, transformer=[], name='endpoint.sftp.192.31.12.23.22.home.user.test', properties={}, transactionConfig=Transaction{factory=null, action=NEVER, timeout=0}, filter=null, deleteUnacceptedMessages=false, securityFilter=null, synchronous=false, initialState=started, responseTimeout=10000, endpointEncoding=UTF-8}
Any help is again appreciated!
---------------------------------------------------------------------
To unsubscribe from this list, please visit:
http://xircles.codehaus.org/manage_email