@Test
    public void testPass() {
        final RabbitmqLogCollectConfig.RabbitmqLogConfig rabbitmqLogConfig = GsonUtils.getInstance().fromJson(pluginData.getConfig(), RabbitmqLogCollectConfig.RabbitmqLogConfig.class);

        shenyuRequestLog.setClientIp("0.0.0.0");
        shenyuRequestLog.setPath("org/apache/shenyu/plugin/logging");
        logs.add(shenyuRequestLog);

        String msg = "";
        RabbitmqLogCollectConfig.INSTANCE.setRabbitmqLogConfig(rabbitmqLogConfig);
        try {
            rabbitmqLogCollectClient.consume(logs);
        } catch (Exception e) {
            msg = "false";
        }

        assertEquals(msg, "");
        rabbitmqLogCollectClient.close();
    }
Integration Test for logging-rabbitmq plugin.
shenyu-integrated-test/shenyu-integrated-test-http/src/test/java/org/apache/shenyu/integrated/test/http/combination/LoggingRabbitMqPluginTest.java