Examples of execute()

Examples of com.sun.star.system.XSystemShellExecute.execute()

695
696
697
698
699
700
701
702
703
704
705
            try
            {
                Object oSystemShell = xContext.getServiceManager().createInstanceWithContext( "com.sun.star.system.SystemShellExecute", xContext );
                XSystemShellExecute xSystemShell = (XSystemShellExecute)UnoRuntime.queryInterface( XSystemShellExecute.class, oSystemShell );
                if ( xSystemShell != null )
                    xSystemShell.execute( sURL, "", SystemShellExecuteFlags.DEFAULTS );
            }
            catch( Exception e )
            {
                e.printStackTrace();
            }
View Full Code Here

Examples of com.sun.star.task.XJob.execute()

103
104
105
106
107
108
109
110
111
112
113
       
        NamedValue[] executeArgs = (NamedValue[]) tEnv.getObjRelation("executeArgs");
        XJob Job = (XJob) tEnv.getObjRelation("Job");
       
        try {
            Job.execute(executeArgs);
        } catch ( com.sun.star.lang.IllegalArgumentException e) {
            throw new StatusException(Status.failed
                ("'could not fire event: " + e)) ;
        } catch ( com.sun.star.uno.Exception e) {
            throw new StatusException(Status.failed
View Full Code Here

Examples of com.sun.star.ucb.XCommandProcessor.execute()

124
125
126
127
128
129
130
131
132
133
134
            cmargs2.Properties = props;

            command.Name = "open";
            command.Argument = cmargs2;

            Object result = xCommandProcessor.execute(command, 0, null);
            XDynamicResultSet xDynamicResultSet = (XDynamicResultSet)UnoRuntime.queryInterface(XDynamicResultSet.class, result);
            XResultSet xResultSet = xDynamicResultSet.getStaticResultSet();
            XRow xRow = (XRow)UnoRuntime.queryInterface(XRow.class, xResultSet);
            // create the new folder 'folderName': first, check if it's already there
            while(xResultSet.next()) {
View Full Code Here

Examples of com.sun.star.ui.dialogs.XExecutableDialog.execute()

869
870
871
872
873
874
875
876
877
878
879
            PropertyValue[] aPropertyValue = new PropertyValue[2];
            aPropertyValue[0] = Properties.createProperty("SQLException", oSQLException);                               
            aPropertyValue[1] = Properties.createProperty("ParentWindow", _xWindow);                               
            xInitialization.initialize(aPropertyValue);
            XExecutableDialog xExecutableDialog = (XExecutableDialog) UnoRuntime.queryInterface(XExecutableDialog.class, oDialog);
            xExecutableDialog.execute();           
    } catch (com.sun.star.uno.Exception ex) {
        ex.printStackTrace();
    }}
    public void finish(){
        xTableNames = null;
View Full Code Here

Examples of com.tangosol.net.InvocationService.execute()

107
108
109
110
111
112
113
114
115
116
117
     */
    public static void clearCacheStats() {

        InvocationService service = com.tangosol.net.CacheFactory.getInvocationService("OpenFire Cluster Service");

        service.execute(new AbstractInvocable() {
            public void run() {
                com.tangosol.coherence.component.net.Cluster cluster =
                        (com.tangosol.coherence.component.net.Cluster)
                        ((SafeCluster)com.tangosol.net.CacheFactory.ensureCluster()).getCluster();

View Full Code Here

Examples of com.taobao.zeus.socket.worker.reqresp.WorkerBeCancel.execute()

67
68
69
70
71
72
73
74
75
76
77
        });
      }else if(request.getOperate()==Operate.Cancel){
        completionService.submit(new Callable<Response>() {
          private WorkerBeCancel cancel=new WorkerBeCancel();
          public Response call() throws Exception {
            return cancel.execute(context, request).get();
          }
        });
      }
    }else if(sm.getKind()==Kind.RESPONSE){
      final Response resp=Response.newBuilder().mergeFrom(sm.getBody()).build();
View Full Code Here

Examples of com.taobao.zeus.socket.worker.reqresp.WorkerBeExecute.execute()

60
61
62
63
64
65
66
67
68
69
70
      Operate op=request.getOperate();
      if(op==Operate.Schedule || op==Operate.Manual || op==Operate.Debug){
        completionService.submit(new Callable<Response>() {
          private WorkerBeExecute execute=new WorkerBeExecute();
          public Response call() throws Exception {
            return execute.execute(context, request).get();
          }
        });
      }else if(request.getOperate()==Operate.Cancel){
        completionService.submit(new Callable<Response>() {
          private WorkerBeCancel cancel=new WorkerBeCancel();
View Full Code Here

Examples of com.taobao.zeus.socket.worker.reqresp.WorkerHeartBeat.execute()

78
79
80
81
82
83
84
85
86
87
88
      public void run() {
        try {
          if (context.getServerChannel() == null) {
            return;
          }
          ChannelFuture cf = heartbeat.execute(context);
          cf.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future)
                throws Exception {
              if (!future.isSuccess()) {
                failCount++;
View Full Code Here

Examples of com.test.FormProcessingAction.execute()

84
85
86
87
88
89
90
91
92
93
94
        try {
            ActionProxy proxy = ActionProxyFactory.getFactory().createActionProxy("", "formProcessing!myMethod", extraContext);
            proxy.setExecuteResult(false);
            System.out.println(proxy.execute());
            FormProcessingAction action = (FormProcessingAction)proxy.getAction();
            action.execute();
            assertEquals("fileHello", action.getFile());
        } catch (Exception e) {
            e.printStackTrace();
        }
       
View Full Code Here

Examples of com.thenetcircle.comsumerdispatcher.distribution.watcher.CountChangedWatcher.execute()

107
108
109
110
111
112
113
114
115
116
117
  public void addJobExecutor(int numToAdd) {
    _logger.info("[THREAD ADD] going to add " + numToAdd + " new executors ...");
   
        CountChangedWatcher ccw = (CountChangedWatcher) countChangedWatcher;
        ccw.setNumToSet(numToAdd + activeExecutorCount.intValue());
        ccw.execute();
  }
 
  @Override
  public void removeJobExecutors(int numToRemove) {
    _logger.info("[THREAD INTERRUPT] going to stop " + numToRemove + " executors ...");
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.