本文整理了Java中org.apache.activemq.broker.Broker.prepareTransaction()方法的一些代码示例，展示了Broker.prepareTransaction()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Broker.prepareTransaction()方法的具体详情如下：
包路径：org.apache.activemq.broker.Broker
类名称：Broker
方法名：prepareTransaction

Broker.prepareTransaction介绍

[英]Prepares a transaction. Only valid for xa transactions.
[中]准备交易。仅对xa事务有效。

代码示例

代码示例来源：origin: apache/activemq

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  int result = next.prepareTransaction(context, xid);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    // TODO decide what to do with return values
    brokers[i].prepareTransaction(context, xid);
  }
  return result;
}

代码示例来源：origin: apache/activemq

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  return getNext().prepareTransaction(context, xid);
}

代码示例来源：origin: apache/activemq

int result = broker.prepareTransaction(context, info.getTransactionId());
transactionState.setPreparedResult(result);
if (result == XAResource.XA_RDONLY) {

代码示例来源：origin: pierre/meteo

public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  return next.prepareTransaction(context, xid);
}

代码示例来源：origin: org.apache.activemq/activemq-broker

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  int result = next.prepareTransaction(context, xid);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    // TODO decide what to do with return values
    brokers[i].prepareTransaction(context, xid);
  }
  return result;
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  int result = next.prepareTransaction(context, xid);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    // TODO decide what to do with return values
    brokers[i].prepareTransaction(context, xid);
  }
  return result;
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  int result = next.prepareTransaction(context, xid);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    // TODO decide what to do with return values
    brokers[i].prepareTransaction(context, xid);
  }
  return result;
}

代码示例来源：origin: pierre/meteo

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  int result = next.prepareTransaction(context, xid);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    // TODO decide what to do with return values
    brokers[i].prepareTransaction(context, xid);
  }
  return result;
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  return getNext().prepareTransaction(context, xid);
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  return getNext().prepareTransaction(context, xid);
}

代码示例来源：origin: org.apache.activemq/activemq-broker

@Override
public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  return getNext().prepareTransaction(context, xid);
}

代码示例来源：origin: pierre/meteo

public int prepareTransaction(ConnectionContext context, TransactionId xid) throws Exception {
  return getNext().prepareTransaction(context, xid);
}

代码示例来源：origin: org.apache.activemq/activemq-broker

int result = broker.prepareTransaction(context, info.getTransactionId());
transactionState.setPreparedResult(result);
if (result == XAResource.XA_RDONLY) {

代码示例来源：origin: org.apache.activemq/activemq-osgi

int result = broker.prepareTransaction(context, info.getTransactionId());
transactionState.setPreparedResult(result);
if (result == XAResource.XA_RDONLY) {

代码示例来源：origin: pierre/meteo

public Response processPrepareTransaction(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = null;
  if (cs != null) {
    context = cs.getContext();
  }
  if (cs == null) {
    throw new NullPointerException("Context is null");
  }
  TransactionState transactionState = cs.getTransactionState(info.getTransactionId());
  if (transactionState == null) {
    throw new IllegalStateException("Cannot prepare a transaction that had not been started or previously returned XA_RDONLY: "
        + info.getTransactionId());
  }
  // Avoid dups.
  if (!transactionState.isPrepared()) {
    transactionState.setPrepared(true);
    int result = broker.prepareTransaction(context, info.getTransactionId());
    transactionState.setPreparedResult(result);
    if (result == XAResource.XA_RDONLY) {
      // we are done, no further rollback or commit from TM
      cs.removeTransactionState(info.getTransactionId());
    }
    IntegerResponse response = new IntegerResponse(result);
    return response;
  } else {
    IntegerResponse response = new IntegerResponse(transactionState.getPreparedResult());
    return response;
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

int result = broker.prepareTransaction(context, info.getTransactionId());
transactionState.setPreparedResult(result);
if (result == XAResource.XA_RDONLY) {