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

Broker.commitTransaction介绍

[英]Commits a transaction.
[中]提交事务。

代码示例

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  next.commitTransaction(context, xid, onePhase);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].commitTransaction(context, xid, onePhase);
  }
}

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  getNext().commitTransaction(context, xid, onePhase);
}

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

private void commit(LocalTransactionId tx, ConnectionContext connectionContext, Message message) throws Exception {
  if (tx != null) {
    connectionContext.getBroker().commitTransaction(connectionContext, tx, true);
    connectionContext.getTransactions().remove(tx);
    connectionContext.setTransaction(null);
    message.setTransactionId(null);
  }
}

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

if (recoveredPendingCommit.contains(txid)) {
  LOG.info("delivering pending commit outcome for tid: " + txid);
  broker.commitTransaction(null, txid, false);

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

@Override
public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), true);
  return null;
}

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

@Override
public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), false);
  return null;
}

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  next.commitTransaction(context, xid, onePhase);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].commitTransaction(context, xid, onePhase);
  }
}

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  next.commitTransaction(context, xid, onePhase);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].commitTransaction(context, xid, onePhase);
  }
}

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  next.commitTransaction(context, xid, onePhase);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].commitTransaction(context, xid, onePhase);
  }
}

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  next.commitTransaction(context, xid, onePhase);
  Broker brokers[] = getListeners();
  for (int i = 0; i < brokers.length; i++) {
    brokers[i].commitTransaction(context, xid, onePhase);
  }
}

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

@Override
public void commitTransaction(ConnectionContext context, TransactionId xid, boolean onePhase) throws Exception {
  getNext().commitTransaction(context, xid, onePhase);
}

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

private void commit(LocalTransactionId tx, ConnectionContext connectionContext, Message message) throws Exception {
  if (tx != null) {
    connectionContext.getBroker().commitTransaction(connectionContext, tx, true);
    connectionContext.getTransactions().remove(tx);
    connectionContext.setTransaction(null);
    message.setTransactionId(null);
  }
}

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

private void commit(LocalTransactionId tx, ConnectionContext connectionContext, Message message) throws Exception {
  if (tx != null) {
    connectionContext.getBroker().commitTransaction(connectionContext, tx, true);
    connectionContext.getTransactions().remove(tx);
    connectionContext.setTransaction(null);
    message.setTransactionId(null);
  }
}

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

@Override
public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), true);
  return null;
}

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

@Override
public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), false);
  return null;
}

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

public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), true);
  return null;
}

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

@Override
public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), false);
  return null;
}

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

@Override
public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), true);
  return null;
}

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

@Override
public Response processCommitTransactionOnePhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), true);
  return null;
}

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

@Override
public Response processCommitTransactionTwoPhase(TransactionInfo info) throws Exception {
  TransportConnectionState cs = lookupConnectionState(info.getConnectionId());
  context = cs.getContext();
  cs.removeTransactionState(info.getTransactionId());
  broker.commitTransaction(context, info.getTransactionId(), false);
  return null;
}