Привет, я хочу реализовать такую функцию, как отправка сообщений sqs с заданной c задержкой доставки с использованием java и JmsTemplate. Собственно, я закончил реализацию отправки сообщений без задержек. как это:
@Override
public boolean sendMessage(String queueName, String message) throws EventBrokerException {
final String messageWithTransactionGuid = addTransactionGuidToMessage(message);
jmsTemplate.convertAndSend(queueName, messageWithTransactionGuid);
return isSuccess;
}
Я прочитал несколько статей, Может быть, мне нужно сделать что-то подобное ???
jmsTemplate.convertAndSend(queueName, messageWithTransactionGuid, new MessagePostProcessor() {
@Override
public Message postProcessMessage(Message message) throws JMSException {
message.setIntProperty(/*specify field name and delay seconds*/);
return message;
}
});
Но я не видел примеров, я читал исходный код и не выяснил, что указать, кто-нибудь может помочь?