Examples of recover()

Examples of org.hornetq.api.core.client.ClientSession.recover()

546
547
548
549
550
551
552
553
554
555
556
      // This is not really necessary... But since the server has stopped, I would prefer to keep recreating the factory
      sessionFactory = createInVMFactory();

      session = sessionFactory.createSession(true, false, false);

      Xid[] xids = session.recover(XAResource.TMSTARTRSCAN);

      Assert.assertEquals(0, xids.length);

      session.close();
View Full Code Here

Examples of org.infinispan.transaction.xa.TransactionXaAdapter.recover()

37
38
39
40
41
42
43
44
45
46
47
   }

   public static void assertPrepared(int count, DummyTransaction...tx) throws XAException {
      for (DummyTransaction dt : tx) {
         TransactionXaAdapter xaRes = (TransactionXaAdapter) dt.firstEnlistedResource();
         assertEquals(count, xaRes.recover(XAResource.TMSTARTRSCAN | XAResource.TMENDRSCAN).length);
      }
   }

   public static RecoveryManagerImpl rm(Cache cache) {
      return (RecoveryManagerImpl) TestingUtil.extractComponentRegistry(cache).getComponent(RecoveryManager.class);
View Full Code Here

Examples of org.jboss.jms.recovery.XAResourceWrapper.recover()

51
52
53
54
55
56
57
58
59
60
61
   {
      XAResourceWrapper wrapper = new XAResourceWrapper();
      try
      {
         wrapper.setProviderName("DefaultJMSProvider");
         wrapper.recover(XAResource.TMSTARTRSCAN);
      }
      finally
      {
         wrapper.close();
      }
View Full Code Here

Examples of org.mule.util.journal.queue.LocalTxQueueTransactionRecoverer.recover()

60
61
62
63
64
65
66
67
68
69
70
        assertThat(inQueue.poll(10), IsNull.nullValue());
        assertThat(value, notNullValue());
        txLog.close();
        txLog = new LocalTxQueueTransactionJournal(temporaryFolder.getRoot().getAbsolutePath(), muleContext);
        LocalTxQueueTransactionRecoverer queueTransactionRecoverer = new LocalTxQueueTransactionRecoverer(txLog, createQueueProvider(inQueue));
        queueTransactionRecoverer.recover();
        Serializable muleEvent = inQueue.poll(10);
        assertThat(muleEvent, notNullValue());
        assertThat(testEvent.equals(muleEvent), is(true));
    }
View Full Code Here

Examples of org.springframework.amqp.rabbit.retry.MessageRecoverer.recover()

87
88
89
90
91
92
93
94
95
96
97
      public Void recover(Object[] args, Throwable cause) {
        Message message = (Message) args[1];
        if (messageRecoverer == null) {
          logger.warn("Message dropped on recovery: " + message, cause);
        } else {
          messageRecoverer.recover(message, cause);
        }
        // This is actually a normal outcome. It means the recovery was successful, but we don't want to consume
        // any more messages until the acks and commits are sent for this (problematic) message...
        throw new ImmediateAcknowledgeAmqpException("Recovered message forces ack (if ack mode requires it): "
            + message, cause);
View Full Code Here

Examples of sun.rmi.log.ReliableLog.recover()

213
214
215
216
217
218
219
220
221
222
223
                                        String logName,
                                        String[] childArgs)
        throws Exception
    {
        ReliableLog log = new ReliableLog(logName, new ActLogHandler());
        Activation state = (Activation) log.recover();
        state.init(port, ssf, log, childArgs);
    }

    /**
     * Initialize the Activation instantiation; start activation
View Full Code Here

Examples of tyrex.tm.TransactionDomain.recover()

101
102
103
104
105
106
107
108
109
110
111
                 + "parameters are invalid.");
        }

        if (domain.getState() == TransactionDomain.READY) {
            try {
                domain.recover();
            } catch( RecoveryException re ) {
                throw new NamingException
                    ("Could not activate TransactionDomain: "
                     + re.getMessage() );
            }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.