List of recover() Examples

Examples of recover()

bitronix.tm.mock.resource.MockXAResource.recover()
com.alibaba.druid.pool.xa.JtdsXAResource.recover()
com.arjuna.ats.internal.jta.transaction.arjunacore.jca.SubordinateTransaction.recover()
com.arjuna.ats.internal.jta.transaction.arjunacore.subordinate.jca.TransactionImple.recover()
Force this transaction to try to recover itself again.
com.arjuna.ats.jta.recovery.XARecoveryResource.recover()
Attempt the recovery. Return one of the status values above.
com.atomikos.datasource.RecoverableResource.recover()
Recovers the partially reconstructed Participant. @param participant A partially recovered Participant. @exception ResourceException On failure. @return boolean True iff reconstruction was successful.If the resource is not responsible for the given participant, then this will return false. A Participant can use this to iterate over all resources in order to eventually recover itself. This is particularly useful if the Participant instance can not serialize its full state, because some of it is on its backside resource (as, for instance, in XA). This way, the TransactionalResource can be used to assist in reconstruction of the Participant's state.
com.atomikos.icatch.Participant.recover()
Called by the transaction manager (TM) at recovery time, and this should reconstruct the internal state. @return boolean False if the instance could not be recovered.It is up to the transaction manager to determine the severity of this case. @exception SysException
com.sleepycat.je.XAEnvironment.recover()
com.sleepycat.je.recovery.RecoveryManager.recover()
Look for an existing log and use it to create an in memory structure for accessing existing databases. The file manager and logging system are only available after recovery. @return RecoveryInfo statistics about the recovery process.
com.sun.jini.reliableLog.ReliableLog.recover()
Retrieves the contents of the snapshot file by calling the client supplied recover callback and then applies the incremental updates by calling the readUpdate callback for each logged updated. @throws LogException if recovery fails due to serious log corruption,or if an exception is thrown by the recover or readUpdate callbacks @throws IOException if an other I/O error occurs
com.sun.sgs.service.RecoveryListener.recover()
Notifies this listener that the specified {@code node} hasfailed and that this listener needs to orchestrate recovery. This method is invoked outside of a transaction.
When recovery for this listener for the specified {@code node} is complete, the {@link RecoveryCompleteFuture#done done}method of the specified {@code future} must be invoked.
Recovery does not need to be performed in this method, but may be performed asynchronously.
The implementation of this method should be idempotent because it may be invoked multiple times. If it is invoked multiple times, the {@link RecoveryCompleteFuture#done done} method mustbe called for each {@code future} provided. @param node a failed node to recover @param future a future to notify when recovery is complete
javax.jms.QueueSession.recover()
javax.jms.Session.recover()
javax.jms.XASession.recover()
javax.resource.spi.XATerminator.recover()
javax.transaction.xa.XAResource.recover()
net.timewalker.ffmq3.local.session.LocalSession.recover()
net.timewalker.ffmq3.storage.data.impl.journal.JournalRecovery.recover()
Start the recovery process @return the new block count of the store, or -1 if unchanged @throws JournalException
nexj.core.rpc.ra.tx.PersistentJournal.recover()
Gets the ids of all of the in-doubt transactions found in the journal. @return A list of in-doubt transaction ids.
org.apache.accumulo.server.tabletserver.log.SortedLogRecovery.recover()
org.apache.activemq.store.MessageStore.recover()
Recover any messages to be delivered. @param container @throws Exception
org.apache.activemq.store.TopicMessageStore.recover()
org.apache.hadoop.hdfs.server.namenode.FSImageTransactionalStorageInspector.LogGroup.recover()
org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppImpl.recover()
org.apache.jackrabbit.oak.plugins.document.LastRevRecoveryAgent.recover()
Recover the correct _lastRev updates for potentially missing candidate nodes. @param clusterId the cluster id for which the _lastRev are to be recovered @return the int the number of restored nodes
org.apache.qpid.jms.Session.recover()
org.apache.qpid.server.model.ConfiguredObjectFactory.recover()
org.chaidb.db.log.LogRecord.recover()
redo or undo the operation for recovery @param flag REDO or UNDO.
org.elasticsearch.index.gateway.IndexShardGatewayService.recover()
Recovers the state of the shard from the gateway.
org.elasticsearch.index.shard.service.InternalIndexShard.recover()
org.exist.storage.recovery.RecoveryManager.recover()
Checks if the database is in a consistent state. If not, start a recovery run. The method scans the last log file and tries to find the last checkpoint record. If the checkpoint record is the last record in the file, the database was closed cleanly and is in a consistent state. If not, a recovery run is started beginning at the last checkpoint found. @throws LogException
org.exolab.jms.tranlog.TransactionLog.recover()
Force a recovery of this log file. This will close the output file stream if one is opened and then read each entry from the log file and send it to the specified listener, if one is allocated.
The returned data structure is a HashMap, where the key is a {@link ExternalXid} and the entries are LinkedList of {@link BaseTransactionLogEntry} objects @return HashMap - a list of open transactions @throws TransactionLogException - if there is a prob recovering
org.hornetq.api.core.client.ClientSession.recover()
org.infinispan.transaction.xa.TransactionXaAdapter.recover()
org.jboss.jms.recovery.XAResourceWrapper.recover()
org.mule.util.journal.queue.LocalTxQueueTransactionRecoverer.recover()
Recover all the pending transactions. Will undo all operations done over queues that were not commit or rolled back. Clears the transaction log after processing all the log entries since does entries are not longer required.
org.springframework.amqp.rabbit.retry.MessageRecoverer.recover()
Callback for message that was consumed but failed all retry attempts. @param message the message to recover @param cause the cause of the error
sun.rmi.log.ReliableLog.recover()
Returns an object which is the value recorded in the current snapshot. This snapshot is recovered by calling the client supplied callback "recover" and then subsequently invoking the "readUpdate" callback to apply any logged updates to the state. @exception IOException If recovery fails due to serious logcorruption, read update failure, or if an exception occurs during the recover callback
tyrex.tm.TransactionDomain.recover()

Examples of javax.transaction.xa.XAResource.recover()

         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);


         assertEquals(xid1, xids[0]);
         
         log.trace("rolling back the tx");

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         
         XASession sess3 = conn3.createXASession();
         
         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);


         assertEquals(xid1, xids[0]);
         
         log.trace("Committing the tx");

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         
         XASession sess3 = conn3.createXASession();
         
         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);


         assertEquals(xid1, xids[0]);
         
         log.trace("rolling back the tx");

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         
         XASession sess3 = conn3.createXASession();
         
         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);


         assertEquals(xid1, xids[0]);
                  
         // Verify message still can't be received

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         
         XAResource res3 = sess3.getXAResource();
         
         log.trace("created connection");
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         log.trace("created connection");
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);


         assertEquals(xid1, xids[0]);
         
         log.trace("recovered");

View Full Code Here

Examples of javax.transaction.xa.XAResource.recover()

         
         XASession sess3 = conn3.createXASession();
         
         XAResource res3 = sess3.getXAResource();
         
         Xid[] xids = res3.recover(XAResource.TMSTARTRSCAN);
         assertEquals(1, xids.length);
         
         Xid[] xids2 = res3.recover(XAResource.TMENDRSCAN);
         assertEquals(0, xids2.length);

View Full Code Here

0 1 2 3 4 5 6 7 8

TOP

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.