Kolejka Hazelcast Info

Question

Obecnie piszę system rozproszony przy użyciu hazelcast. Mam kilka pytań dotyczących kolejki zaimplementowanej przy użyciu hazelcast.

1. Jaki jest najlepszy sposób przetwarzania danych z kolejki? Obecnie mam wątki na każdym "węźle" odczytujące kolejkę blokującą przetwarzającą dane. Czy to jest poprawne, czy jest jakaś klasa, której nie jestem świadomy, która zajmuje się tym jak JMS lub messageListener?
2. Widzę, że istnieje ustawienie czasu życia, które usunie wpis z kolejki po jej wygaśnięciu. Moje pytanie brzmi ... czy istnieje sposób na wykrycie usunięcia wygasłego przedmiotu z kolejki? Wiem, że są nasi słuchacze, ale to nie pomaga, ponieważ jest ono uruchamiane we wszystkich "węzłach", a nie tylko w jednym. Szukam sposobu wykonywania kodu dla każdej wygasłej wiadomości (podobnie jak kolejka z martwą literą).

Wszelkie uwagi i porady w tej sprawie byłyby bardzo mile widziane.

Dzięki

Answer 1

1. Nie ma innego sposobu, w tej chwili. Więc będziesz mieć swoje wątki na każdym węźle wywołującym queue.take(). Zespół Hazelcast planuje dodać IQueue.addQueueConsumer (QueueConsumer), który będzie zachowywał się podobnie do JMS MessageListener

2. Masz rację. Dodawanie słuchaczy nie jest dobrym sposobem na to, ponieważ jest to bardzo kosztowna operacja. Możesz utworzyć problem na ten temat pod numerem http://code.google.com/p/hazelcast/issues. Na pewno fajnie jest mieć funkcję.

-talip @ hazelcast