[INLONG-9461][Manager] Failure of GroupTaskListenerFactoryTest

vernedeng · Dec 12, 2023 · bfe12fe · bfe12fe
1 parent 7426680
commit bfe12fe
Showing 1 changed file with 0 additions and 9 deletions.
diff --git a/...rc/test/java/org/apache/inlong/manager/service/workflow/GroupTaskListenerFactoryTest.java b/...rc/test/java/org/apache/inlong/manager/service/workflow/GroupTaskListenerFactoryTest.java
@@ -44,22 +44,13 @@ public class GroupTaskListenerFactoryTest extends ServiceBaseTest {
     public void testGetQueueOperateListener() {
         GroupResourceProcessForm processForm = new GroupResourceProcessForm();
         InlongPulsarInfo pulsarInfo = new InlongPulsarInfo();
-        // check pulsar listener
         pulsarInfo.setMqType(MQType.PULSAR);
         processForm.setGroupInfo(pulsarInfo);
         WorkflowContext context = new WorkflowContext();
         context.setProcessForm(processForm);
         List<QueueOperateListener> queueOperateListeners = groupTaskListenerFactory.getQueueResourceListener(context);
-        if (queueOperateListeners.size() == 0) {
-            return;
-        }
         Assertions.assertEquals(1, queueOperateListeners.size());
 
-        // check tubemq listener
-        InlongTubeMQInfo tubeInfo = new InlongTubeMQInfo();
-        tubeInfo.setMqType(MQType.TUBEMQ);
-        queueOperateListeners = groupTaskListenerFactory.getQueueResourceListener(context);
-        Assertions.assertEquals(2, queueOperateListeners.size());
     }
 
 }