cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject git commit: change stream message priority(make received/retry proorities higher than complete).
Date Tue, 23 Jul 2013 18:12:42 GMT
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 <yukim@apache.org>
Authored: Tue Jul 23 13:12:34 2013 -0500
Committer: Yuki Morishita <yukim@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)


Mime
View raw message