This is an automated email from the ASF dual-hosted git repository. dschneider pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push: new 72eca0c GEODE-6690: use the caching addStringPart method 72eca0c is described below commit 72eca0c33a942db731366cacf3603a806f893e7c Author: Darrel Schneider <dschnei...@pivotal.io> AuthorDate: Thu May 2 10:07:48 2019 -0700 GEODE-6690: use the caching addStringPart method now uses the caching addStringPart for region name parts --- .../main/java/org/apache/geode/cache/client/internal/ClearOp.java | 2 +- .../java/org/apache/geode/cache/client/internal/ContainsKeyOp.java | 2 +- .../main/java/org/apache/geode/cache/client/internal/DestroyOp.java | 4 ++-- .../org/apache/geode/cache/client/internal/DestroyRegionOp.java | 2 +- .../geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java | 4 ++-- .../apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java | 6 +++--- .../cache/client/internal/ExecuteRegionFunctionSingleHopOp.java | 4 ++-- .../main/java/org/apache/geode/cache/client/internal/GetAllOp.java | 2 +- .../apache/geode/cache/client/internal/GetClientPRMetaDataOp.java | 2 +- .../geode/cache/client/internal/GetClientPartitionAttributesOp.java | 2 +- .../java/org/apache/geode/cache/client/internal/GetEntryOp.java | 2 +- .../src/main/java/org/apache/geode/cache/client/internal/GetOp.java | 2 +- .../java/org/apache/geode/cache/client/internal/InvalidateOp.java | 2 +- .../main/java/org/apache/geode/cache/client/internal/KeySetOp.java | 2 +- .../main/java/org/apache/geode/cache/client/internal/PutAllOp.java | 2 +- .../src/main/java/org/apache/geode/cache/client/internal/PutOp.java | 2 +- .../apache/geode/cache/client/internal/RegisterInterestListOp.java | 2 +- .../org/apache/geode/cache/client/internal/RegisterInterestOp.java | 2 +- .../java/org/apache/geode/cache/client/internal/RemoveAllOp.java | 2 +- .../main/java/org/apache/geode/cache/client/internal/SizeOp.java | 2 +- .../geode/cache/client/internal/UnregisterInterestListOp.java | 2 +- .../apache/geode/cache/client/internal/UnregisterInterestOp.java | 2 +- .../internal/cache/tier/sockets/ClientInterestMessageImpl.java | 2 +- .../geode/internal/cache/tier/sockets/ClientTombstoneMessage.java | 2 +- .../apache/geode/cache/client/internal/GatewaySenderBatchOp.java | 2 +- 25 files changed, 30 insertions(+), 30 deletions(-) diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java index 0c1e059..0f9b940 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ClearOp.java @@ -65,7 +65,7 @@ public class ClearOp { */ public ClearOpImpl(String region, EventID eventId, Object callbackArg) { super(MessageType.CLEAR_REGION, callbackArg != null ? 3 : 2); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addBytesPart(eventId.calcBytes()); if (callbackArg != null) { getMessage().addObjPart(callbackArg); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java index 8159bf9..e722932 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ContainsKeyOp.java @@ -53,7 +53,7 @@ public class ContainsKeyOp { */ public ContainsKeyOpImpl(String region, Object key, MODE mode) { super(MessageType.CONTAINS_KEY, 3); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addStringOrObjPart(key); getMessage().addIntPart(mode.ordinal()); this.region = region; diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java index 6ac95c7..dfcb6b6 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyOp.java @@ -138,7 +138,7 @@ public class DestroyOp { this.prSingleHopEnabled = prSingleHopEnabled; this.callbackArg = callbackArg; this.event = event; - getMessage().addStringPart(region.getFullPath()); + getMessage().addStringPart(region.getFullPath(), true); getMessage().addStringOrObjPart(key); getMessage().addObjPart(expectedOldValue); getMessage().addBytePart(operation.ordinal); @@ -155,7 +155,7 @@ public class DestroyOp { this.key = key; this.event = event; this.callbackArg = callbackArg; - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addStringOrObjPart(key); getMessage().addObjPart(expectedOldValue); getMessage().addBytePart(operation.ordinal); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java index 0cec72c..6d8ed7a 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/DestroyRegionOp.java @@ -65,7 +65,7 @@ public class DestroyRegionOp { */ public DestroyRegionOpImpl(String region, EventID eventId, Object callbackArg) { super(MessageType.DESTROY_REGION, callbackArg != null ? 3 : 2); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addBytesPart(eventId.calcBytes()); if (callbackArg != null) { getMessage().addObjPart(callbackArg); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java index 8550a48..7c90e69 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionNoAckOp.java @@ -119,7 +119,7 @@ public class ExecuteRegionFunctionNoAckOp { Object args = serverRegionExecutor.getArguments(); MemberMappedArgument memberMappedArg = serverRegionExecutor.getMemberMappedArgument(); getMessage().addBytesPart(new byte[] {functionState}); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); if (serverRegionExecutor.isFnSerializationReqd()) { getMessage().addStringOrObjPart(function); } else { @@ -152,7 +152,7 @@ public class ExecuteRegionFunctionNoAckOp { Object args = serverRegionExecutor.getArguments(); MemberMappedArgument memberMappedArg = serverRegionExecutor.getMemberMappedArgument(); getMessage().addBytesPart(new byte[] {functionState}); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addStringOrObjPart(functionId); getMessage().addObjPart(args); getMessage().addObjPart(memberMappedArg); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java index 5f4f41f..94782d0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionOp.java @@ -348,7 +348,7 @@ public class ExecuteRegionFunctionOp { MemberMappedArgument memberMappedArg = serverRegionExecutor.getMemberMappedArgument(); addBytes(functionState); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); if (serverRegionExecutor.isFnSerializationReqd()) { getMessage().addStringOrObjPart(function); } else { @@ -410,7 +410,7 @@ public class ExecuteRegionFunctionOp { Object args = serverRegionExecutor.getArguments(); MemberMappedArgument memberMappedArg = serverRegionExecutor.getMemberMappedArgument(); addBytes(functionState); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addStringOrObjPart(function); getMessage().addObjPart(args); getMessage().addObjPart(memberMappedArg); @@ -467,7 +467,7 @@ public class ExecuteRegionFunctionOp { MemberMappedArgument memberMappedArg = executor.getMemberMappedArgument(); getMessage().clear(); addBytes(this.hasResult); - getMessage().addStringPart(this.regionName); + getMessage().addStringPart(this.regionName, true); if (executor.isFnSerializationReqd()) { getMessage().addStringOrObjPart(function); } else { diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java index e4f4cb6..b33a7fc 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/ExecuteRegionFunctionSingleHopOp.java @@ -225,7 +225,7 @@ public class ExecuteRegionFunctionSingleHopOp { Object args = serverRegionExecutor.getArguments(); MemberMappedArgument memberMappedArg = serverRegionExecutor.getMemberMappedArgument(); addBytes(functionState); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); if (serverRegionExecutor.isFnSerializationReqd()) { getMessage().addStringOrObjPart(function); } else { @@ -270,7 +270,7 @@ public class ExecuteRegionFunctionSingleHopOp { hasResult == (byte) 1 ? true : false, optimizeForWrite); MemberMappedArgument memberMappedArg = serverRegionExecutor.getMemberMappedArgument(); addBytes(functionState); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addStringOrObjPart(functionId); getMessage().addObjPart(args); getMessage().addObjPart(memberMappedArg); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java index 64bfc09..fedf91b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetAllOp.java @@ -147,7 +147,7 @@ public class GetAllOp { super(callback != null ? MessageType.GET_ALL_WITH_CALLBACK : MessageType.GET_ALL_70, 3); this.keyList = keys; this.callback = callback; - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); } @Override diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java index 8fcf566..77f1d63 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPRMetaDataOp.java @@ -63,7 +63,7 @@ public class GetClientPRMetaDataOp { super(MessageType.GET_CLIENT_PR_METADATA, 1); this.regionFullPath = regionFullPath; this.cms = cms; - getMessage().addStringPart(regionFullPath); + getMessage().addStringPart(regionFullPath, true); } @Override diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java index 19d8e46..645458c 100755 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetClientPartitionAttributesOp.java @@ -68,7 +68,7 @@ public class GetClientPartitionAttributesOp { public GetClientPartitionAttributesOpImpl(String regionFullPath) { super(MessageType.GET_CLIENT_PARTITION_ATTRIBUTES, 1); this.regionFullPath = regionFullPath; - getMessage().addStringPart(regionFullPath); + getMessage().addStringPart(regionFullPath, true); } @Override diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java index 75a69e4..c927b8b 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetEntryOp.java @@ -43,7 +43,7 @@ public class GetEntryOp { super(MessageType.GET_ENTRY, 2); this.region = region; this.key = key; - getMessage().addStringPart(region.getFullPath()); + getMessage().addStringPart(region.getFullPath(), true); getMessage().addStringOrObjPart(key); } diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java index cce4c29..ec1f889 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/GetOp.java @@ -126,7 +126,7 @@ public class GetOp { this.key = key; this.callbackArg = callbackArg; this.clientEvent = clientEvent; - getMessage().addStringPart(region.getFullPath()); + getMessage().addStringPart(region.getFullPath(), true); getMessage().addStringOrObjPart(key); if (callbackArg != null) { getMessage().addObjPart(callbackArg); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java index 97d233c..45fb1c0 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/InvalidateOp.java @@ -60,7 +60,7 @@ public class InvalidateOp { super(MessageType.INVALIDATE, event.getCallbackArgument() != null ? 4 : 3); Object callbackArg = event.getCallbackArgument(); this.event = event; - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addStringOrObjPart(event.getKeyInfo().getKey()); getMessage().addBytesPart(event.getEventId().calcBytes()); if (callbackArg != null) { diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java index 65dc961..edcce48 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/KeySetOp.java @@ -54,7 +54,7 @@ public class KeySetOp { */ public KeySetOpImpl(String region) { super(MessageType.KEY_SET, 1); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); } @Override diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java index be2b2be..aac819f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutAllOp.java @@ -266,7 +266,7 @@ public class PutAllOp { (callbackArg != null ? 6 : 5) + (map.size() * 2)); this.prSingleHopEnabled = prSingleHopEnabled; this.region = (LocalRegion) region; - getMessage().addStringPart(region.getFullPath()); + getMessage().addStringPart(region.getFullPath(), true); getMessage().addBytesPart(eventId.calcBytes()); getMessage().addIntPart(skipCallbacks ? 1 : 0); this.map = map; diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java index 2ddbc9d..57b25bd 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/PutOp.java @@ -197,7 +197,7 @@ public class PutOp { this.prSingleHopEnabled = prSingleHopEnabled; this.requireOldValue = requireOldValue; this.expectedOldValue = expectedOldValue; - getMessage().addStringPart(regionName); + getMessage().addStringPart(regionName, true); getMessage().addBytePart(op.ordinal); int flags = 0; if (requireOldValue) diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java index 69acdfb..a335401 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestListOp.java @@ -101,7 +101,7 @@ public class RegisterInterestListOp { public RegisterInterestListOpImpl(String region, List keys, InterestResultPolicy policy, boolean isDurable, boolean receiveUpdatesAsInvalidates, byte regionDataPolicy) { super(region, MessageType.REGISTER_INTEREST_LIST, 6); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addObjPart(policy); { byte durableByte = (byte) (isDurable ? 0x01 : 0x00); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java index e7fe472..10ffa0c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RegisterInterestOp.java @@ -119,7 +119,7 @@ public class RegisterInterestOp { byte regionDataPolicy) { super(MessageType.REGISTER_INTEREST, 7); this.region = region; - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addIntPart(interestType); getMessage().addObjPart(policy); { diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java index 209829b..57a73ba 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/RemoveAllOp.java @@ -246,7 +246,7 @@ public class RemoveAllOp { super(MessageType.REMOVE_ALL, 5 + keys.size()); this.prSingleHopEnabled = prSingleHopEnabled; this.region = (LocalRegion) region; - getMessage().addStringPart(region.getFullPath()); + getMessage().addStringPart(region.getFullPath(), true); getMessage().addBytesPart(eventId.calcBytes()); this.keys = keys; this.callbackArg = callbackArg; diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java index 27e2c01..965f37f 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/SizeOp.java @@ -45,7 +45,7 @@ public class SizeOp { */ public SizeOpImpl(String region) { super(MessageType.SIZE, 1); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); } @Override diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java index 694d3a7..2c2b540 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestListOp.java @@ -53,7 +53,7 @@ public class UnregisterInterestListOp { public UnregisterInterestListOpImpl(String region, List keys, boolean isClosing, boolean keepAlive) { super(MessageType.UNREGISTER_INTEREST_LIST, 4 + keys.size()); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); { byte closingByte = (byte) (isClosing ? 0x01 : 0x00); getMessage().addBytesPart(new byte[] {closingByte}); diff --git a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java index 962858c..10d959c 100644 --- a/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java +++ b/geode-core/src/main/java/org/apache/geode/cache/client/internal/UnregisterInterestOp.java @@ -52,7 +52,7 @@ public class UnregisterInterestOp { public UnregisterInterestOpImpl(String region, Object key, int interestType, boolean isClosing, boolean keepAlive) { super(MessageType.UNREGISTER_INTEREST, 5); - getMessage().addStringPart(region); + getMessage().addStringPart(region, true); getMessage().addIntPart(interestType); getMessage().addStringOrObjPart(key); { diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientInterestMessageImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientInterestMessageImpl.java index b83b2c0..f9fa525 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientInterestMessageImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientInterestMessageImpl.java @@ -162,7 +162,7 @@ public class ClientInterestMessageImpl implements ClientMessage { } // Add the region name - message.addStringPart(this.regionName); + message.addStringPart(this.regionName, true); // Add the key message.addStringOrObjPart(this.keyOfInterest); diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientTombstoneMessage.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientTombstoneMessage.java index 99b4122..7bc761b 100644 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientTombstoneMessage.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/ClientTombstoneMessage.java @@ -94,7 +94,7 @@ public class ClientTombstoneMessage extends ClientUpdateMessageImpl { message = new Message(numParts, clientVersion); // Set message type message.setMessageType(MessageType.TOMBSTONE_OPERATION); - message.addStringPart(this.getRegionName()); + message.addStringPart(this.getRegionName(), true); message.addIntPart(this.op.ordinal()); message.addObjPart(this.removalInformation); message.addObjPart(getEventId()); diff --git a/geode-wan/src/main/java/org/apache/geode/cache/client/internal/GatewaySenderBatchOp.java b/geode-wan/src/main/java/org/apache/geode/cache/client/internal/GatewaySenderBatchOp.java index 18a01de..33f5293 100755 --- a/geode-wan/src/main/java/org/apache/geode/cache/client/internal/GatewaySenderBatchOp.java +++ b/geode-wan/src/main/java/org/apache/geode/cache/client/internal/GatewaySenderBatchOp.java @@ -111,7 +111,7 @@ public class GatewaySenderBatchOp { Object callbackArg = event.getSenderCallbackArgument(); // Add region name - getMessage().addStringPart(regionName); + getMessage().addStringPart(regionName, true); // Add event id getMessage().addObjPart(eventId); // Add key