// Path: src/java/mql4j-core/src/main/java/com/mql4j/core/exception/Mql4jException.java
// @SuppressWarnings("serial")
// public class Mql4jException extends Exception {
// 	public Mql4jException(Throwable cause) {
// 		super(cause);
// 	}
// 
// 	public Mql4jException(String msg) {
// 		super(msg);
// 	}
// }


import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.mql4j.core.exception.Mql4jException;
package com.mql4j.activemq;




public class ActivemqClient {
	private final static Logger log = LoggerFactory.getLogger(ActivemqClient.class);
	private Connection connection;
	private Session session;
	private boolean connected;
	private TransactionType transactions;

	public ActivemqClient() {
		connected = false;
		transactions = TransactionType.NO_TRANSACTIONS;
		connection = null;
		session = null;
	}

// Path: src/java/mql4j-core/src/main/java/com/mql4j/core/exception/Mql4jException.java
// @SuppressWarnings("serial")
// public class Mql4jException extends Exception {
// 	public Mql4jException(Throwable cause) {
// 		super(cause);
// 	}
// 
// 	public Mql4jException(String msg) {
// 		super(msg);
// 	}
// }


// Path: src/java/mql4j-core/src/main/java/com/mql4j/activemq/ActivemqClient.java
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.MessageProducer;
import javax.jms.Queue;
import javax.jms.Session;
import javax.jms.Topic;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.mql4j.core.exception.Mql4jException;

package com.mql4j.activemq;




public class ActivemqClient {
	private final static Logger log = LoggerFactory.getLogger(ActivemqClient.class);
	private Connection connection;
	private Session session;
	private boolean connected;
	private TransactionType transactions;

	public ActivemqClient() {
		connected = false;
		transactions = TransactionType.NO_TRANSACTIONS;
		connection = null;
		session = null;
	}

	public void connect(final String brokerURI) throws Mql4jException, JMSException {