Hazelcast ITopic Arayüzü

Giriş

Şu satırı dahil ederiz

import com.hazelcast.core.ITopic;

constructor

Örnek - Topic

Şöyle yaparız

HazelcastInstance hzInstance = ...;
ITopic<StockPrice> topic = hzInstance.getTopic(topicName);

Örnek - Reliable Topic

Şöyle yaparız

HazelcastInstance hz = ...
ITopic<Long> topic = hz.getReliableTopic("sometopic");

addMessageListener metodu

Örnek

Şöyle yaparız

import com.hazelcast.topic.Message;
import com.hazelcast.topic.MessageListener;

HazelcastInstance hz = ...;
ITopic<Long> topic = hz.getReliableTopic("sometopic");
topic.addMessageListener(new MessageListenerImpl());


MessageListenerImpl implements MessageListener<Long> {
  public void onMessage(Message<Long> m) {
    System.out.println("Received: " + m.getMessageObject());
  }
}

Örnek - Lambda

Şöyle yaparız. Node1 publish, Node 2 ise subscribe işlemini lambda ile gerçekleştirir. 

// node #1
Hazelcast.newHazelcastInstance()
         .getTopic("topic")
         .publish(new Date());

// node #2
Hazelcast.newHazelcastInstance()
         .getTopic("topic");
         .addMessageListener(message -> /*Do something here*/);

publish metodu

Gönderilecek nesne Serializable'dan kalıtır.

Örnek - Object

Şöyle yaparız

StockPrice price = ...
topic.publish(price);

Örnek - long

Şöyle yaparız

long messageId  = ...
topic.publish(messageId);