Improve MessagingService assertion. patch by scode; reviewed by jbellis for CASSANDRA-3887
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/212fd417 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/212fd417 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/212fd417 Branch: refs/heads/trunk Commit: 212fd417f3e622449725d83e8dacab9506318dff Parents: 3a4459f Author: Peter Schuller <[email protected]> Authored: Wed Feb 15 00:37:26 2012 +0100 Committer: Peter Schuller <[email protected]> Committed: Wed Feb 15 00:37:26 2012 +0100 ---------------------------------------------------------------------- .../org/apache/cassandra/net/MessagingService.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/212fd417/src/java/org/apache/cassandra/net/MessagingService.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/net/MessagingService.java b/src/java/org/apache/cassandra/net/MessagingService.java index d7613cb..0bb36fb 100644 --- a/src/java/org/apache/cassandra/net/MessagingService.java +++ b/src/java/org/apache/cassandra/net/MessagingService.java @@ -569,7 +569,7 @@ public final class MessagingService implements MessagingServiceMBean Runnable runnable = new MessageDeliveryTask(message, id); ExecutorService stage = StageManager.getStage(message.getMessageType()); - assert stage != null : "No stage for message type " + message.getMessageType(); + assert stage != null : "No stage for message type " + message.getVerb(); stage.execute(runnable); }
