public abstract class AbstractRoutingStrategy extends Object implements RoutingStrategy
RoutingStrategy interface that includes a fallback RoutingStrategy
which prescribes what happens when routing cannot be resolved by this implementation.| Modifier | Constructor and Description |
|---|---|
protected |
AbstractRoutingStrategy(RoutingStrategy fallbackRoutingStrategy)
Initializes the strategy using given
RoutingStrategy prescribing the fallback approach when this
implementation cannot resolve a routing key. |
|
AbstractRoutingStrategy(UnresolvedRoutingKeyPolicy fallbackRoutingStrategy)
Deprecated.
in favor of
AbstractRoutingStrategy(RoutingStrategy) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract String |
doResolveRoutingKey(CommandMessage<?> command)
Resolve the Routing Key for the given
command. |
String |
getRoutingKey(CommandMessage<?> command)
Generates a routing key for the given
command. |
@Deprecated public AbstractRoutingStrategy(@Nonnull UnresolvedRoutingKeyPolicy fallbackRoutingStrategy)
AbstractRoutingStrategy(RoutingStrategy)UnresolvedRoutingKeyPolicy prescribing the fallback approach when
this implementation cannot resolve a routing key.fallbackRoutingStrategy - the fallback routing to use whenever this RoutingStrategy doesn't succeedprotected AbstractRoutingStrategy(@Nonnull RoutingStrategy fallbackRoutingStrategy)
RoutingStrategy prescribing the fallback approach when this
implementation cannot resolve a routing key.fallbackRoutingStrategy - the fallback routing to use whenever this RoutingStrategy doesn't succeedpublic String getRoutingKey(@Nonnull CommandMessage<?> command)
RoutingStrategycommand. Commands that should be handled by the same segment,
should result in the same routing key.getRoutingKey in interface RoutingStrategycommand - the command to create a routing key forprotected abstract String doResolveRoutingKey(@Nonnull CommandMessage<?> command)
command.command - the command to resolve the routing key fornull if unresolvedCopyright © 2010–2023. All rights reserved.