Examples of take()

Examples of com.cloudera.flume.handlers.thrift.PrioritizedThriftEventSource.EventQueue.take()

51
52
53
54
55
56
57
58
59
60
61
        add(e6);
        add(e1);
      }
    };

    Assert.assertEquals(q.take(), e5); // WARN
    Assert.assertEquals(q.take(), e1); // INFO
    Assert.assertEquals(q.take(), e6); // DEBUG

  }
View Full Code Here

Examples of com.cloudhopper.mq.queue.QueueTake.take()

139
140
141
142
143
144
145
146
147
148
149
   
    // Option 2: Exits on timeout. (because of put contention or takes from another thread).
    //           Reschedules if queueSize is still non-zero.
    QueueTake take = localQueue.getTemporarySession();
    try {
        item = take.take(dqm.getConfiguration().getRemotingTakeTimeout());
    } catch (QueueTimeoutException te) {
        dqm.incrementRemotingTakeTimeouts();
        logger.debug("[{}] Timeout waiting to take from Queue. Size = {}. Item = {}", new Object[] { localQueue.getName(), localQueue.getSize(), item });
    }
View Full Code Here

Examples of com.datasift.client.push.PulledInteractions.take()

30
31
32
33
34
35
36
37
38
39
40
        datasift.historics().start(historic).sync();

        PulledInteractions historicSubscriptions = datasift.push().pull(historicsSubscription).sync();

        Interaction interaction;
        while (!((interaction = historicSubscriptions.take()) instanceof LastInteraction)) {
            System.out.println(interaction);
        }
        System.out.println("We're done!");
    }
}
View Full Code Here

Examples of com.fernferret.allpay.commons.GenericBank.take()

172
173
174
175
176
177
178
179
180
181
182
                    return false;
                } else if (pay) {
                    if (toWorld.getPrice() < 0D) {
                        bank.give(teleporterPlayer, toWorld.getPrice() * -1D, toWorld.getCurrency());
                    } else {
                        bank.take(teleporterPlayer, toWorld.getPrice(), toWorld.getCurrency());
                    }
                }
            }
        }
        return true;
View Full Code Here

Examples of com.fernferret.allpay.multiverse.commons.GenericBank.take()

290
291
292
293
294
295
296
297
298
299
300
                                }
                            } else {
                                if (portal.getPrice() < 0D) {
                                    bank.give(event.getPlayer(), -portal.getPrice(), portal.getCurrency());
                                } else {
                                    bank.take(event.getPlayer(), portal.getPrice(), portal.getCurrency());
                                }
                            }
                        }
                    }
                    this.plugin.log(Level.FINE, "Sending player to a location via our Sexy Travel Agent!");
View Full Code Here

Examples of com.google.enterprise.connector.pusher.DocPusher.take()

81
82
83
84
85
86
87
88
89
90
91
        }
        int k = pm.getPropertyNames().size();
        System.out.println("counter " + counter + ",  num properties " + k);
        System.out.println(pm.findProperty(
            SpiConstants.PROPNAME_DISPLAYURL).nextValue());
        push.take(pm);
      }
      String checkpoint = "";
      if (counter != 0) {
        System.out.println("appel checkpoint");
        checkpoint = documentList.checkpoint();
View Full Code Here

Examples of com.google.enterprise.connector.pusher.Pusher.take()

201
202
203
204
205
206
207
208
209
210
211
            }
          }
          LOGGER.finer("Sending document (" + docid + ") from connector "
              + connectorName + " to Pusher");

          if (pusher.take(nextDocument) != PusherStatus.OK) {
            LOGGER.fine("Traversal batch for connector " + connectorName
                + " is completing at the request of the Pusher,"
                + " after processing " + counter + " documents.");
            break;
          }
View Full Code Here

Examples of com.hazelcast.core.IQueue.take()

256
257
258
259
260
261
262
263
264
265
266
        }, 10);
        addOperation(operations, new Runnable() {
            public void run() {
                IQueue q = hazelcast.getQueue("myQ");
                try {
                    q.take();
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
            }
        }, 10);
View Full Code Here

Examples of com.jcabi.http.mock.MkContainer.take()

89
90
91
92
93
94
95
96
97
98
99
            Json.createObjectBuilder()
                .add("content", "hi you!")
                .build()
        );
        MatcherAssert.assertThat(
            container.take().method(),
            Matchers.equalTo(Request.PATCH)
        );
        container.stop();
    }
View Full Code Here

Examples of com.jcabi.http.mock.MkContainer.take()

70
71
72
73
74
75
76
77
78
79
80
            repo()
        );
        try {
            final Blob blob = blobs.create(content, "utf-8");
            MatcherAssert.assertThat(
                container.take().method(),
                Matchers.equalTo(Request.POST)
            );
            MatcherAssert.assertThat(
                new Blob.Smart(blob).url(),
                Matchers.equalTo("http://localhost/1")
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.