Examples of execute()

Examples of com.dci.intellij.dbn.execution.statement.processor.StatementExecutionCursorProcessor.execute()

22
23
24
25
26
27
28
29
30
31
32
            if (continueExecution) {
                new BackgroundTask(executionResult.getProject(), "Executing statement", false, true) {
                    protected void execute(@NotNull ProgressIndicator progressIndicator) {
                        initProgressIndicator(progressIndicator, true);
                        StatementExecutionCursorProcessor executionProcessor = executionResult.getExecutionProcessor();
                        executionProcessor.execute(progressIndicator);
                    }
                }.start();
            }
        }
    }
View Full Code Here

Examples of com.developmentsprint.spring.breaker.CircuitManager.execute()

108
109
110
111
112
113
114
115
116
117
118
        if (applicableCircuitManager == null && fallbackToNoOpCircuitManager) {
            applicableCircuitManager = new NoOpCircuitManager();
        }

        return applicableCircuitManager.execute(invoker);
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
View Full Code Here

Examples of com.director.core.ExecutorAdapter.execute()

75
76
77
78
79
80
81
82
83
84
85
         throws DirectException {
      Map<String, String> nsMapping = this.actionMapping.get(directAction.getNamespace());
      String beanName = nsMapping.get(directAction.getName());
      Object bean = this.applicationContext.getBean(beanName);
      ExecutorAdapter beanExecutorAdapter = this.buildBeanExecutorAdapter(bean);
      return beanExecutorAdapter.execute(directAction, directMethod, data);
   }

   private ExecutorAdapter buildBeanExecutorAdapter(Object action) {
      return (action instanceof Advised) ?
            new AdvisedActionExecutorAdapter((Advised) action) : new DefaultActionExecutorAdapter(action);
View Full Code Here

Examples of com.documentum.fc.client.DfQuery.execute()

71
72
73
74
75
76
77
78
79
80
81
    }
    log.trace("DQL: " + name + " -> "+ dql);
    if (dql==null) return null;
    query.setDQL(dql);
    try {
      return query.execute(session, DfQuery.READ_QUERY);
    } catch (DfException e) {
      throw new CaoException(e);
    }
  }
 
View Full Code Here

Examples of com.dooapp.gaedo.finders.dynamic.Mode.execute()

70
71
72
73
74
75
76
77
78
79
80
    case COUNT:
    case FIND_ALL:
    case FIND_ONE:
    default:
    }
    return usedMode.execute(statement, parameters.toArray(), System.currentTimeMillis()+"");
  }

  private int toInt(Map<String, Object> returnParams,
      String paramKey, int defaultValue) {
    if(returnParams.containsKey(paramKey))
View Full Code Here

Examples of com.dotcms.repackage.com.caucho.quercus.program.QuercusProgram.execute()

192
193
194
195
196
197
198
199
200
201
202
   
    Env env = php.createEnv(page, writeStream, null, null);
    env.start();
    populateEnv(env);
    page.executeTop(env);
    Value v = qp.execute(env);
   
    List<Function> funcs = qp.getFunctionList();
    if(funcs != null){
      wrapper.setFunctions(funcs);
    }
View Full Code Here

Examples of com.dotcms.repackage.org.elasticsearch.action.admin.indices.create.CreateIndexRequestBuilder.execute()

493
494
495
496
497
498
499
500
501
502
503
    map.put("number_of_shards", shards);


        // create actual index
    CreateIndexRequestBuilder cirb = iac.prepareCreate(indexName).setSettings(map);
        CreateIndexResponse createIndexResponse = cirb.execute().actionGet();

        AdminLogger.log(this.getClass(), "createIndex",
                "Index created: " + indexName + " with shards: " + shards);

    return createIndexResponse;
View Full Code Here

Examples of com.dotcms.repackage.org.elasticsearch.action.admin.indices.settings.UpdateSettingsRequestBuilder.execute()

607
608
609
610
611
612
613
614
615
616
617
          newSettings.put("index.number_of_replicas", replicas+"");


      UpdateSettingsRequestBuilder usrb = new ESClient().getClient().admin().indices().prepareUpdateSettings(indexName);
      usrb.setSettings(newSettings);
      usrb.execute().actionGet();
    }
   
    AdminLogger.log(this.getClass(), "updateReplicas", "Replicas updated to index: " + indexName);
    }
View Full Code Here

Examples of com.dotcms.repackage.org.elasticsearch.action.bulk.BulkRequestBuilder.execute()

292
293
294
295
296
297
298
299
300
301
302
                        contentToIndex.addAll(loadDeps(content));
                   
                    indexContentletList(req, contentToIndex,reindexOnly);
                                       
                    if(bulk==null && req.numberOfActions()>0)
                        req.execute().actionGet();

                } catch (Exception e) {
                    Logger.error(ESContentFactoryImpl.class, e.getMessage(), e);
                }
            }
View Full Code Here

Examples of com.dotcms.repackage.org.elasticsearch.action.count.CountRequestBuilder.execute()

1196
1197
1198
1199
1200
1201
1202
1203
1204
1205
1206
        Client client=new ESClient().getClient();
        QueryStringQueryBuilder qb = QueryBuilders.queryString(qq);
        CountRequestBuilder crb = client.prepareCount();
        crb.setQuery(qb);
        crb.setIndices(indexToHit);
        return crb.execute().actionGet().getCount();
  }

  private SearchRequestBuilder createRequest(Client client, String query) {
    if(Config.getBooleanProperty("ELASTICSEARCH_USE_FILTERS_FOR_SEARCHING",false)) {
      /* this is filtered query
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.