Updated Branches: refs/heads/trunk 283b1a33b -> 931be4803
change stream message priority(make received/retry proorities higher than complete). Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/931be480 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/931be480 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/931be480 Branch: refs/heads/trunk Commit: 931be4803b1f21dc1605612364df128dce74a6ef Parents: 283b1a3 Author: Yuki Morishita <yu...@apache.org> Authored: Tue Jul 23 13:12:34 2013 -0500 Committer: Yuki Morishita <yu...@apache.org> Committed: Tue Jul 23 13:12:34 2013 -0500 ---------------------------------------------------------------------- .../org/apache/cassandra/streaming/messages/StreamMessage.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/931be480/src/java/org/apache/cassandra/streaming/messages/StreamMessage.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/streaming/messages/StreamMessage.java b/src/java/org/apache/cassandra/streaming/messages/StreamMessage.java index 11e9955..8ba731a 100644 --- a/src/java/org/apache/cassandra/streaming/messages/StreamMessage.java +++ b/src/java/org/apache/cassandra/streaming/messages/StreamMessage.java @@ -65,9 +65,9 @@ public abstract class StreamMessage { PREPARE(1, 5, PrepareMessage.serializer), FILE(2, 0, FileMessage.serializer), - RECEIVED(3, 1, ReceivedMessage.serializer), - RETRY(4, 1, RetryMessage.serializer), - COMPLETE(5, 4, CompleteMessage.serializer), + RECEIVED(3, 4, ReceivedMessage.serializer), + RETRY(4, 4, RetryMessage.serializer), + COMPLETE(5, 1, CompleteMessage.serializer), SESSION_FAILED(6, 5, SessionFailedMessage.serializer); public static Type get(byte type)
