Java 类javax.jms.XAJMSContext 实例源码

@Override
protected XAJMSContext createProviderContext(String username, String password, int sessionMode) {
    if (connectionFactory instanceof ConnectionFactory) {
        if (username == null && password == null) {
            return ((XAConnectionFactory) connectionFactory).createXAContext();
        } else {
            return ((XAConnectionFactory) connectionFactory).createXAContext(username, password);
        }
    } else {
        throw new javax.jms.IllegalStateRuntimeException("connectionFactory should implement javax.jms.ConnectionFactory");
    }
}

public XAJMSContext createXAContext() {
    return null;
}

public XAJMSContext createXAContext(String userName, String password) {
    return null;
}

@Override
public XAJMSContext createXAContext() {
   return createXAContext(null, null);
}

@Override
public XAJMSContext createXAContext() {
   incrementRefCounter();

   return new ActiveMQRAXAJMSContext(this, threadAwareContext);
}

@Override
public XAJMSContext createXAContext() {
   refCounter.increment();

   return new ActiveMQXAJMSContext(this, threadAwareContext);
}

@Override
public XAJMSContext createXAContext() {
   return createXAContext(user, password);
}

@Override
public XAJMSContext createXAContext() {
    return new XAJMSContextImpl(this, Session.SESSION_TRANSACTED, userName, password);
}

@Override
public XAJMSContext createXAContext(String userName, String password) {
    return new XAJMSContextImpl(this, Session.SESSION_TRANSACTED, userName, password);
}

@Override
public XAJMSContext createXAContext() {
    return doCallInTcclRuntimeException(obtainXaTargetConnectionFactory()::createXAContext);
}

@Override
public XAJMSContext createXAContext(String username, String password) {
    return doCallInTcclRuntimeException(() -> obtainXaTargetConnectionFactory().createXAContext(username, password));
}

XAJMSContext createXAContext();