aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus')
-rwxr-xr-xmessagebus/src/main/java/com/yahoo/messagebus/routing/RoutingNode.java6
1 files changed, 2 insertions, 4 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/routing/RoutingNode.java b/messagebus/src/main/java/com/yahoo/messagebus/routing/RoutingNode.java
index 1f63744c205..ac8fd637646 100755
--- a/messagebus/src/main/java/com/yahoo/messagebus/routing/RoutingNode.java
+++ b/messagebus/src/main/java/com/yahoo/messagebus/routing/RoutingNode.java
@@ -21,7 +21,6 @@ import java.util.ArrayDeque;
import java.util.ArrayList;
import java.util.Deque;
import java.util.List;
-import java.util.Stack;
import java.util.concurrent.atomic.AtomicInteger;
/**
@@ -130,7 +129,7 @@ public class RoutingNode implements ReplyHandler {
* @param msg The error message to assign.
*/
private void notifyAbort(String msg) {
- Stack<RoutingNode> stack = new Stack<>();
+ Deque<RoutingNode> stack = new ArrayDeque<>();
stack.push(this);
while (!stack.isEmpty()) {
RoutingNode node = stack.pop();
@@ -430,8 +429,7 @@ public class RoutingNode implements ReplyHandler {
private boolean lookupRoute() {
RoutingTable table = mbus.getRoutingTable(msg.getProtocol());
Hop hop = route.getHop(0);
- if (hop.getDirective(0) instanceof RouteDirective) {
- RouteDirective dir = (RouteDirective)hop.getDirective(0);
+ if (hop.getDirective(0) instanceof RouteDirective dir) {
if (table == null || !table.hasRoute(dir.getName())) {
setError(ErrorCode.ILLEGAL_ROUTE, "Route '" + dir.getName() + "' does not exist.");
return false;