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

QueueSession.commit介绍

暂无

代码示例

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

@Override
public void commit() throws JMSException {
  next.commit();
}

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

/**
 * @throws JMSException
 */
public void commit() throws JMSException {
  next.commit();
}

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

@Override
public void commit() throws JMSException {
  next.commit();
}

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

@Override
public void commit() throws JMSException {
  next.commit();
}

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

@Override
public void commit() throws JMSException {
  next.commit();
}

代码示例来源：origin: org.jbpm/jbpm-human-task-jms

handleMessage(serverMessage);
  if(transactedQueue)
    consumerSession.commit();
}else {
  while(true){
    handleMessage(serverMessage);
    if(transactedQueue)
      consumerSession.commit();

代码示例来源：origin: org.jbpm/jbpm-human-task-jms

this.producer.send(message);
if(transactedQueue)
  this.producerSession.commit();

代码示例来源：origin: objectweb-joramtests/joramtests

/**
* Test that an attempt to call the <code>commit()</code> method on a 
* <strong>non transacted</strong> <code>Session</code> throws a 
* <code>javax.jms.IllegalStateException</code>.
*/
public void testCommitNonTransactedSession()
{
 try
 {
   // senderSession has been created as non transacted in the setUp() method
   assertEquals(false, senderSession.getTransacted());
   senderSession.commit();
   fail("Should raise an IllegalStateException, the session is not transacted.\n");
 }
 catch (javax.jms.IllegalStateException e)
 {
 }
 catch (java.lang.IllegalStateException e)
 {
   fail("Should raise a javax.jms.IllegalStateException, not a java.lang.IllegalStateException.\n");
 }
 catch (Exception e)
 {
   fail("Should raise a javax.jms.IllegalStateException, not a " + e);
 }
}

代码示例来源：origin: objectweb-joramtests/joramtests

senderSession.commit();

代码示例来源：origin: timewalker74/ffmq

session.commit();

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

/**
* Test that an attempt to call the <code>commit()</code> method on a
* <strong>non transacted</strong> <code>Session</code> throws a
* <code>javax.jms.IllegalStateException</code>.
*/
@Test
public void testCommitNonTransactedSession() {
 try {
   // senderSession has been created as non transacted in the setUp() method
   Assert.assertEquals(false, senderSession.getTransacted());
   senderSession.commit();
   Assert.fail("Should raise an IllegalStateException, the session is not transacted.\n");
 } catch (javax.jms.IllegalStateException e) {
 } catch (java.lang.IllegalStateException e) {
   Assert.fail("Should raise a javax.jms.IllegalStateException, not a java.lang.IllegalStateException.\n");
 } catch (Exception e) {
   Assert.fail("Should raise a javax.jms.IllegalStateException, not a " + e);
 }
}

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

/**
* Test that a call to the <code>rollback()</code> method on a
* <strong>transacted</strong> <code>Session</code> rollbacks all
* the messages sent in the transaction.
*/
@Test
public void testCommitTransactedSession() {
 try {
   // re-create senderSession as a transacted session
   senderSession = senderConnection.createQueueSession(true, 0);
   sender = senderSession.createSender(senderQueue);
   Assert.assertEquals(true, senderSession.getTransacted());
   TextMessage message = senderSession.createTextMessage();
   message.setText("testCommitTransactedSession");
   // send a message within a transacted session
   sender.send(message);
   TextMessage m = (TextMessage) receiver.receiveNoWait();
   // test that no message has been received (the transaction has not been committed yet)
   Assert.assertEquals(null, m);
   // commit the transaction -> the sent message should be received
   senderSession.commit();
   m = (TextMessage) receiver.receive(TestConfig.TIMEOUT);
   Assert.assertTrue(m != null);
   Assert.assertEquals("testCommitTransactedSession", m.getText());
 } catch (Exception e) {
   fail(e);
 }
}

代码示例来源：origin: objectweb-joramtests/joramtests

sender.send(message);
senderSession.commit();

代码示例来源：origin: objectweb-joramtests/joramtests

sender.send(message);
senderSession.commit();

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

sender.send(message);
senderSession.commit();

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

sender.send(message);
senderSession.commit();