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

Message.isInTransaction介绍

暂无

代码示例

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

private boolean isInTransaction(Command command) {
  return command instanceof Message && ((Message)command).isInTransaction()
      || command instanceof MessageAck && ((MessageAck)command).isInTransaction();
}

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

if (messageSend.isInTransaction()) {
  LOG.warn("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}", new Object[]{
      (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber

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

Message message = (Message)c;
JournalMessageStore store = (JournalMessageStore)createMessageStore(message.getDestination());
if (message.isInTransaction()) {
  transactionStore.addMessage(store, message, pos);
} else {

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

if (message.isInTransaction()) {
  if (context.getTransaction().getState() > IN_USE_STATE) {
    throw new JMSException("Send transaction completed while waiting for space");

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

private boolean isInTransaction(Command command) {
  return command instanceof Message && ((Message)command).isInTransaction()
      || command instanceof MessageAck && ((MessageAck)command).isInTransaction();
}

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

private boolean isInTransaction(Command command) {
  return command instanceof Message && ((Message)command).isInTransaction()
      || command instanceof MessageAck && ((MessageAck)command).isInTransaction();
}

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

private boolean isInTransaction(Command command) {
  return command instanceof Message && ((Message)command).isInTransaction()
      || command instanceof MessageAck && ((MessageAck)command).isInTransaction();
}

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

if (messageSend.isInTransaction()) {
  LOG.warn("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}", new Object[]{
      (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber

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

if (messageSend.isInTransaction()) {
  LOG.warn("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}", new Object[]{
      (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber

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

if (messageSend.isInTransaction()) {
  LOG.warn("suppressing duplicated message send [{}] with producerSequenceId [{}] <= last stored: {}", new Object[]{
      (LOG.isTraceEnabled() ? messageSend : messageSend.getMessageId()), producerSequenceId, lastSendSequenceNumber

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

/**
 * @param message
 * @throws IOException
 */
void addMessage(final MessageStore destination, final Message message) throws IOException {
  try {
    if (message.isInTransaction()) {
      KahaTransaction tx = getOrCreateTx(message.getTransactionId());
      tx.add((KahaMessageStore)destination, message);
    } else {
      destination.addMessage(null, message);
    }
  } catch (RuntimeStoreException rse) {
    if (rse.getCause() instanceof IOException) {
      brokerService.handleIOException((IOException)rse.getCause());
    }
    throw rse;
  }
}

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

Message message = (Message)c;
AMQMessageStore store = (AMQMessageStore)createMessageStore(message.getDestination());
if (message.isInTransaction()) {
  transactionStore.addMessage(store, message, pos);
} else {

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

Message message = (Message)c;
JournalMessageStore store = (JournalMessageStore)createMessageStore(message.getDestination());
if (message.isInTransaction()) {
  transactionStore.addMessage(store, message, pos);
} else {

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

Message message = (Message)c;
JournalMessageStore store = (JournalMessageStore)createMessageStore(message.getDestination());
if (message.isInTransaction()) {
  transactionStore.addMessage(store, message, pos);
} else {

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

Message message = (Message)c;
JournalMessageStore store = (JournalMessageStore)createMessageStore(message.getDestination());
if (message.isInTransaction()) {
  transactionStore.addMessage(store, message, pos);
} else {

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

Message message = (Message)c;
JournalMessageStore store = (JournalMessageStore)createMessageStore(message.getDestination());
if (message.isInTransaction()) {
  transactionStore.addMessage(store, message, pos);
} else {

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

if (message.isInTransaction()) {
  if (context.getTransaction().getState() > IN_USE_STATE) {
    throw new JMSException("Send transaction completed while waiting for space");

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

if (message.isInTransaction()) {
  if (context.getTransaction().getState() > IN_USE_STATE) {
    throw new JMSException("Send transaction completed while waiting for space");

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

if (message.isInTransaction()) {
  if (context.getTransaction().getState() > IN_USE_STATE) {
    throw new JMSException("Send transaction completed while waiting for space");