@Generated(value="6fb3370301dcfcf186905a5982514e8d") public final class CacheEventJournalReadCodec extends Object
minSize
, the
call will wait until it has sufficient items.
The predicate, filter and projection may be null
in which case all elements are returned
and no projection is applied.Modifier and Type | Class and Description |
---|---|
static class |
CacheEventJournalReadCodec.RequestParameters |
static class |
CacheEventJournalReadCodec.ResponseParameters |
Modifier and Type | Field and Description |
---|---|
static int |
REQUEST_MESSAGE_TYPE |
static int |
RESPONSE_MESSAGE_TYPE |
Modifier and Type | Method and Description |
---|---|
static CacheEventJournalReadCodec.RequestParameters |
decodeRequest(ClientMessage clientMessage) |
static CacheEventJournalReadCodec.ResponseParameters |
decodeResponse(ClientMessage clientMessage) |
static ClientMessage |
encodeRequest(String name,
long startSequence,
int minSize,
int maxSize,
Data predicate,
Data projection) |
static ClientMessage |
encodeResponse(int readCount,
Collection<Data> items,
long[] itemSeqs,
long nextSeq) |
public static final int REQUEST_MESSAGE_TYPE
public static final int RESPONSE_MESSAGE_TYPE
public static ClientMessage encodeRequest(String name, long startSequence, int minSize, int maxSize, Data predicate, Data projection)
public static CacheEventJournalReadCodec.RequestParameters decodeRequest(ClientMessage clientMessage)
public static ClientMessage encodeResponse(int readCount, Collection<Data> items, long[] itemSeqs, long nextSeq)
public static CacheEventJournalReadCodec.ResponseParameters decodeResponse(ClientMessage clientMessage)
Copyright © 2019 Hazelcast, Inc.. All rights reserved.