co.cask.cdap.data2.queue

Class ConsumerConfig

java.lang.Object

co.cask.cdap.data2.queue.ConsumerGroupConfig

co.cask.cdap.data2.queue.ConsumerConfig

public final class ConsumerConfig
extends ConsumerGroupConfig

Contains queue consumer instance configuration.

Constructor Summary

Constructors

Constructor and Description
ConsumerConfig(ConsumerGroupConfig groupConfig, int instanceId)
ConsumerConfig(long groupId, int instanceId, int groupSize, DequeueStrategy dequeueStrategy, String hashKey)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
int	getInstanceId()
int	hashCode()
String	toString()

Methods inherited from class co.cask.cdap.data2.queue.ConsumerGroupConfig

getDequeueStrategy, getGroupId, getGroupSize, getHashKey

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ConsumerConfig

public ConsumerConfig(ConsumerGroupConfig groupConfig,
              int instanceId)

ConsumerConfig

public ConsumerConfig(long groupId,
              int instanceId,
              int groupSize,
              DequeueStrategy dequeueStrategy,
              String hashKey)

Method Detail

getInstanceId

public int getInstanceId()

toString

public String toString()

Overrides:

toString in class ConsumerGroupConfig

equals

public boolean equals(Object o)

Overrides:

equals in class ConsumerGroupConfig

hashCode

public int hashCode()

Overrides:

hashCode in class ConsumerGroupConfig