CODEWITHSUNDEEP
apache-camelpollingproducer-consumer
Mehdi Yedes
Mehdi Yedes

Reputation: 2375

Apache Camel: Polling consumer

I'm new to Apache Camel and I'm trying to understand and use the Polling Consumer EIP in a simple project but I feel a little bit lost.. Could someone please help me with a little explanation or even with a little working example.

Any help would be appreciated Thanks in advance

Upvotes: 1

Views: 11635

Answers (2)

Kushagra Saxena
Kushagra Saxena

Reputation: 71

Camel supports implementing the Polling Consumer from the EIP patterns using the PollingConsumer interface which can be created via the Endpoint.createPollingConsumer() method.

This is also known as a synchronous receiver, because the receiver thread blocks until a message is received. We call it a Polling Consumer because the receiver polls for a message, processes it, then polls for another. As a convenience, messaging API’s usually provide a receive() method that blocks until a message is delivered, in addition to methods like receiveNoWait() and receive(0) that return immediately if no message is available.

Eg

ActiveMq Consumer

<from uri="activemq:someQueue"/>
<to uri="direct:somepath"/>

Periodic Consumer

<from uri="timer://foo?period=5000"/>
 <to uri="direct:somepath"/>

For more information regarding Polling Consumer

Upvotes: 1

Ben ODay
Ben ODay

Reputation: 21015

for most use cases, you can create a consumer by just defining them in the from() clause in a route...

from("activemq:inbox").to(new MyProcessor());

but, you can also write your own POJO polling consumer logic for more control over the consumer logic...simply initiate it periodically with a timer and call the receive() method as follows:

from("timer://foo?period=5000").bean(MyBean, "processQueue");

public void processQueue() {
    while (true) {
        // receive the message from the queue, wait at most 3 sec
        String msg = consumer.receiveBody("activemq:inbox", 3000, String.class);
        if (msg == null) {
            // no more messages in queue
            break;
        }

        // do something with body
    }
}

see the docs for more details: http://camel.apache.org/polling-consumer

Upvotes: 3

Related Questions