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

QueueSession.rollback介绍

暂无

代码示例

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

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

代码示例来源：origin: spring-projects/spring-framework

verify(txSession).rollback();
verify(txSession).close();
verify(nonTxSession).close();

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

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

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

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

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

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

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

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

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

/**
* Test that an attempt to call the <code>roolback()</code> method on a 
* <strong>non transacted</strong> <code>Session</code> throws a 
* <code>javax.jms.IllegalStateException</code>.
*/
public void testRollbackNonTransactedSession()
{
 try
 {
   // senderSession has been created as non transacted in the setUp() method
   assertEquals(false, senderSession.getTransacted());
   senderSession.rollback();
   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

/**
* 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.
*/
public void testRollbackTransactedSession()
{
 try
 {
   // re-create senderSession as a transacted session
   senderSession = senderConnection.createQueueSession(true, 0);
   sender = senderSession.createSender(senderQueue);
   assertEquals(true, senderSession.getTransacted());
   TextMessage message = senderSession.createTextMessage();
   message.setText("testRollbackTransactedSession");
   // send a message within a transacted session
   sender.send(message);
   // rollback the transaction -> the sent message shouldn't be received
   senderSession.rollback();
   TextMessage m = (TextMessage) receiver.receiveNoWait();
   // test that no message has been received
   assertEquals(null, m);
 }
 catch (Exception e)
 {
   fail(e);
 }
}

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

/**
* Test that an attempt to call the <code>roolback()</code> method on a
* <strong>non transacted</strong> <code>Session</code> throws a
* <code>javax.jms.IllegalStateException</code>.
*/
@Test
public void testRollbackNonTransactedSession() {
 try {
   // senderSession has been created as non transacted in the setUp() method
   Assert.assertEquals(false, senderSession.getTransacted());
   senderSession.rollback();
   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: objectweb-joramtests/joramtests

receiverSession.rollback();

代码示例来源：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 testRollbackTransactedSession() {
 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("testRollbackTransactedSession");
   // send a message within a transacted session
   sender.send(message);
   // rollback the transaction -> the sent message shouldn't be received
   senderSession.rollback();
   TextMessage m = (TextMessage) receiver.receiveNoWait();
   // test that no message has been received
   Assert.assertEquals(null, m);
 } catch (Exception e) {
   fail(e);
 }
}

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

assertEquals(1, jmsxDeliveryCount);
receiverSession.rollback();

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

receiverSession.rollback();

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

Assert.assertEquals(1, jmsxDeliveryCount);
receiverSession.rollback();