package hello;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;

import javax.jms.ConnectionFactory;
import javax.jms.Message;
import javax.jms.Queue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;

@Configuration
@ComponentScan({"hello"})
public class JmsConfig {
    @Autowired
    private Environment env;

    @Bean
    public ConnectionFactory jmsFactory() {
        return new ActiveMQConnectionFactory("tcp://localhost:61616");
    }

    @Bean
    public Queue destination() {
        return new ActiveMQQueue("TESTQUEUE");
    }
}

package hello;


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.jms.*;


@Component
public class QueueConsumer {
    private final ConnectionFactory connectionFactory;
    private final Queue queue;
    private MessageConsumer consumer;

    @Autowired
    public QueueConsumer(ConnectionFactory connectionFactory, Queue queue) {
        this.connectionFactory = connectionFactory;
        this.queue = queue;
    }

    void init() throws JMSException {
        Connection connection = connectionFactory.createConnection();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        consumer = session.createConsumer(queue);
        connection.start();
    }

    Message readMessage() {
        TextMessage message=null;
        try {
           message = (TextMessage) consumer.receive();
           System.out.println("Полученное сообщение "+message.getText());
        } catch (JMSException e) {
            e.printStackTrace();
        }

        return message;
    }
}

package hello;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;

@Service
public class QueueProducer {
    private final ConnectionFactory connectionFactory;

    private final Queue queue;

    private MessageProducer producer;
    Session session;

    @Autowired
    public QueueProducer(ConnectionFactory connectionFactory, Queue queue) {
        this.connectionFactory = connectionFactory;
        this.queue = queue;
    }

    @PostConstruct
    private void init() throws JMSException {
        Connection connection = connectionFactory.createConnection();
        session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        producer = session.createProducer(queue);

    }

    public void send(Long userId) throws JMSException {
        Message messages = session.createTextMessage(userId.toString());
        System.out.println("Отправляем "+userId.toString());
        producer.send(messages);
    }
}

public class App {
    public static void main(String[] args) {
        try (AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext()) {
            ctx.register(JmsConfig.class);
            ctx.refresh();
            QueueConsumer queueReader = ctx.getBean(QueueConsumer.class);
            QueueProducer queueWriter = ctx.getBean(QueueProducer.class);

            queueWriter.send(5L);
            queueReader.readMessage();
           
            queueWriter.send(2L);
            queueReader.readMessage();

        } catch (JMSException e) {
        //    e.printStackTrace();
        }
    }
}