Hi,
I have a process that takes a message from an Active MQ queue, does some processing and then wants to put the Message.Body onto an FTP server. I wrote the following:
from("activemq:queue:ftplondon.INCOMING")
.process(singularityProcessor)
.recipientList(header(Constants.HEADER_FTP_ENDPOINT));
The message is processed correctly and contains the payload. The connection to the FTP server is also made correctly, however at the point of transfer an error occurs.
org.apache.camel.NoTypeConversionAvailableException: No type converter available to convert from type: class org.apache.camel.impl.DefaultMessage to the required type: java.io.InputStream with value Message: {message=<FSAMarketsFeed xmlns:cmn="
http://www.fsa.gov.uk/XMLSchema/FSAFeedCommon-v1-2" xmlns:ns2="
http://www.w3.org/2001/XMLSchema-instance" xmlns:ns1="....
I tried to resolve this by manually converting the body to an InputStream as follows:
from("activemq:queue:ftplondon.INCOMING")
.convertBodyTo(InputStream.class)
.recipientList(header(Constants.HEADER_FTP_ENDPOINT));
however this has had no effect and I still get the same error.
Any help would be greatly appreciated.
Many Thanks
Graham