В JMS 2.0 factory.createContext() выбрасывает AbstractMethodError

Question

Я использую ActiveMq в качестве провайдера и JMS 2.0 API. Вторая строчка выкидывает AbstractMethodError, как это исправить?

1. ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
2. JMSContext context = factory.createContext();
3. context.createProducer().send(destination, msg);

Exception in thread "main" java.lang.AbstractMethodError: org.apache.activemq.ActiveMQConnectionFactory.createContext()Ljavax/jms/JMSContext; at jms.advance.Sender.sendMessage(Sender.java:41) at jms.advance.Sender.main(Sender.java:26)

Объект назначения я создал, используя следующие шаги.

ConnectionFactory factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);   
Connection connection = factory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("SAMPLE_test_QUEUE");

Ниже приведен полный фрагмент кода.

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.JMSRuntimeException;
import javax.jms.Session;

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

public class Sender {
    public String senderId;
    private ConnectionFactory factory = null;
    private Connection connection = null;
    private Session session = null;
    private Destination destination = null;

public static void main(String... arg) throws JMSException, InterruptedException{
    Sender sender = new Sender("facebook");
    int count = 1;
    for(int i=0; i <= 100; i++, count++){
        String msg = sender.senderId +": "+ "sending msg #" + count;
        sender.sendMessage(sender.factory, sender.destination, msg);
        Thread.sleep(3000);
    }
}
public Sender(String senderid) throws JMSRuntimeException, JMSException {
    this.senderId = senderid;
    factory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL);
    connection = factory.createConnection();
    connection.start();
    session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
    destination = session.createQueue("SAMPLE_test_QUEUE");

}

public void sendMessage(ConnectionFactory factory, Destination destination, String msg) throws JMSException{
    try(JMSContext context = factory.createContext()){
        context.createProducer().send(destination, msg);
    }catch(JMSRuntimeException e)
    {
        System.out.println(e);
    }

}
}

Answer 1

Если моя память верна, activemq еще не поддерживает JMS2. (связанная проблема в их JIRA все еще открыта: https://issues.apache.org/jira/browse/AMQ-5383)

Итак createContext() Метод не даст ожидаемых результатов. Однако вы все еще можете использовать метод createConnection() чтобы сделать работу, так как JMS2 имеет обратную совместимость JMS 1.1.