Java 类javax.jms.XAQueueSession 实例源码

项目：ats-framework 文件：ManagedSession.java

public static ManagedSession create( Session session ) {

        if ( (session instanceof XAQueueSession) && (session instanceof XATopicSession))
            return new ManagedXAQueueTopicSession(session);
        if (session instanceof XAQueueSession)
            return new ManagedXAQueueSession((XAQueueSession) session);
        if (session instanceof XATopicSession)
            return new ManagedXATopicSession((XATopicSession) session);
        if ( (session instanceof QueueSession) && (session instanceof TopicSession))
            return new ManagedQueueTopicSession(session);
        if (session instanceof QueueSession)
            return new ManagedQueueSession((QueueSession) session);
        if (session instanceof TopicSession)
            return new ManagedTopicSession((TopicSession) session);

        return new ManagedSession(session);
    }

项目：activemq-artemis 文件：ActiveMQRASessionFactoryImpl.java

/**
 * Create a XA queue session
 *
 * @return The XA queue session
 * @throws JMSException Thrown if an error occurs
 */
@Override
public XAQueueSession createXAQueueSession() throws JMSException {
   if (ActiveMQRASessionFactoryImpl.trace) {
      ActiveMQRALogger.LOGGER.trace("createXAQueueSession()");
   }

   checkClosed();

   if (type == ActiveMQRAConnectionFactory.CONNECTION || type == ActiveMQRAConnectionFactory.TOPIC_CONNECTION ||
      type == ActiveMQRAConnectionFactory.XA_TOPIC_CONNECTION) {
      throw new IllegalStateException("Can not get a topic session from a queue connection");
   }

   return allocateConnection(type);
}

项目：ats-framework 文件：ManagedXAQueueConnection.java

@Override
public XAQueueSession createXAQueueSession() throws JMSException {

    return addSession(xaConnection.createXAQueueSession());
}

项目：ats-framework 文件：ManagedXAQueueTopicConnection.java

@Override
public XAQueueSession createXAQueueSession() throws JMSException {

    return addSession( ((XAQueueConnection) connection).createXAQueueSession());
}

项目：ats-framework 文件：ManagedXAQueueSession.java

public ManagedXAQueueSession( final XAQueueSession session ) {

        super(session);
        xaQueueSession = session;
    }

项目：ats-framework 文件：ManagedXAQueueTopicSession.java

@Override
public QueueSession getQueueSession() throws JMSException {

    return addSession( ((XAQueueSession) session).getQueueSession());
}

项目：daq-eclipse 文件：ActiveMQXAConnection.java

public XAQueueSession createXAQueueSession() throws JMSException {
    return (XAQueueSession) createSession(true, Session.SESSION_TRANSACTED);
}

项目：activemq-artemis 文件：ActiveMQXAConnection.java

@Override
public XAQueueSession createXAQueueSession() throws JMSException {
   checkClosed();
   return (XAQueueSession) createSessionInternal(isXA(), true, Session.SESSION_TRANSACTED, ActiveMQSession.TYPE_QUEUE_SESSION);

}

项目：andes 文件：XAConnectionImpl.java

/**
 * Creates an XAQueueSession.
 *
 * @return A newly created XASession.
 * @throws JMSException If the XAQueueConnectionImpl fails to create an XASession due to
 *                      some internal error.
 */
public XAQueueSession createXAQueueSession() throws JMSException {
    return (XAQueueSession) createXASession();
}