Hi,
Just to summarize my understanding a bit, I configured an FTPSource adapter to retrieve files from our FTP server i.e. I configured a adapter and a channel to listen to that adapter....which worked fine no issues...
I also wrote a message endpoint (MessageHandler if my understanding is correct) which listens on that channel like this just to see if it gets invoked by the message bus but it doesnt...so was wondering how would this thing work ? Any help would be appreciated..Thanks in advance
This is my message endpoint
This is my xml configurationCode:@MessageEndpoint(input="ftpChannel") public class FCPBFTPEndPoint { private static final Logger LOGGER = Logger.getLogger(FCPBFTPEndPoint.class); @Handler public void handleFtp(Message message){ LOGGER.debug("getting into this"); LOGGER.debug("This message is" +message); } }
Code:<message-bus/> <channel id="ftpChannel"/> <annotation-driven />


Reply With Quote