Examples of resume()

Examples of org.infinispan.transaction.tm.DummyTransactionManager.resume()

331
332
333
334
335
336
337
338
339
340
341
      tm.begin();
      cache.put("k", "v");
      assert !tm.getTransaction().runPrepare();

      tm.rollback();
      tm.resume(transaction);
      transaction.runCommitTx();

      assertNoLocks();
   }
View Full Code Here

Examples of org.jboss.cache.transaction.DummyTransactionManager.resume()

531
532
533
534
535
536
537
538
539
540
541
        // assert we can see this outside the existing tx
        assertEquals(pojo2, cache.get("/one/two", "key2"));
        System.out.println("Current TX " + mgr.getTransaction());
        // resume the suspended one
        mgr.resume(tx);
        System.out.println("Current TX " + mgr.getTransaction());
        // assert we can't see the change from tx2 as we already touched the node
        assertEquals(null, cache.get("/one/two", "key2"));
        mgr.commit();
        destroyCache(cache);
View Full Code Here

Examples of org.jboss.resteasy.spi.ResteasyAsynchronousResponse.resume()

39
40
41
42
43
44
45
46
47
48
      return new AsynchronousResponse()
      {
         @Override
         public void setResponse(Response response)
         {
            asynchronousResponse.resume(response);
         }
      };
   }
}
View Full Code Here

Examples of org.jbpm.graph.exe.ProcessInstance.resume()

279
280
281
282
283
284
285
286
287
288
289
    assertSame(processInstance.getRootToken(), suspendedToken);

    jbpmContext = jbpmConfiguration.createJbpmContext();
    testSchedulerService = (TestSchedulerService) jbpmContext.getServices().getSchedulerService();
    try {
      processInstance.resume();
      jbpmContext.save(processInstance);
    } finally {
      jbpmContext.close();
    }
View Full Code Here

Examples of org.jbpm.pvm.internal.repository.DeploymentImpl.resume()

40
41
42
43
44
45
46
47
48
  }

  public Object execute(Environment environment) throws Exception {
    RepositorySession repositorySession = environment.get(RepositorySession.class);
    DeploymentImpl deployment = (DeploymentImpl) repositorySession.getDeployment(deploymentId);
    deployment.resume();
    return null;
  }
}
View Full Code Here

Examples of org.jbpm.task.service.TaskClient.resume()

613
614
615
616
617
618
619
620
621
622
623
        if (taskSummary == null) {
            return;
        }

        BlockingTaskOperationResponseHandler responseHandler = new BlockingTaskOperationResponseHandler();
        client.resume(taskSummary.getId(), userId, responseHandler);
        responseHandler.waitTillDone(3000);
        refresh();
    }

    public void skip() {
View Full Code Here

Examples of org.jbpm.taskmgmt.exe.TaskMgmtInstance.resume()

703
704
705
706
707
708
709
710
711
712
713
  void resumeTaskInstances()
  {
    TaskMgmtInstance taskMgmtInstance = (processInstance != null ? processInstance.getTaskMgmtInstance() : null);
    if (taskMgmtInstance != null)
    {
      taskMgmtInstance.resume(this);
    }
  }

  // equals ///////////////////////////////////////////////////////////////////
  // hack to support comparing hibernate proxies against the real objects
View Full Code Here

Examples of org.libvirt.Domain.resume()

1600
1601
1602
1603
1604
1605
1606
1607
1608
1609
1610
                 * qemu
                 */
                vm = getDomain(conn, cmd.getVmName());
                state = vm.getInfo().state;
                if (state == DomainInfo.DomainState.VIR_DOMAIN_PAUSED) {
                    vm.resume();
                }
            } else {

                /* VM is not running, create a snapshot by ourself */
                final Script command = new Script(_manageSnapshotPath,
View Full Code Here

Examples of org.luaj.vm2.LuaThread.resume()

87
88
89
90
91
92
93
94
95
96
97
        final LuaValue func = args.checkfunction(1);
        return new LuaThread(func, LuaThread.getGlobals() );
      }
      case RESUME: {
        final LuaThread t = args.checkthread(1);
        return t.resume( args.subargs(2) );
      }
      case RUNNING: {
        final LuaThread r = LuaThread.getRunning();
        return LuaThread.isMainThread(r)? NIL: r;
      }
View Full Code Here

Examples of org.mortbay.jetty.nio.SelectChannelConnector.RetryContinuation.resume()

74
75
76
77
78
79
80
81
82
83
84
        log = extractLog(marker);
      } else {
        tailProcess.onChange(new TailChanged() {
          @Override
          public void onChange() {
            continuation.resume();
          }
        });
        continuation.suspend(60 * 1000);
      }
    }
 
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.