SpringBoot 2.1.5 整合 OpenMQ

心已赠人 2021-09-20 05:52 250阅读 0赞

import com.sun.messaging.jmq.jmsclient.ConnectionImpl; 
    import com.sun.messaging.jmq.jmsclient.MessageImpl;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.jms.config.JmsListenerContainerFactory;
    import org.springframework.jms.connection.ConnectionFactoryUtils;
    import org.springframework.jms.connection.SingleConnectionFactory;
    import org.springframework.jms.core.JmsTemplate;
    import org.springframework.jms.core.MessageCreator;
    import org.springframework.stereotype.Component;
    import reactor.core.publisher.Mono;
    
    import javax.jms.*;
    import java.io.BufferedReader;
    import java.io.IOException;
    import java.io.InputStreamReader;
    
    @Slf4j
    @Component
    public class MessageProducer { 
        @Autowired
        JmsTemplate jmsTemplate;
    
        @Value("${destination.topic}")
        private String topicDestination;
    
    
        private Topic getTopic() { 
            return () -> "surcharge.update";
        }
    
        public Mono<String> sendMessage(String message) { 
    
            // Send a message with a POJO - the template reuse the message converter
            log.info("sending message='{}' to destination='{}'", message,
                    topicDestination);
            jmsTemplate.convertAndSend(topicDestination, new Email("info@example.com", message));
            return Mono.just(message + " send~");
        }
    
    }

import com.active.platform.modules.pos.service.config.Email;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.jms.annotation.JmsListener;
    import org.springframework.stereotype.Component;
    
    import java.util.concurrent.CountDownLatch;
    
    import static com.active.platform.modules.pos.service.config.JMSConfig.TOPIC_LISTENER_CONTAINER_FACTORY;
    
    
    @Slf4j
    @Component
    public class MessageConsumer { 
    
    
        private CountDownLatch latch = new CountDownLatch(2);
    
        public CountDownLatch getLatch() { 
            return latch;
        }
    
        @JmsListener(destination = "${destination.topic}", containerFactory = TOPIC_LISTENER_CONTAINER_FACTORY)
        public void receive1(Email message) { 
            log.info("'subscriber1' received message='{}'", message);
            latch.countDown();
        }
    
        @JmsListener(destination = "${destination.topic}", containerFactory = TOPIC_LISTENER_CONTAINER_FACTORY)
        public void receive2(Email message) { 
            log.info("'subscriber2' received message='{}'", message);
            latch.countDown();
        }
    }

> [https://codenotfound.com/spring-jms-topic-example.html][https_codenotfound.com_spring-jms-topic-example.html]

[https_codenotfound.com_spring-jms-topic-example.html]: https://codenotfound.com/spring-jms-topic-example.html