| commit | 8fd0f6f268c887d55e135618259a1221495eb3cd | [log] [tgz] |
|---|---|---|
| author | Bruce Schuchardt <bschuchardt@pivotal.io> | Fri Apr 03 08:29:51 2020 -0700 |
| committer | GitHub <noreply@github.com> | Fri Apr 03 08:29:51 2020 -0700 |
| tree | f45aebe15956f2994936d591bc171822e2c510c3 | |
| parent | 6312b324ddc1e99337f3ebf37a9775a53af0aa86 [diff] | |
| parent | 189ae766efb47dd94ca495a00e7ead88dbd287a1 [diff] |
Merge pull request #4892 from apache/feature/GEODE-7939 GEODE-7939: membership heartbeat messages aren't designated high-prio…
diff --git a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java index d1cfc83..263a9bd 100755 --- a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java +++ b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatMessage.java
@@ -72,4 +72,9 @@ DeserializationContext context) throws IOException, ClassNotFoundException { requestId = in.readInt(); } + + @Override + public boolean isHighPriority() { + return true; + } }
diff --git a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java index 5441074..bcdb4b1 100755 --- a/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java +++ b/geode-membership/src/main/java/org/apache/geode/distributed/internal/membership/gms/messages/HeartbeatRequestMessage.java
@@ -83,4 +83,10 @@ requestId = in.readInt(); target = context.getDeserializer().readObject(in); } + + @Override + public boolean isHighPriority() { + return true; + } + }