Table of Contents

Class KNetShareConsumerValueBuffered<K, V>

Namespace
MASES.KNet.Consumer
Assembly
MASES.KNet.dll

Extends KNetShareConsumer<K, V, TJVMK, TJVMV> using ByteBuffer for value

public class KNetShareConsumerValueBuffered<K, V> : KNetShareConsumer<K, V, byte[], ByteBuffer>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IShareConsumer<K, V, byte[], ByteBuffer>, IShareConsumer<byte[], ByteBuffer>, ICloseable, IAutoCloseable

Type Parameters

K

The key type

V

The value type

Inheritance
KNetShareConsumerValueBuffered<K, V>
Implements
Inherited Members

Constructors

KNetShareConsumerValueBuffered(ConsumerConfigBuilder, ISerDes<K, byte[]>, ISerDes<V, ByteBuffer>, bool)

Initialize a new instance of KNetShareConsumer<K, V, TJVMK, TJVMV>

public KNetShareConsumerValueBuffered(ConsumerConfigBuilder props, ISerDes<K, byte[]> keyDeserializer, ISerDes<V, ByteBuffer> valueDeserializer, bool useJVMCallback = false)

Parameters

props ConsumerConfigBuilder

The properties to use, see ConsumerConfigBuilder

keyDeserializer ISerDes<K, byte[]>

Key serializer base on SerDes<T, TJVMT>

valueDeserializer ISerDes<V, ByteBuffer>

Value serializer base on SerDes<T, TJVMT>

useJVMCallback bool

true to active callback based mode

KNetShareConsumerValueBuffered(ConsumerConfigBuilder, bool)

Initialize a new instance of KNetShareConsumer<K, V, TJVMK, TJVMV>

public KNetShareConsumerValueBuffered(ConsumerConfigBuilder configBuilder, bool useJVMCallback = false)

Parameters

configBuilder ConsumerConfigBuilder

An instance of ConsumerConfigBuilder

useJVMCallback bool

true to active callback based mode

Edit this page