[#noissue] Fix spring-amqp-rabbit it

BillionaireDY · Dec 29, 2022 · ead7a02 · ead7a02
1 parent 42c8ebe
commit ead7a02
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/.../java/com/navercorp/pinpoint/plugin/rabbitmq/spring/SpringAmqpRabbit_2_1_x_to_2_x_IT.java b/.../java/com/navercorp/pinpoint/plugin/rabbitmq/spring/SpringAmqpRabbit_2_1_x_to_2_x_IT.java
@@ -135,8 +135,8 @@ public void testPush() throws Exception {
         Method abstractMessageListenerContainerExecuteListener = getExecuteListenerMethod(abstractMessageListenerContainerClass);
 
         ExpectedTrace abstractMessageListenerContainerExecuteListenerTrace = Expectations.event(
-                    ServiceType.INTERNAL_METHOD.getName(),
-                    abstractMessageListenerContainerExecuteListener);
+                ServiceType.INTERNAL_METHOD.getName(),
+                abstractMessageListenerContainerExecuteListener);
 
         Class<?> propagationMarkerClass = PropagationMarker.class;
         Method propagationMarkerMark = propagationMarkerClass.getDeclaredMethod("mark");
@@ -169,13 +169,11 @@ public void testPush() throws Exception {
 
     private Method getExecuteListenerMethod(Class<?> abstractMessageListenerContainerClass) throws NoSuchMethodException {
         Method abstractMessageListenerContainerExecuteListener = getExecuteListenerMethod0(abstractMessageListenerContainerClass);
-
-        if (abstractMessageListenerContainerExecuteListener.getParameterCount() != 2) {
-            final Class<?>[] parameterTypes = abstractMessageListenerContainerExecuteListener.getParameterTypes();
+        final Class<?>[] parameterTypes = abstractMessageListenerContainerExecuteListener.getParameterTypes();
+        if (parameterTypes.length >= 2) {
             if (!parameterTypes[0].equals(Channel.class)) {
                 throw new NoSuchMethodException("executeListener");
             }
-
             if (parameterTypes[1].equals(Message.class) || parameterTypes[1].equals(Object.class)) {
                 return abstractMessageListenerContainerExecuteListener;
             }