春の統合/春のクラウドストリーム：どのように

Question

@inboundchanneladapter使用して単一のメッセージを送信するためには、私は次のコードを持っている：

@Bean 
    @InboundChannelAdapter(value = Source.OUTPUT, poller = @Poller(fixedDelay = "${fixedDelay}", maxMessagesPerPoll = "1")) 
    public MessageSource<String> timerMessageSource() { 
     logger.info("Sending Message"); 
     return() -> new GenericMessage<>(new SimpleDateFormat().format(new Date())); 
    } 

私は、単一のメッセージを送信できるように、ポーラーを無効にしたいです。それ、どうやったら出来るの？

Answer 1

このアプリケーションはstream :-)にはなりません。taskという1つのメッセージを送信するだけです。

Answer 2

コード：

public interface MessageChannels { 

    @Output("activationMsgQueue") 
    MessageChannel save(); 
} 

コード：

@Service 
@EnableBinding(MessageChannels.class) 
public class CloudStreamProducer implements MessageSender { 

    private static final Logger LOGGER = LoggerFactory 
     .getLogger(CloudStreamProducer.class); 

    @Autowired 
    MessageChannels msgChannel; 

    public void sendMessage(ActivationDataInfo msg) { 
     msgChannel.save().send(MessageBuilder.withPayload(msg).build()); 
     LOGGER.info("Sent Activation Message to apt Topic : Acct NO = " + msg.getAcctNo() 
      + " TN = " + msg.getTn() + " FlowType = " + msg.getFlowType()); 
    } 

}