Package com.google.appengine.api.taskqueue

Examples of com.google.appengine.api.taskqueue.TaskOptions.param()

47
48
49
50
51
52
53
54
55
56
57
                taskOptions.param("corporationID", String.valueOf(character.getCorporationID()))
                        .param("corporationName", character.getCorporationName())
                        .param("corporationTicker", character.getCorporationTicker());
            }
            if (character.getAllianceID() != null) {
                taskOptions.param("allianceID", String.valueOf(character.getAllianceID()))
                        .param("allianceName", character.getAllianceName());
            }
            queue.add(taskOptions);
        }
    }
View Full Code Here
14
15
16
17
18
19
20
21
22
23
24
  public void addTaskToQueue(Map<String, String> params){
    Queue tq = QueueFactory.getQueue("onPositiveQueue");
    TaskOptions to = TaskOptions.Builder.withUrl(CONN_URL);
    for (String k : params.keySet()) {
      String val = params.get(k);
      to = to.param(k, val);
    }
    to = to.method(Method.POST);
    // to = to.taskName("task" + INIT + "count" + (-1));
    tq.add(to);
  }
View Full Code Here
149
150
151
152
153
154
155
156
157
158
159
        .header("Content-Type", "application/x-www-form-urlencoded; charset=utf-8")
        .param(PARAM_PROC_ID, processor.name);

    while (args.hasNext()) {
      for (int i = 0; i < batchSize - 1 && args.hasNext(); i++) {
        opts.param(PARAM_ARGS, args.next());
      }
      queue.add(opts);
      opts.removeParam(PARAM_ARGS);
    }
  }
View Full Code Here
17
18
19
20
21
22
23
24
25
26
27
    throws MalformedURLException, InterruptedException, ExecutionException {
    Queue queue = QueueFactory.getQueue(workId);
    TaskOptions options = TaskOptions.Builder.withUrl(url);
    options.method(Method.POST);
    for(String name : params.keySet()) {
      options.param(name, params.get(name));
    }
    options.header("Host", BackendServiceFactory.getBackendService().getBackendAddress("worker",0));
    queue.add(options);      
  }
 
View Full Code Here
17
18
19
20
21
22
23
24
25
26
27
    throws MalformedURLException, InterruptedException, ExecutionException {
    Queue queue = QueueFactory.getQueue(workId);
    TaskOptions options = TaskOptions.Builder.withUrl(url);
    options.method(Method.POST);
    for(String name : params.keySet()) {
      options.param(name, params.get(name));
    }
    queue.add(options);
  }
 
}
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
            TaskOptions options =
                    TaskOptions.Builder
                        .withUrl("/GenerateNicoliveIndex")
                        .method(Method.POST);
            for (Key key : keys) {
                options = options.param("keys[]", Datastore.keyToString(key));
            }

            QueueFactory.getQueue("generate-nicoliveindex").add(options);
        }
    }
View Full Code Here
163
164
165
166
167
168
169
170
171
172
173
                    }
                    break;
                case "params":
                    if (value instanceof Map) {
                        for (Entry<String, Object> option : ((Map<String, Object>)value).entrySet()) {
                            options = options.param(option.getKey(), String.valueOf(option.getValue()));
                        }
                    } else {
                        throw new RuntimeException("The params key/value pairs should be passed as a map.");
                    }
                    break;
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.