Package | Description |
---|---|
com.hazelcast.topic.impl.reliable |
Modifier and Type | Class and Description |
---|---|
class |
ReliableMessageListenerAdapter<E> |
Modifier and Type | Field and Description |
---|---|
protected ReliableMessageListener<E> |
MessageRunner.listener |
Constructor and Description |
---|
MessageRunner(String id,
ReliableMessageListener<E> listener,
Ringbuffer<ReliableTopicMessage> ringbuffer,
String topicName,
int batchSze,
SerializationService serializationService,
Executor executor,
ConcurrentMap<String,MessageRunner<E>> runnersMap,
ILogger logger) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.