HazelcastAPI IQueue Arayüzü - Veriyi Bölümlendirerek Dağıtmaz

Giriş

Şu satırı dahil ederiz

import com.hazelcast.collection.IQueue;

java.util.concurrent.BlockingQueue arayüzünden kalıtır. Açıklaması şöyle

The IQueue is not a partitioned data-structure. All the content of an IQueue is stored in a single machine (and in the backup).

Örnek

Şöyle yaparız

HazelcastInstance instance = ...;
IQueue<Float> queue = instance.getQueue("dist_q");

addItemListener metodu

Örnek

Şöyle yaparız

import com.hazelcast.collection.ItemEvent;
import com.hazelcast.collection.ItemListener;

public class MyItemListener implements ItemListener<Foo> {
  @Override
  public void itemAdded(ItemEvent<Foo> item) {
    System.out.println("Item added: " + item.getItem());   
  }

  @Override
  public void itemRemoved(ItemEvent<Foo> item) {
    System.out.println("Item removed: " + item.getItem());      
  }
}

boolean includeValue = true;
queue.addItemListener(listener, includeValue);

drainTo metodu

Örnek

Şöyle yaparız

BlockingQueue<Message> queue = hazelcastInstance.getQueue("send-test");
Collection<Message> list = new HashSet<>();
int d = queue.drainTo(list, 100);

offer metodu

Bir örnek burada

poll metodu

Bir örnek burada

take metodu

Örnek ver