public MessageChannel gcsInputChannel() {
return MessageChannels.direct().get();
@InboundChannelAdapter(channel = "gcsInputChannel", poller = @Poller(fixedDelay = "5000"))
public MessageSource<File> (Storage gcs, GcpProjectIdProvider projectIdProvider)
GcsInboundFileSynchronizer synchronizer = new GcsInboundFileSynchronizer(gcs);
synchronizer.setRemoteDirectory(projectIdProvider.getProjectId());
GcsInboundFileSynchronizingMessageSource messageSource =
new GcsInboundFileSynchronizingMessageSource(synchronizer);
File localDirectory = Files.createTempDirectory("gcs");
messageSource.setLocalDirectory(localDirectory);