Skip to content

Commit 71570d4

Browse files
committed
Test: BlockingClusterStatePublishResponseHandlerTests fix compilation error reg. AbstractRunnable
1 parent 8ef9170 commit 71570d4

File tree

1 file changed

+10
-11
lines changed

1 file changed

+10
-11
lines changed

src/test/java/org/elasticsearch/discovery/BlockingClusterStatePublishResponseHandlerTests.java

+10-11
Original file line numberDiff line numberDiff line change
@@ -53,17 +53,16 @@ public PublishResponder(boolean fail, DiscoveryNode node, CyclicBarrier barrier,
5353
}
5454

5555
@Override
56-
public void onFailure(Throwable t) {
57-
logger.error("unexpected error", t);
58-
}
59-
60-
@Override
61-
protected void doRun() throws Exception {
62-
barrier.await();
63-
if (fail) {
64-
handler.onFailure(node, new Exception("bla"));
65-
} else {
66-
handler.onResponse(node);
56+
public void run() {
57+
try {
58+
barrier.await();
59+
if (fail) {
60+
handler.onFailure(node, new Exception("bla"));
61+
} else {
62+
handler.onResponse(node);
63+
}
64+
} catch (Throwable t) {
65+
logger.error("unexpected error", t);
6766
}
6867
}
6968
}

0 commit comments

Comments
 (0)