public class SbcCellLoadEvent extends SbcEvent
SbcEvent.SbcEventHandlerResult
eventContext, LOG
Constructor and Description |
---|
SbcCellLoadEvent(SbcContext sbcContext,
List<Integer> cellIds,
kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.CellLoadDescriptionInternal> cb) |
Modifier and Type | Method and Description |
---|---|
protected SbcEvent.SbcEventHandlerResult |
handleEvent()
The "business logic" of an SbcEvent.
|
protected void |
respondToClient(org.apache.kafka.common.requests.ApiError error,
SbcEvent.SbcEventHandlerResult result)
This method is invoked when an operation completes (the
SbcEvent.SbcEventHandlerResult does not indicate that any resources are needed
to continue. |
public SbcCellLoadEvent(SbcContext sbcContext, List<Integer> cellIds, kafka.controller.ClusterBalanceManager.BalanceManagerStatusQueryClientCallback<kafka.common.CellLoadDescriptionInternal> cb)
@Nonnull protected SbcEvent.SbcEventHandlerResult handleEvent() throws Exception
SbcEvent
handleEvent
in class SbcEvent
Exception
protected void respondToClient(org.apache.kafka.common.requests.ApiError error, SbcEvent.SbcEventHandlerResult result)
SbcEvent
SbcEvent.SbcEventHandlerResult
does not indicate that any resources are needed
to continue. Events which need to respond to clients via a client callback will respond here.respondToClient
in class SbcEvent
error
- the ApiError value for success or failure. handleEvent operations which completed normally will have a result of ApiError.NONE.result
- The SbcEventHandlerResult which was returned from SbcEvent.handleEvent()
}.