diff --git a/framework/src/Volo.Abp.EventBus.RabbitMQ/Volo/Abp/EventBus/RabbitMq/RabbitMqDistributedEventBus.cs b/framework/src/Volo.Abp.EventBus.RabbitMQ/Volo/Abp/EventBus/RabbitMq/RabbitMqDistributedEventBus.cs
index a9cfb4dc23..a9d6a42207 100644
--- a/framework/src/Volo.Abp.EventBus.RabbitMQ/Volo/Abp/EventBus/RabbitMq/RabbitMqDistributedEventBus.cs
+++ b/framework/src/Volo.Abp.EventBus.RabbitMQ/Volo/Abp/EventBus/RabbitMq/RabbitMqDistributedEventBus.cs
@@ -238,7 +238,7 @@ public class RabbitMqDistributedEventBus : DistributedEventBusBase, ISingletonDe
             foreach (var outgoingEvent in outgoingEventArray)
             {
                 pendingConfirms.TryAdd(channel.NextPublishSeqNo, outgoingEvent.Id);
-                await PublishInternalAsync(channel, outgoingEvent.EventName, outgoingEvent.EventData, null,
+                await PublishAsync(channel, outgoingEvent.EventName, outgoingEvent.EventData, null,
                     eventId: outgoingEvent.Id);
             }
 
@@ -293,11 +293,11 @@ public class RabbitMqDistributedEventBus : DistributedEventBusBase, ISingletonDe
     {
         using (var channel = ConnectionPool.Get(AbpRabbitMqEventBusOptions.ConnectionName).CreateModel())
         {
-            return PublishInternalAsync(channel, eventName, body, properties, headersArguments, eventId);
+            return PublishAsync(channel, eventName, body, properties, headersArguments, eventId);
         }
     }
 
-    protected virtual Task PublishInternalAsync(
+    protected virtual Task PublishAsync(
         IModel channel,
         string eventName,
         byte[] body,