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

Package com.netflix.astyanax.recipes.queue

Class com.netflix.astyanax.recipes.queue.MessageConsumer

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

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

        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

        // 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


        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


        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


        // 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


            // 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

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.