import static org.mule.runtime.extension.api.annotation.param.MediaType.ANY;

import org.mule.runtime.extension.api.annotation.param.Config;

import org.mule.runtime.extension.api.annotation.param.MediaType;


//

import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class ProduceOperations {

	@MediaType(value = ANY, strict = false)
	  public void produceInfo(@Config AdvanceConfiguration configuration) throws JMSException{

		// URL of the JMS server. DEFAULT_BROKER_URL will just mean
		// that JMS server is on localhost
		String url = ActiveMQConnection.DEFAULT_BROKER_URL;
		// default broker URL is : tcp://localhost:61616"

		String subject = "gslab"; //Queue Name
		// You can create any/many queue names as per your requirement.


		// Getting JMS connection from the server and starting it
		ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
		javax.jms.Connection connection = connectionFactory.createConnection();
		connection.start();
		// JMS messages are sent and received using a Session. We will
		// create here a non-transactional session object. If you want
		// to use transactions you should set the first parameter to 'true'
		Session session = connection.createSession(false,
		Session.AUTO_ACKNOWLEDGE);
		// Destination represents here our queue 'VALLYSOFTQ' on the
		// JMS server. You don't have to do anything special on the
		// server to create it, it will be created automatically.
		Destination destination = session.createQueue(subject);
		// MessageProducer is used for sending messages (as opposed
		// to MessageConsumer which is used for receiving them)
		MessageProducer producer = session.createProducer(destination);
		// We will send a small text message saying 'Hello' in Japanese
		TextMessage message = session.createTextMessage(configuration.getMessage());
		//TextMessage message = session.createTextMessage("Hello welcome come to vallysoft ActiveMQ!");
		// Here we are sending the message!
		producer.send(message);
		System.out.println("Sentage '" + message.getText() + "'");

		connection.close();
	  }


}