package io.trygvis.calamus.nexus;

import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.MessageProducer;
import javax.jms.Session;

import static javax.jms.Session.AUTO_ACKNOWLEDGE;

public class MqClient {

    ActiveMQConnectionFactory connectionFactory;

    public MqClient(String brokerUrl) {
        this.connectionFactory = new ActiveMQConnectionFactory(brokerUrl);
    }

    public void sendMessage(String repository, String groupId, String artifactId, String version, String type, String classifier) {
        try {
            Connection connection = connectionFactory.createConnection();
            connection.start();

            Session session = connection.createSession(false, AUTO_ACKNOWLEDGE);

            Destination destination = session.createQueue("nexus.new-artifact");

            MessageProducer producer = session.createProducer(destination);
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

            MapMessage message = session.createMapMessage();
            message.setString("repository", repository);
            message.setString("groupId", groupId);
            message.setString("artifactId", artifactId);
            message.setString("version", version);
            message.setString("type", type);
            message.setString("classifier", classifier);

            producer.send(message);

            session.close();
            connection.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}