public class

ConsumerStateModelFactory

extends HelixStateModelFactory<T extends StateModel>
java.lang.Object
   ↳ org.apache.helix.participant.statemachine.HelixStateModelFactory<T extends org.apache.helix.participant.statemachine.StateModel>
     ↳ org.apache.helix.recipes.rabbitmq.ConsumerStateModelFactory

Summary

Public Constructors
ConsumerStateModelFactory(String consumerId, String msServer)
Public Methods
ConsumerStateModel createNewStateModel(PartitionId partition)
This method will be invoked only once per partition per session
[Expand]
Inherited Methods
From class org.apache.helix.participant.statemachine.HelixStateModelFactory
From class java.lang.Object

Public Constructors

public ConsumerStateModelFactory (String consumerId, String msServer)

Public Methods

public ConsumerStateModel createNewStateModel (PartitionId partition)

This method will be invoked only once per partition per session