Package com.linkedin.venice.helix
Class HelixStatusMessageChannel
java.lang.Object
com.linkedin.venice.helix.HelixStatusMessageChannel
- All Implemented Interfaces:
StatusMessageChannel
Deprecated.
The control message changed built on Helix message service.
It will convert Venice message to helix message when sending and reverse this process when receiving.
Only one Helix message type is used, so channel is similar to a dispatcher that receive all of control messages and dispatch them to related handlers.
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionHelixStatusMessageChannel
(SafeHelixManager manager, HelixMessageChannelStats stats) Deprecated.HelixStatusMessageChannel
(SafeHelixManager manager, HelixMessageChannelStats stats, int timeOut) Deprecated. -
Method Summary
Modifier and TypeMethodDescriptionprotected StatusMessage
convertHelixMessageToVeniceMessage
(org.apache.helix.model.Message helixMessage) Deprecated.Convert Helix message to Venice Message.protected org.apache.helix.model.Message
convertVeniceMessageToHelixMessage
(StatusMessage veniceMessage) Deprecated.Convert Venice message to Helix message.protected <T extends StatusMessage>
StatusMessageHandlergetHandler
(Class<T> clazz) Deprecated.Get the handler for given Venice message type.<T extends StatusMessage>
voidregisterHandler
(Class<T> clazz, StatusMessageHandler<T> handler) Deprecated.Register a handler to handle a specific message type.void
sendToController
(StatusMessage message) Deprecated.Send message to controller.void
sendToController
(StatusMessage message, int retryCount, long retryDurationMs) Deprecated.Send message to controller.void
sendToStorageNodes
(String clusterName, StatusMessage message, String resourceName, int retryCount) Deprecated.Send message to all storage nodes in the given cluster.<T extends StatusMessage>
voidunRegisterHandler
(Class<T> clazz, StatusMessageHandler<T> handler) Deprecated.Remove a handler for a specific message type.
-
Field Details
-
DEFAULT_SEND_MESSAGE_TIME_OUT
public static final int DEFAULT_SEND_MESSAGE_TIME_OUTDeprecated.- See Also:
-
HELIX_MESSAGE_TYPE
Deprecated.- See Also:
-
VENICE_MESSAGE_CLASS
Deprecated.- See Also:
-
VENICE_MESSAGE_FIELD
Deprecated.- See Also:
-
-
Constructor Details
-
HelixStatusMessageChannel
Deprecated. -
HelixStatusMessageChannel
public HelixStatusMessageChannel(SafeHelixManager manager, HelixMessageChannelStats stats, int timeOut) Deprecated.
-
-
Method Details
-
sendToController
Deprecated.Description copied from interface:StatusMessageChannel
Send message to controller. If met any error during the sending, retry it after retryDurationMs until retry @retryCount times.- Specified by:
sendToController
in interfaceStatusMessageChannel
retryCount
- retry how many times.retryDurationMs
- the duration between two retries.
-
sendToController
Deprecated.Description copied from interface:StatusMessageChannel
Send message to controller.- Specified by:
sendToController
in interfaceStatusMessageChannel
-
sendToStorageNodes
public void sendToStorageNodes(String clusterName, StatusMessage message, String resourceName, int retryCount) Deprecated.Description copied from interface:StatusMessageChannel
Send message to all storage nodes in the given cluster. If met any error during the sending, retry it after retryDurationMs until retry @retryCount times.- Specified by:
sendToStorageNodes
in interfaceStatusMessageChannel
-
registerHandler
public <T extends StatusMessage> void registerHandler(Class<T> clazz, StatusMessageHandler<T> handler) Deprecated.Description copied from interface:StatusMessageChannel
Register a handler to handle a specific message type.- Specified by:
registerHandler
in interfaceStatusMessageChannel
-
unRegisterHandler
public <T extends StatusMessage> void unRegisterHandler(Class<T> clazz, StatusMessageHandler<T> handler) Deprecated.Description copied from interface:StatusMessageChannel
Remove a handler for a specific message type.- Specified by:
unRegisterHandler
in interfaceStatusMessageChannel
-
convertHelixMessageToVeniceMessage
protected StatusMessage convertHelixMessageToVeniceMessage(org.apache.helix.model.Message helixMessage) Deprecated.Convert Helix message to Venice Message.- Parameters:
helixMessage
-- Returns:
-
convertVeniceMessageToHelixMessage
protected org.apache.helix.model.Message convertVeniceMessageToHelixMessage(StatusMessage veniceMessage) Deprecated.Convert Venice message to Helix message.- Parameters:
veniceMessage
-- Returns:
-
getHandler
Deprecated.Get the handler for given Venice message type.- Type Parameters:
T
-- Parameters:
clazz
-- Returns:
-