HazelcastAPI DefaultQueryCache Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.map.impl.querycache.subscriber.DefaultQueryCache;

QueryCache

  InternalQueryCache

    AbstractInternalQueryCache

      DefaultQueryCache

add metodu

Callstack şöyle. Map'e ekleme işlemi yapıldıktan sonra ismi hz.client_1_event-N olan başka bir thread tarafından tetikleniyor.

add:101, DefaultQueryCacheRecordStore (com.hazelcast.map.impl.querycache.subscriber)
setInternal:104, DefaultQueryCache (com.hazelcast.map.impl.querycache.subscriber)
set:85, DefaultQueryCache (com.hazelcast.map.impl.querycache.subscriber)
handle:98, SubscriberAccumulatorHandler (com.hazelcast.map.impl.querycache.subscriber)
addQueryCache:181, SubscriberAccumulator (com.hazelcast.map.impl.querycache.subscriber)
accumulate:70, SubscriberAccumulator (com.hazelcast.map.impl.querycache.subscriber)
onEvent:64, SubscriberListener (com.hazelcast.map.impl.querycache.subscriber)
handleQueryCacheBatchEvent:261, ClientQueryCacheEventService$QueryCacheHandler (com.hazelcast.client.map.impl.querycache.subscriber)
handle:159, ContinuousQueryAddListenerCodec$AbstractEventHandler (com.hazelcast.client.impl.protocol.codec)
handleEventMessageOnCallingThread:190, ClientListenerServiceImpl (com.hazelcast.client.impl.spi.impl.listener)
run:361, ClientListenerServiceImpl$ClientEventProcessor (com.hazelcast.client.impl.spi.impl.listener)
process:245, StripedExecutor$Worker (com.hazelcast.internal.util.executor)
run:228, StripedExecutor$Worker (com.hazelcast.internal.util.executor)

Gönderilen event nesnesi şöyle. Bu listenin büyüklüğü QueryCacheConfig.setBatchSize() ile belirleniyor.

Collection<com.hazelcast.map.impl.querycache.event.QueryCacheEventData>