camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Andrea Cosentino (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (CAMEL-11666) Camel Hazelcast Queue Cosumer implementation
Date Mon, 21 Aug 2017 14:19:01 GMT

    [ https://issues.apache.org/jira/browse/CAMEL-11666?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16135217#comment-16135217
] 

Andrea Cosentino commented on CAMEL-11666:
------------------------------------------

This is more clear now. I'll take a look tomorrow. It waan't clear you were talking from the
cluster perspective. Btw now it's clear

> Camel Hazelcast Queue Cosumer implementation
> --------------------------------------------
>
>                 Key: CAMEL-11666
>                 URL: https://issues.apache.org/jira/browse/CAMEL-11666
>             Project: Camel
>          Issue Type: Bug
>          Components: camel-hazelcast
>            Reporter: Ruslan Belinskyy
>              Labels: documentation, features
>
> Guys, 
> i have following concern / question about Hazelcast Queue Consumer:
> # I do understand why Topic is build based on CamelItemListener as ItemListener in HazelcastTopicConsumer.
But the same behavior in HazelcastQueueConsumer doesn't look meaningful:
> ## Unlike Topic, Queue has state and someone subscribed to Queue and didn't process it
(any reason here) no one will take it from queue (Event Already happened and will not happen
again). Message will be stuck there. Until you explicitly poll it, which Camel-Hazelcast doesn't
support (as consumer). I had to do Polling via Camel-Timer as workaround.
> ## Another problem is that ItemListener doesn't actually drain the Queue. It just listens
to events. As for me it doesn't make any sense to receive message from Queue and don't have
it removed from Queue. In current implementation you'll have to inject queue in Processor
to actually Poll the message after ADD Event. 
> If you won't change the code just please warn user here (http://camel.apache.org/hazelcast-component.html#HazelcastComponent-queue)
that Queue consumer doesn't drain the queue. And Processor should actually drain it.
> If node has failed to process message it should be explicitly polled to drain the queue
via for example Timer.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Mime
View raw message