This is an automated email from the ASF dual-hosted git repository.

wy471x pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shenyu.git


The following commit(s) were added to refs/heads/master by this push:
     new 08e87ee7a5 [ISSUE #7393] Align DataChangedEventDispatcherTest 
verifications with the 3-arg onPluginChanged overload (#7395)
08e87ee7a5 is described below

commit 08e87ee7a5a80e70edd3a81dcd5ddf2207fef497
Author: eye-gu <[email protected]>
AuthorDate: Thu Oct 1 19:49:19 2026 +0800

    [ISSUE #7393] Align DataChangedEventDispatcherTest verifications with the 
3-arg onPluginChanged overload (#7395)
    
    * Fixes #7393: align DataChangedEventDispatcherTest with the 3-arg 
onPluginChanged overload
    
    * Also align the never() verifications in transaction tests with the 3-arg 
onPluginChanged overload
---
 .../admin/listener/DataChangedEventDispatcherTest.java | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 deletions(-)

diff --git 
a/shenyu-admin/src/test/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcherTest.java
 
b/shenyu-admin/src/test/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcherTest.java
index 70a5e9cd32..901a213c68 100644
--- 
a/shenyu-admin/src/test/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcherTest.java
+++ 
b/shenyu-admin/src/test/java/org/apache/shenyu/admin/listener/DataChangedEventDispatcherTest.java
@@ -340,9 +340,9 @@ public final class DataChangedEventDispatcherTest {
         DataChangedEvent dataChangedEvent = new 
DataChangedEvent(ConfigGroupEnum.PLUGIN, null, new ArrayList<>());
         dataChangedEventDispatcher.onApplicationEvent(dataChangedEvent);
         verify(clusterDataChangedEventForwarder, 
times(1)).forward(dataChangedEvent);
-        verify(httpLongPollingDataChangedListener, 
times(1)).onPluginChanged(anyList(), any());
-        verify(nacosDataChangedListener, never()).onPluginChanged(anyList(), 
any());
-        verify(websocketDataChangedListener, 
never()).onPluginChanged(anyList(), any());
+        verify(httpLongPollingDataChangedListener, 
times(1)).onPluginChanged(anyList(), any(), any());
+        verify(nacosDataChangedListener, never()).onPluginChanged(anyList(), 
any(), any());
+        verify(websocketDataChangedListener, 
never()).onPluginChanged(anyList(), any(), any());
     }
 
     /**
@@ -356,8 +356,8 @@ public final class DataChangedEventDispatcherTest {
         DataChangedEvent dataChangedEvent = new 
DataChangedEvent(ConfigGroupEnum.PLUGIN, null, new ArrayList<>());
         dataChangedEventDispatcher.onApplicationEvent(dataChangedEvent);
         verify(clusterDataChangedEventForwarder, 
times(1)).forward(dataChangedEvent);
-        verify(httpLongPollingDataChangedListener, 
times(1)).onPluginChanged(anyList(), any());
-        verify(websocketDataChangedListener, 
never()).onPluginChanged(anyList(), any());
+        verify(httpLongPollingDataChangedListener, 
times(1)).onPluginChanged(anyList(), any(), any());
+        verify(websocketDataChangedListener, 
never()).onPluginChanged(anyList(), any(), any());
     }
 
     /**
@@ -369,8 +369,8 @@ public final class DataChangedEventDispatcherTest {
         DataChangedEvent dataChangedEvent = new 
DataChangedEvent(ConfigGroupEnum.PLUGIN, null, new ArrayList<>());
         dataChangedEventDispatcher.onApplicationEvent(dataChangedEvent);
         verify(clusterDataChangedEventForwarder, 
never()).forward(any(DataChangedEvent.class));
-        verify(websocketDataChangedListener, 
times(1)).onPluginChanged(anyList(), any());
-        verify(httpLongPollingDataChangedListener, 
times(1)).onPluginChanged(anyList(), any());
+        verify(websocketDataChangedListener, 
times(1)).onPluginChanged(anyList(), any(), any());
+        verify(httpLongPollingDataChangedListener, 
times(1)).onPluginChanged(anyList(), any(), any());
     }
 
     @Test
@@ -383,7 +383,7 @@ public final class DataChangedEventDispatcherTest {
             DataChangedEvent event = new 
DataChangedEvent(ConfigGroupEnum.PLUGIN, null, new ArrayList<>());
             dataChangedEventDispatcher.onApplicationEvent(event);
             verify(clusterDataChangedEventForwarder, never()).forward(any());
-            verify(httpLongPollingDataChangedListener, 
never()).onPluginChanged(anyList(), any());
+            verify(httpLongPollingDataChangedListener, 
never()).onPluginChanged(anyList(), any(), any());
             
org.springframework.transaction.support.TransactionSynchronizationManager.getSynchronizations()
                     
.forEach(org.springframework.transaction.support.TransactionSynchronization::afterCommit);
             verify(clusterDataChangedEventForwarder).forward(event);
@@ -402,7 +402,7 @@ public final class DataChangedEventDispatcherTest {
             
org.springframework.transaction.support.TransactionSynchronizationManager.getSynchronizations()
                     .forEach(sync -> 
sync.afterCompletion(org.springframework.transaction.support.TransactionSynchronization.STATUS_ROLLED_BACK));
             verify(clusterDataChangedEventForwarder, never()).forward(any());
-            verify(httpLongPollingDataChangedListener, 
never()).onPluginChanged(anyList(), any());
+            verify(httpLongPollingDataChangedListener, 
never()).onPluginChanged(anyList(), any(), any());
         } finally {
             
org.springframework.transaction.support.TransactionSynchronizationManager.clear();
         }

Reply via email to