Message redelivery on Exception

Ludo · April 2, 2020, 7:49am

I did put the code on GitHub to help the readability:

src/main/java/org/ludo/experiment/solace/config/JmsConfig.java

master

package org.ludo.experiment.solace.config;

import javax.jms.ConnectionFactory;

import org.apache.qpid.jms.JmsConnectionFactory;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jms.annotation.EnableJms;
import org.springframework.jms.config.DefaultJmsListenerContainerFactory;
import org.springframework.jms.connection.CachingConnectionFactory;
import org.springframework.jms.core.JmsTemplate;

@Configuration
@EnableJms
@ConditionalOnMissingBean(ConnectionFactory.class)
public class JmsConfig {
    @Bean
    public JmsConnectionFactory jmsConnectionFactory(JmsConfigurationProperties props) {
        JmsConnectionFactory factory = new JmsConnectionFactory();

This file has been truncated. show original

github.com/the8tre/solace-experiment

src/main/java/org/ludo/experiment/solace/controller/JmsTestController.java

fbaffec7a


      
              doSend("Q/" + queue, message);
          }
          
          private void doSend(String destination, String message) {
              Destination jmsDestination = null;
              if (destination.startsWith("Q/")) {
                  jmsDestination = new JmsQueue(destination);
              } else if (destination.startsWith("T/")) {
                  jmsDestination = new JmsTopic(destination);
              }
              jmsTemplate.convertAndSend(jmsDestination, message, new MessagePostProcessor() {
                  @Override
                  public Message postProcessMessage(Message message) throws JMSException {
                      message.setBooleanProperty("SOLACE_JMS_PROP_DEAD_MSG_QUEUE_ELIGIBLE", true);
                      return message;
                  }
              });
          }
          
          @JmsListener(destination = TEST_TOPIC, containerFactory = "topicListenerContainerFactory")
          public void receiveFromShortTopic(String message) {

Topic		Replies	Views
Reprocess messages from Dead Message Queue PubSub+ Event Broker	15	1569	February 11, 2021
Message redelivery for New Java API - if an exception or un-acknowledgement happened Training, Tips and Tricks java , spring-cloud-stream , java-api , connectors	2	274	October 9, 2023
MessageTTLAndDeadMessageQueue.java How to set up a queue for dead letter queues Connectors & Integrations java , queue , jcsmp	2	13	June 5, 2025
Clone Message in Java ? (for DMQ move to Main Queue) PubSub+ Event Broker java , dmq	4	27548	November 24, 2021
Spring cloud stream with solace General Discussions spring-cloud-stream	8	32663	October 11, 2021

Message redelivery on Exception

Related topics