StackOverflow2013

Note that there are some explanatory texts on larger screens.

plurals

POHandle Null messages in Spring Integration
text
Body
copied!<p>I'm using spring integration( <code><int-ftp:outbound-gateway ></code>) to retrieve files from ftp server,</p> <p>First I couldn't continue the program if there were no files in the remote directory,I could solve that issue adding <code>default-reply-timeout="100"</code> to the <code><int:gateway></code>, after adding that I am getting null point exception which caused build failure.</p> <p>This is my full configuration file</p> <pre><code><?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:int="http://www.springframework.org/schema/integration" xmlns:p="http://www.springframework.org/schema/p" xmlns:int-ftp="http://www.springframework.org/schema/integration/ftp" xsi:schemaLocation="http://www.springframework.org/schema/integration/ftp http://www.springframework.org/schema/integration/ftp/spring-integration-ftp.xsd http://www.springframework.org/schema/integration http://www.springframework.org/schema/integration/spring-integration.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> <context:property-placeholder location="classpath:host.properties"/> <int:gateway id="gw" service-interface="com.util.ToFtpFlowGateway" default-request-channel="inbound" default-reply-timeout="100"/> <bean id="downloadProcessBean" class="com.util.FTPDownloadInterceptor"> <property name="fileType" value="txt"/> <property name="sourceType" value="ftp"/> <property name="destinationName" value="destinationName"/> <property name="destinationQueName" value="destinationQueName"/> <property name="sourceAddressDetails" value="sourceAddressDetails"/> <property name="sourceName" value="sourceName"/> </bean> <bean id="ftpSessionFactory" class="org.springframework.integration.ftp.session.DefaultFtpSessionFactory"> <property name="host" value="${local.host}"/> <property name="port" value="${local.availableServerPort}"/> <property name="username" value="${local.userid}"/> <property name="password" value="${local.user.password}"/> </bean> <int-ftp:outbound-gateway id="gatewayLS" cache-sessions="false" session-factory="ftpSessionFactory" request-channel="inbound" command="ls" command-options="" expression="payload" reply-channel="toSplitter" /> <int:channel id="toSplitter"> <int:interceptors> <int:wire-tap channel="logger"/> </int:interceptors> </int:channel> <int:logging-channel-adapter id="logger" log-full-message="true" /> <int:splitter id="splitter" input-channel="toSplitter" output-channel="toGet"/> <int-ftp:outbound-gateway id="gatewayGET" cache-sessions="false" local-directory="/home/udeshika/project/sxpmsg-distributer/req/local/download" session-factory="ftpSessionFactory" request-channel="toGet" reply-channel="toRemoveChannel" command="get" command-options="-P" expression="payload.remoteDirectory + '/' + payload.filename" reply-timeout="10"/> <int-ftp:outbound-gateway id="gatewayRM" session-factory="ftpSessionFactory" cache-sessions="false" expression="payload.remoteDirectory + '/'+ payload.filename" request-channel="toRemoveChannel" command="rm" reply-channel="aggregateResultsChannel" auto-create-local-directory="true" reply-timeout="10" />  <int:channel id="toRemoveChannel"> <int:interceptors> <int:wire-tap channel="logger2"/>  </int:interceptors> </int:channel> <bean class="org.springframework.integration.file.FileReadingMessageSource" p:directory="${download.directory}"/> <int:logging-channel-adapter id="logger2" log-full-message="true" /> <int-ftp:outbound-gateway id="gatewayRM" session-factory="ftpSessionFactory" cache-sessions="false" expression="headers['file_remoteDirectory'] + '/' + headers['file_remoteFile']" request-channel="toRemoveChannel" command="rm" reply-channel="aggregateResultsChannel"/> <int:aggregator input-channel="aggregateResultsChannel"/> </beans> </code></pre> <p>java code</p> <pre><code> rmResults = toFtpFlow.lsGetAndRmFiles("testftp"); if(null == rmResults)[ LOGGER.info("Null returned"); } </code></pre> <p>Error message</p> <pre><code>[INFO] ------------------------------------------------------------------------ [INFO] BUILD FAILURE [INFO] ------------------------------------------------------------------------ [INFO] Total time: 9.200s [INFO] Finished at: Thu Jun 20 15:48:43 IST 2013 [INFO] Final Memory: 15M/84M [INFO] ------------------------------------------------------------------------ [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.1.1:java (default) on project ftp: An exception occured while executing the Java class. null: InvocationTargetException: message must not be null -> [Help 1] [ERROR] [ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch. [ERROR] Re-run Maven using the -X switch to enable full debug logging. [ERROR] [ERROR] For more information about the errors and possible solutions, please read the following articles: [ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException </code></pre>

Querying!

Guidance

An individual column

Larger individual text columns get their own page to allow for proper reading.

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload