public void initMQSource()

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

• 12 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(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
            Destination destination = session.createQueue(activeMQQueue);
            messageProducer = session.createProducer(destination);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }