Package org.persvr.remote

Examples of org.persvr.remote.Client


    final Callable function = (Callable) args[0];
    TimerTask timeoutTask;
    final int thisTaskId = taskId++;
    final Object user = UserSecurity.currentUser();
    IndividualRequest request = Client.getCurrentObjectResponse();
    final Client session = request == null ? null : Client.getCurrentObjectResponse().getConnection();

    return new Runnable(){

      public void run() {
        try{
          if(session != null)
            session.adoptThread(Thread.currentThread());
          UserSecurity.registerThisThread(user);
          Transaction.startTransaction();
          function.call(PersevereContextFactory.getContext(), scope, null, new Object[]{});
          Transaction.currentTransaction().commit();
        }catch(Throwable e){
View Full Code Here


        delay = ((Number) args[1]).intValue();
      }
      TimerTask timeoutTask;
      final int thisTaskId = taskId++;
      IndividualRequest request = Client.getCurrentObjectResponse();
      final Client session = request == null ? null : Client.getCurrentObjectResponse().getConnection();
      final Runnable runnable = runnableInNewThread(scope, args, repeated ? "setInterval" : "setTimeout");     
      currentQueuedTasks.put(thisTaskId,timeoutTask = new TimerTask(){
        @Override
        public void run() {
          // ensure that we don't access the same transient values with more than one thread
View Full Code Here

TOP

Related Classes of org.persvr.remote.Client

Copyright © 2018 www.massapicom. 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.