public class

ConsumerStateModel

extends StateModel
java.lang.Object
   ↳ org.apache.helix.participant.statemachine.StateModel
     ↳ org.apache.helix.recipes.rabbitmq.ConsumerStateModel

Summary

[Expand]
Inherited Fields
From class org.apache.helix.participant.statemachine.StateModel
Public Constructors
ConsumerStateModel(String consumerId, String partition, String mqServer)
Public Methods
void onBecomeDroppedFromOffline(Message message, NotificationContext context)
void onBecomeOfflineFromError(Message message, NotificationContext context)
void onBecomeOfflineFromOnline(Message message, NotificationContext context)
void onBecomeOnlineFromOffline(Message message, NotificationContext context)
void reset()
Called when the state model is reset
[Expand]
Inherited Methods
From class org.apache.helix.participant.statemachine.StateModel
From class java.lang.Object

Public Constructors

public ConsumerStateModel (String consumerId, String partition, String mqServer)

Public Methods

public void onBecomeDroppedFromOffline (Message message, NotificationContext context)

public void onBecomeOfflineFromError (Message message, NotificationContext context)

public void onBecomeOfflineFromOnline (Message message, NotificationContext context)

Throws
InterruptedException

public void onBecomeOnlineFromOffline (Message message, NotificationContext context)

public void reset ()

Called when the state model is reset