下面列出了怎么用javax.jms.XAJMSContext的API类实例代码及写法,或者点击链接到github查看源代码。
@Override
protected XAJMSContext createProviderContext(String username, String password, int sessionMode) {
if (connectionFactory instanceof XAConnectionFactory) {
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.XAConnectionFactory");
}
}
static JMSContext create(JMSContext delegate, JmsTracing jmsTracing) {
if (delegate == null) throw new NullPointerException("delegate == null");
if (jmsTracing == null) throw new NullPointerException("jmsTracing == null");
if (delegate instanceof XAJMSContext) {
return new TracingXAJMSContext((XAJMSContext) delegate, jmsTracing);
}
return new TracingJMSContext(delegate, jmsTracing);
}
@Override
public XAJMSContext createXAContext() {
return createProviderContext(null, null, 0);
}
@Override
public XAJMSContext createXAContext(String userName, String password) {
return createProviderContext(userName, password, 0);
}
public XAJMSContext createXAContext() {
return null;
}
public XAJMSContext createXAContext(String userName, String password) {
return null;
}
@Override
public XAJMSContext createXAContext() {
return wrappedDelegate().createXAContext();
}
@Override
public XAJMSContext createXAContext(String s, String s1) {
return wrappedDelegate().createXAContext(s, s1);
}
@Override
public XAJMSContext createXAContext() {
return this.xaConnectionFactoryDelegate.createXAContext();
}
@Override
public XAJMSContext createXAContext(String userName, String password) {
return this.xaConnectionFactoryDelegate.createXAContext(userName, password);
}
@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);
}
static XAJMSContext create(XAJMSContext delegate, JmsTracing jmsTracing) {
if (delegate instanceof TracingXAJMSContext) return delegate;
return new TracingXAJMSContext(delegate, jmsTracing);
}
TracingXAJMSContext(XAJMSContext delegate, JmsTracing jmsTracing) {
super(delegate, jmsTracing);
}
@Override public XAResource getXAResource() {
return ((XAJMSContext) delegate).getXAResource();
}
@JMS2_0 public XAJMSContext createXAContext() {
XAConnectionFactory xacf = (XAConnectionFactory) delegate;
return TracingXAJMSContext.create(xacf.createXAContext(), jmsTracing);
}
@JMS2_0 public XAJMSContext createXAContext(String userName, String password) {
XAConnectionFactory xacf = (XAConnectionFactory) delegate;
return TracingXAJMSContext.create(xacf.createXAContext(userName, password), jmsTracing);
}
XAJMSContext createXAContext();