Consumer Example

    1.2 PushConsumer

    3.        public static void test(String[] args) throws Throwable {
    4.            final String masterHostAndPort = "localhost:8000";
    5.            final String topic = "test";
    6.            final String group = "test-group";
    7.            final ConsumerConfig consumerConfig = new ConsumerConfig(masterHostAndPort, group);
    8.            final MessageSessionFactory messageSessionFactory = new TubeSingleSessionFactory(consumerConfig);
    9.            final PushMessageConsumer pushConsumer = messageSessionFactory.createPushConsumer(consumerConfig);
    11.                @Override
    12.                public void receiveMessages(PeerInfo peerInfo, List<Message> messages) throws InterruptedException {
    13.                    for (Message message : messages) {
    14.                        System.out.println("received message : " + new String(message.getData()));
    15.                    }
    16.                }
    17.                @Override
    18.                    return null;
    20.                @Override
    21.                public void stop() {
    22.                    //
    23.                }
    24.            });
    25.            pushConsumer.completeSubscribe();
    26.            CountDownLatch latch = new CountDownLatch(1);
    27.            latch.await(10, TimeUnit.MINUTES);