An update, I replaced the older 3.2.3 version with Servicemix 3.3.1 and now I see debug messages "Polling directory /test" repeatedly in my console. I tried looking into the activities in jconsole. All Services and the endpoints are up and running.
But no notifications are displyed in the bean endpoint/ftp endpoint and ofcourse still the message I am printing from the bean is not visible :( Servicemix 3.3.1 documentation pointed that the ftp:poller will poll an ftp server, downloads the file and sends a JBI InOnly message to the registered JBI Service. In my example I am trying to hookup the bean service to the ftp poller so that it can receive the message. I am surely missing something which I am trying hard to debug :( Regards, Ramu -----Original Message----- From: ext Sr, Ramu (NSN - IN/Bangalore) [mailto:[email protected]] Sent: Tuesday, November 17, 2009 9:13 AM To: [email protected] Subject: FTP Poller component Hi All, I am trying to use ftp:poller component of servicemix. The requirement is very simple: Download a file from FTP Server to the local system and send a JBI message to another service unit. I am expecting the message to carry information regarding where the file was downloaded, so that I can take it up for processing in the bean. I deploy the service assembly and the Deployment was successful. But nothing happens after that. I am expecting to see my System.out statement printed on the console. I even enabled DEBUG, hoping to see some useful message. But no interesting messages there. I am using 2 components for this purpose. Files in the FTP Server location are XML. Can any of you help me in this? 1. FTP Poller <ftp:poller>: xbean.xml : ... <ftp:poller service="mediations:file" endpoint="MyFTPPollerEndpoint" targetService="mediations:fileListenerService" uri=ftp://me:m...@myftpserver/test"; /> 2. Listener Bean <bean:endpoint> and <bean>: xbean.xml: ... <bean:endpoint service="mediations:fileListenerService" endpoint="MyListenerEndpoint" bean="#listener"/> <bean id="listener" class="com.test.MyFileListener"/> MyFileListener.java .... public class MyFileListener implements MessageExchangeListener { @Resource private DeliveryChannel channel; public void onMessageExchange(MessageExchange exchange) throws MessagingException { System.out.println("############################## Received exchange: " + exchange); exchange.setStatus(ExchangeStatus.DONE); channel.send(exchange); } } Thanks for your help in advance Ramu
