DonalEvans commented on a change in pull request #5381:
URL: https://github.com/apache/geode/pull/5381#discussion_r456569959
##########
File path:
geode-core/src/main/java/org/apache/geode/internal/cache/wan/AbstractGatewaySender.java
##########
@@ -1034,9 +1036,17 @@ public void distribute(EnumListenerEvent operation,
EntryEventImpl event,
// If this gateway is not running, return
if (!isRunning()) {
if (this.isPrimary()) {
- tmpDroppedEvents.add(clonedEvent);
- if (isDebugEnabled) {
- logger.debug("add to tmpDroppedEvents for evnet {}", clonedEvent);
+ if (this.startTime < 0
+ && System.currentTimeMillis() + this.startTime <
maxWaitTimeForSenderToStart) {
+ tmpDroppedEvents.add(clonedEvent);
+ if (isDebugEnabled) {
+ logger.debug("add to tmpDroppedEvents for evnet {}",
clonedEvent);
+ }
+ } else {
+ if (isDebugEnabled) {
+ logger.debug("The sender is stopped. Not to add to
tmpDroppedEvents for event {}",
Review comment:
This might be worded better as "Gateway sender is stopped. Event was not
added to tmpDroppedEvents: {}"
----------------------------------------------------------------
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]
