@Profile("javaconfig")
@Bean
@ServiceActivator(inputChannel="fileWriterChannel")
public FileWritingMessageHandler fileWriter() {
  FileWritingMessageHandler handler =
      new FileWritingMessageHandler(new File("/tmp/sia5/files"));
  handler.setExpectReply(false);
  handler.setFileExistsMode(FileExistsMode.APPEND);
  handler.setAppendNewLine(true);
  return handler;
}
 

@Profile("javadsl")
@Bean
public IntegrationFlow fileWriterFlow() {
  return IntegrationFlows
      .from(MessageChannels.direct("textInChannel"))
      .<String, String>transform(t -> t.toUpperCase())
      .handle(Files
          .outboundAdapter(new File("/tmp/sia5/files"))
          .fileExistsMode(FileExistsMode.APPEND)
          .appendNewLine(true))
      .get(); 
}
 

@Test
public void fileExistsModeCanBeCustomized() {
	AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
	EnvironmentTestUtils.addEnvironment(context, "ftp.mode:FAIL");
	context.register(Conf.class);
	context.refresh();
	FtpSinkProperties properties = context.getBean(FtpSinkProperties.class);
	assertThat(properties.getMode(), equalTo(FileExistsMode.FAIL));
}
 

@Test
public void fileExistsModeCanBeCustomized() {
	AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext();
	EnvironmentTestUtils.addEnvironment(context, "sftp.mode:FAIL");
	context.register(Conf.class);
	context.refresh();
	SftpSinkProperties properties = context.getBean(SftpSinkProperties.class);
	assertThat(properties.getMode(), equalTo(FileExistsMode.FAIL));
}
 

@Bean
@ServiceActivator(inputChannel = "fileChannel")
public MessageHandler fileWritingMessageHandler() {
    FileWritingMessageHandler handler = new FileWritingMessageHandler(new File(OUTPUT_DIR));
    handler.setFileExistsMode(FileExistsMode.REPLACE);
    handler.setExpectReply(false);
    return handler;
}
 

public GcsMessageHandler(RemoteFileTemplate<BlobInfo> remoteFileTemplate, FileExistsMode mode) {
	super(remoteFileTemplate, mode);
}
 

@NotNull
public FileExistsMode getMode() {
	return this.mode;
}
 

public void setMode(FileExistsMode mode) {
	this.mode = mode;
}
 

public FileExistsMode getMode() {
	return mode;
}
 

public void setMode(FileExistsMode mode) {
	this.mode = mode;
}