Package com.google.appengine.api.taskqueue

Examples of com.google.appengine.api.taskqueue.TaskHandle

142
143
144
145
146
147
148
149
150
151
152
153
154
    public void testPullWithGroupTag() throws Exception {
        final Queue queue = QueueFactory.getQueue("pull-queue");
        String tag = "testPullWithGroupTag" + "_" + System.currentTimeMillis();

        long currentTime = System.currentTimeMillis();
        TaskHandle th1 = queue.add(withMethod(PULL).tag(tag).payload("foobar").etaMillis(currentTime));
        TaskHandle th2 = queue.add(withMethod(PULL).tag(tag + "qwerty").payload("foofoo").etaMillis(currentTime + 1000));
        TaskHandle th3 = queue.add(withMethod(PULL).tag(tag).payload("foofoo").etaMillis(currentTime + 2000));
        sync();

        try {
            LeaseOptions options = new LeaseOptions(LeaseOptions.Builder
                .withLeasePeriod(1000L, TimeUnit.SECONDS))
View Full Code Here
169
170
171
172
173
174
175
176
177
178
179
180
    }

    @Test
    public void testLeaseTasksOnlyReturnsSpecifiedNumberOfTasks() {
        Queue queue = QueueFactory.getQueue("pull-queue");
        TaskHandle th1 = queue.add(withMethod(PULL));
        TaskHandle th2 = queue.add(withMethod(PULL));
        sync(2000);
        try {
            int countLimit = 1;
            List<TaskHandle> handles = waitOnFuture(queue.leaseTasksAsync(10, TimeUnit.SECONDS, countLimit));
            assertEquals(countLimit, handles.size());
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
110
111
        Queue queue = QueueFactory.getDefaultQueue();

        TaskOptions options = withTaskName(name).payload("payload");
        options.etaMillis(0); // TODO -- remove this once NPE is fixewd

        TaskHandle handle = waitOnFuture(queue.addAsync(options));

        assertEquals("default", handle.getQueueName());
        assertEquals(name, handle.getName());
        assertEquals("payload", new String(handle.getPayload(), "UTF-8"));
        assertNotNull(handle.getEtaMillis());
        assertEquals(0, (int) handle.getRetryCount());
    }
View Full Code Here
111
112
113
114
115
116
117
118
    }

    @Test
    public void testTaskHandleContainsAutoGeneratedTaskNameWhenTaskNameNotDefinedInTaskOptions() throws Exception {
        Queue queue = QueueFactory.getDefaultQueue();
        TaskHandle handle = waitOnFuture(queue.addAsync());
        assertNotNull(handle.getName());
    }
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
        }
       
        URL uri = new URL(url);
        String path = uri.getPath();   
        Queue queue = QueueFactory.getDefaultQueue();
        TaskHandle task = queue.add(withUrl(path)
            .payload(request.toString())
            .countdownMillis(delay));
       
        // store task information
        DateTime timestamp = DateTime.now().plus(delay);
        GaeTask storedTask = new GaeTask(task.getName(),
            agentId, timestamp.toString());
        ObjectDatastore datastore = new AnnotationObjectDatastore();
        datastore.store(storedTask);
       
        return task.getName();     
      } catch (MalformedURLException e) {
        e.printStackTrace();
      }

      // TODO: throw error?
View Full Code Here
29
30
31
32
33
34
35
36
37
        Date endDate = new Date();
        Queue queue = TaskUtils.getQueue(FileMoveDeleter.class);
        TaskOptions options = TaskUtils.newTaskOptions(FileMoveDeleter.class)
            .param("owner", KeyFactory.keyToString(user.getKey()))
            .param(pEND_DATE, String.valueOf(endDate.getTime()));
        TaskHandle handle = queue.add(options);
        Logger.info("Enqueued delete task. User key: %s End date: %s", user.getKey(), endDate);
        return handle;
    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
        }
       
        URL uri = new URL(url);
        String path = uri.getPath();   
        Queue queue = QueueFactory.getDefaultQueue();
        TaskHandle task = queue.add(withUrl(path)
            .payload(request.toString())
            .countdownMillis(delay));
       
        // store task information
        DateTime timestamp = DateTime.now().plus(delay);
        GaeTask storedTask = new GaeTask(task.getName(),
            agentId, timestamp.toString());
        ObjectDatastore datastore = new AnnotationObjectDatastore();
        datastore.store(storedTask);
       
        return task.getName();     
      } catch (MalformedURLException e) {
        e.printStackTrace();
      }

      // TODO: throw error?
View Full Code Here
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
        if (url != null){
          URL uri = url.toURL();
          path = uri.getPath();
        }
        Queue queue = QueueFactory.getDefaultQueue();
        TaskHandle task = queue.add(withUrl(path)
            .payload(request.toString())
            .countdownMillis(delay));
       
        // store task information
        DateTime timestamp = DateTime.now().plus(delay);
        GaeTask storedTask = new GaeTask(task.getName(),
            agentId, timestamp.toString());
        ObjectDatastore datastore = new AnnotationObjectDatastore();
        datastore.store(storedTask);
       
        return task.getName();     
      } catch (MalformedURLException e) {
        e.printStackTrace();
      }

      // TODO: throw error?
View Full Code Here
TOP

Related Classes of com.google.appengine.api.taskqueue.TaskHandle

  • com.almende.eve.scheduler.google.GaeSchedulerFactory$AppEngineScheduler
  • com.google.appengine.tck.taskqueue.AsyncTasksTest
  • com.google.appengine.tck.taskqueue.PullAsyncTest
  • com.google.appengine.tck.taskqueue.PullQueueTest
  • com.google.appengine.tck.taskqueue.PullTest
  • com.google.appengine.tck.taskqueue.SmokeTest
  • com.google.appengine.tck.taskqueue.TasksTest
  • rules.ChunkedRuleProcessor
  • tasks.FileMoveDeleter
    • 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.