davebarnes97 commented on a change in pull request #5968:
URL: https://github.com/apache/geode/pull/5968#discussion_r568879819
##########
File path:
geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySenderEventProcessor.java
##########
@@ -173,14 +174,25 @@ public int getTotalQueueSize() {
protected abstract void initializeMessageQueue(String id, boolean
cleanQueues);
- public void enqueueEvent(EnumListenerEvent operation, EntryEvent event,
+ public boolean enqueueEvent(EnumListenerEvent operation, EntryEvent event,
Object substituteValue) throws IOException, CacheException {
- enqueueEvent(operation, event, substituteValue, false);
+ return enqueueEvent(operation, event, substituteValue, false, null);
}
- public abstract void enqueueEvent(EnumListenerEvent operation, EntryEvent
event,
- Object substituteValue, boolean isLastEventInTransaction) throws
IOException, CacheException;
-
+ /**
+ *
+ * @param operation The operation
+ * @param event The event to be put in the queue
+ * @param substituteValue The substitute value
+ * @param isLastEventInTransaction True if this event is the last one in the
+ * transaction it belongs to
+ * @param condition If not null, the event will be enqueued only if the
predicate
+ * matches at least with one elements in the queue
Review comment:
"matches at least with one elements" -> "matches at least one element"
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
