public void initMQSource()

in services/songs-service/src/main/java/org/apache/skywalking/showcase/services/song/mq/SongMessageReceiver.java [50:62]

• 13 lines of code
• 2 McCabe index (conditional complexity)

    public void initMQSource() {
        try {
            ConnectionFactory factory = new ActiveMQConnectionFactory(activeMQUrl);
            connection = factory.createConnection();
            connection.start();
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Destination destination = session.createQueue(activeMQQueue);
            messageConsumer = session.createConsumer(destination);
            new Thread(this::receiveMsg).start();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }