diff --git a/geode-core/src/integrationTest/java/org/apache/geode/alerting/internal/api/AlertingServiceWithClusterIntegrationTest.java b/geode-core/src/integrationTest/java/org/apache/geode/alerting/internal/api/AlertingServiceWithClusterIntegrationTest.java
index 65199dd1ce00..258654fdfe43 100644
--- a/geode-core/src/integrationTest/java/org/apache/geode/alerting/internal/api/AlertingServiceWithClusterIntegrationTest.java
+++ b/geode-core/src/integrationTest/java/org/apache/geode/alerting/internal/api/AlertingServiceWithClusterIntegrationTest.java
@@ -26,7 +26,9 @@
 import static org.apache.geode.test.awaitility.GeodeAwaitility.getTimeout;
 import static org.apache.geode.test.dunit.NetworkUtils.getServerHostName;
 import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.ArgumentMatchers.eq;
 import static org.mockito.ArgumentMatchers.isA;
+import static org.mockito.Mockito.doAnswer;
 import static org.mockito.Mockito.spy;
 import static org.mockito.Mockito.timeout;
 import static org.mockito.Mockito.verify;
@@ -120,6 +122,23 @@ public void alertMessageIsReceivedForListenerLevelWarning() {
     verify(messageListener, timeout(TIMEOUT)).received(isA(AlertListenerMessage.class));
   }
 
+  @Test
+  public void alertMessageProcessingDoesNotTriggerAdditionalAlertMessage() {
+    alertingService.addAlertListener(member, WARNING);
+    logger = spy(logger);
+
+    String recursiveAlert = "Recursive Alert";
+    doAnswer(invocation -> {
+      logger.warn(recursiveAlert);
+      return null;
+    }).when(messageListener).received(isA(AlertListenerMessage.class));
+
+    logger.warn(alertMessage);
+
+    verify(messageListener, timeout(TIMEOUT).times(1)).received(isA(AlertListenerMessage.class));
+    verify(logger, timeout(TIMEOUT).times(1)).warn(eq(recursiveAlert));
+  }
+
   @Test
   public void alertMessageIsReceivedForListenerLevelError() {
     alertingService.addAlertListener(member, ERROR);
diff --git a/geode-core/src/main/java/org/apache/geode/alerting/internal/ClusterAlertMessaging.java b/geode-core/src/main/java/org/apache/geode/alerting/internal/ClusterAlertMessaging.java
index 60df6868ae4b..f5fcba5fe799 100644
--- a/geode-core/src/main/java/org/apache/geode/alerting/internal/ClusterAlertMessaging.java
+++ b/geode-core/src/main/java/org/apache/geode/alerting/internal/ClusterAlertMessaging.java
@@ -22,6 +22,7 @@
 import org.apache.logging.log4j.Logger;
 
 import org.apache.geode.alerting.internal.spi.AlertLevel;
+import org.apache.geode.alerting.internal.spi.AlertingAction;
 import org.apache.geode.annotations.VisibleForTesting;
 import org.apache.geode.distributed.DistributedMember;
 import org.apache.geode.distributed.internal.ClusterDistributionManager;
@@ -66,7 +67,7 @@ public void sendAlert(final DistributedMember member,
       final long threadId,
       final String formattedMessage,
       final String stackTrace) {
-    executor.submit(() -> {
+    executor.submit(() -> AlertingAction.execute(() -> {
       try {
         String connectionName = system.getConfig().getName();
 
@@ -77,14 +78,16 @@ public void sendAlert(final DistributedMember member,
         if (member.equals(system.getDistributedMember())) {
           // process in local member
           logger.debug("Processing local alert message: {}, {}, {}, {}, {}, {}, [{}], [{}].",
-              member, alertLevel, timestamp, connectionName, threadName, threadId, formattedMessage,
+              member, alertLevel, timestamp, connectionName, threadName, threadId,
+              formattedMessage,
               stackTrace);
           processAlertListenerMessage(message);
 
         } else {
           // send to remote member
           logger.debug("Sending remote alert message: {}, {}, {}, {}, {}, {}, [{}], [{}].",
-              member, alertLevel, timestamp, connectionName, threadName, threadId, formattedMessage,
+              member, alertLevel, timestamp, connectionName, threadName, threadId,
+              formattedMessage,
               stackTrace);
           dm.putOutgoing(message);
         }
@@ -92,7 +95,7 @@ public void sendAlert(final DistributedMember member,
         // OK. We can't send to this recipient because we're in the middle of
         // trying to connect to it.
       }
-    });
+    }));
   }
 
   public void close() {
diff --git a/geode-core/src/test/java/org/apache/geode/alerting/internal/ClusterAlertMessagingTest.java b/geode-core/src/test/java/org/apache/geode/alerting/internal/ClusterAlertMessagingTest.java
index 3242ae7341d8..5dd5687fcc82 100644
--- a/geode-core/src/test/java/org/apache/geode/alerting/internal/ClusterAlertMessagingTest.java
+++ b/geode-core/src/test/java/org/apache/geode/alerting/internal/ClusterAlertMessagingTest.java
@@ -41,6 +41,7 @@
 import org.mockito.stubbing.Answer;
 
 import org.apache.geode.alerting.internal.spi.AlertLevel;
+import org.apache.geode.alerting.internal.spi.AlertingAction;
 import org.apache.geode.distributed.DistributedMember;
 import org.apache.geode.distributed.internal.ClusterDistributionManager;
 import org.apache.geode.distributed.internal.DistributionConfig;
@@ -111,6 +112,23 @@ public void sendAlertUsesExecutorService() {
     verify(executor).submit(any(Runnable.class));
   }
 
+  @Test
+  public void sendAlertUsesAlertingAction() {
+    ExecutorService executor = currentThreadExecutorService();
+    ClusterDistributionManager distributionManager = mock(ClusterDistributionManager.class);
+    ClusterAlertMessaging clusterAlertMessaging =
+        spyClusterAlertMessaging(distributionManager, executor);
+    when(distributionManager.putOutgoing(any())).thenAnswer(invocation -> {
+      assertThat(AlertingAction.isThreadAlerting()).isTrue();
+      return null;
+    });
+
+    clusterAlertMessaging.sendAlert(remoteMember, AlertLevel.WARNING, Instant.now(), "threadName",
+        Thread.currentThread().getId(), "formattedMessage", "stackTrace");
+
+    verify(distributionManager).putOutgoing(any());
+  }
+
   @Test
   public void processAlertListenerMessage_requires_ClusterDistributionManager() {
     ClusterAlertMessaging clusterAlertMessaging = spy(new ClusterAlertMessaging(system,
diff --git a/geode-log4j/src/main/java/org/apache/geode/alerting/log4j/internal/impl/AlertAppender.java b/geode-log4j/src/main/java/org/apache/geode/alerting/log4j/internal/impl/AlertAppender.java
index 48626b4b7bf5..6c1fa79da4bc 100644
--- a/geode-log4j/src/main/java/org/apache/geode/alerting/log4j/internal/impl/AlertAppender.java
+++ b/geode-log4j/src/main/java/org/apache/geode/alerting/log4j/internal/impl/AlertAppender.java
@@ -149,7 +149,7 @@ public void append(final LogEvent event) {
       LOGGER.trace("Skipping append of {} because {} is alerting.", event, Thread.currentThread());
       return;
     }
-    AlertingAction.execute(() -> doAppend(event));
+    doAppend(event);
   }
 
   private void doAppend(final LogEvent event) {