public void releaseMQSource()

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


    public void releaseMQSource() {
        try {
            if (this.messageProducer != null) {
                this.messageProducer.close();
            }
            if (this.session != null) {
                this.session.close();
            }
            if (this.connection != null) {
                connection.close();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }