List of readMessages() Examples

Examples of readMessages()

com.google.i18n.pseudolocalization.format.ReadableMessageCatalog.readMessages()
Load messages from the catalog. This may involve reading the entire contents of the catalog immediately, or it may read them as requested from the iterator. @return a collection of {@link Message}s @throws IOException
com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()
Acquire up to N items from the queue. Each item must be released by calling ackMessage. TODO: Items since last process time @param itemsToRead @return @throws InterruptedException @throws Exception
org.sis.ancmessaging.server.utility.SmsMessageHandler.readMessages()

Examples of com.google.i18n.pseudolocalization.format.ReadableMessageCatalog.readMessages()

      MessageCatalog msgCat, InputStream inputStream)
      throws IOException {
    List<Message> processedMessages = new ArrayList<Message>();
    ReadableMessageCatalog input = msgCat.readFrom(inputStream);
    try {
      for (Message msg : input.readMessages()) {
        pipeline.localize(msg);
        processedMessages.add(msg);
      }
    } finally {
      input.close();

View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()

        Assert.assertEquals(1, queue.getMessageCount());
        printMessages("Pending messages after insert ORIG message", queue.peekMessagesByKey(key));


        // Consume the message
        LOG.info("*** Reading first message ***");
        final List<MessageContext> m1 = consumer.readMessages(10);
        printMessages("Consuming the ORIG message", m1);
        Assert.assertEquals(1, m1.size());


        printMessages("Pending messages after consume ORIG " + key, queue.peekMessagesByKey(key));

View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()

        // Exceed the timeout
        Thread.sleep(2000);


        // Consume the timeout event
        LOG.info("*** Reading timeout message ***");
        final List<MessageContext> m2 = consumer.readMessages(10);
        printMessages("Consuming the TIMEOUT message", m2);
        Assert.assertEquals(1, m2.size());


        printMessages("Pending messages after consume TIMEOUT " + key, queue.peekMessagesByKey(key));
//        Assert.assertEquals(2, m2a.size());

View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()


        printMessages("Pending messages after both acks " + key, queue.peekMessagesByKey(key));
//        Assert.assertEquals(2, m2a.size());


        // Consume anything that is in the queue
        final List<MessageContext> m3 = consumer.readMessages(10);
        printMessages("Consuming messages", m3);
        Assert.assertEquals(1, m3.size());


        printMessages("Pending messages after 2nd consume " + key, queue.peekMessagesByKey(key));

View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()


        consumer.ackMessages(m3);


        Thread.sleep(2000);


        final List<MessageContext> m4 = consumer.readMessages(10);
        printMessages("Consuming messages", m4);
        Assert.assertEquals(1, m4.size());


        // There should be only one message
//        Assert.assertEquals(1, queue.getMessageCount());

View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()


        // There should be only one message
//        Assert.assertEquals(1, queue.getMessageCount());


        for (int i = 0; i < 10; i++) {
            final List<MessageContext> m5 = consumer.readMessages(10);
            Assert.assertEquals(1, m5.size());


            long systemtime = System.currentTimeMillis();
            MessageContext m = Iterables.getFirst(m5, null);
            LOG.info("MessageTime: " + (systemtime - m.getMessage().getTrigger().getTriggerTime()));

View Full Code Here

Examples of com.netflix.astyanax.recipes.queue.MessageConsumer.readMessages()


            // Delete the message
            scheduler.deleteMessageByKey(key2);


            // Read the message
            final Collection<MessageContext> lm2 = consumer.readMessages(10, 10, TimeUnit.SECONDS);
            LOG.info("Read message: " + lm2);
            Assert.assertEquals(1, lm2.size());
            LOG.info(lm2.toString());
            Assert.assertEquals(1, scheduler.getMessageCount());

View Full Code Here

Examples of org.sis.ancmessaging.server.utility.SmsMessageHandler.readMessages()

    @Override
    public void readIncomingInInterval() {
        MainForm mainForm = MainForm.getInstance();
        SmsMessageHandler messageHandler = new SmsMessageHandler();
        try {
            List<InboundMessage> msgList = messageHandler.readMessages();


            for (InboundMessage inboundMessage : msgList) {
                String content = inboundMessage.getText().trim();
                String identifier = content.substring(0, 1);
                int seqId = Integer.parseInt(content.substring(2).trim());

View Full Code Here

TOP

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.