更新rabbitmq配置

seatunnel-datasource/seatunnel-datasource-plugins/datasource-rabbitmq/src/main/java/org.apache.seatunnel.datasource.plugin.rabbitmq/RabbitAConfiguration.java

@@ -50,10 +50,6 @@ public class RabbitAConfiguration {
             throw new IllegalArgumentException(
                     "redis datasource queue_name is null, please check your config");
         }
-        if (!redisOption.containsKey(RabbitmqOptionRule.SCHEMA.key())) {
-            throw new IllegalArgumentException(
-                    "redis datasource schema is null, please check your config");
-        }
         if (!redisOption.containsKey(RabbitmqOptionRule.URL.key())) {
             throw new IllegalArgumentException(
                     "redis datasource url is null, please check your config");
@@ -65,7 +61,6 @@ public class RabbitAConfiguration {
         redisConfiguration.setPassword(redisOption.get(RabbitmqOptionRule.PASSWORD.key()));
         redisConfiguration.setVirtualHost(redisOption.get(RabbitmqOptionRule.VIRTUAL_HOST.key()));
         redisConfiguration.setQueueName(redisOption.get(RabbitmqOptionRule.QUEUE_NAME.key()));
-        redisConfiguration.setSchema(redisOption.get(RabbitmqOptionRule.SCHEMA.key()));
         redisConfiguration.setUri(redisOption.get(RabbitmqOptionRule.URL.key()));
 
         return redisConfiguration;

seatunnel-datasource/seatunnel-datasource-plugins/datasource-rabbitmq/src/main/java/org.apache.seatunnel.datasource.plugin.rabbitmq/RabbitConfiguration.java

@@ -18,7 +18,6 @@ public class RabbitConfiguration {
     private long deliveryTimeout;
     private String queueName;
     private String routingKey;
-    private String schema;
 
     public RabbitConfiguration() {}
 
@@ -58,57 +57,29 @@ public class RabbitConfiguration {
         this.deliveryTimeout = deliveryTimeout;
         this.queueName = queueName;
         this.routingKey = routingKey;
-        this.schema = schema;
     }
 
     @Override
     public String toString() {
-        return "RabbitConfiguration{"
-                + "host='"
-                + host
-                + '\''
-                + ", port="
-                + port
-                + ", virtualHost='"
-                + virtualHost
-                + '\''
-                + ", username='"
-                + username
-                + '\''
-                + ", password='"
-                + password
-                + '\''
-                + ", uri='"
-                + uri
-                + '\''
-                + ", networkRecoveryInterval="
-                + networkRecoveryInterval
-                + ", automaticRecovery="
-                + automaticRecovery
-                + ", topologyRecovery="
-                + topologyRecovery
-                + ", connectionTimeout="
-                + connectionTimeout
-                + ", requestedChannelMax="
-                + requestedChannelMax
-                + ", requestedFrameMax="
-                + requestedFrameMax
-                + ", requestedHeartbeat="
-                + requestedHeartbeat
-                + ", prefetchCount="
-                + prefetchCount
-                + ", deliveryTimeout="
-                + deliveryTimeout
-                + ", queueName='"
-                + queueName
-                + '\''
-                + ", routingKey='"
-                + routingKey
-                + '\''
-                + ", schema='"
-                + schema
-                + '\''
-                + '}';
+        return "RabbitConfiguration{" +
+                "host='" + host + '\'' +
+                ", port=" + port +
+                ", virtualHost='" + virtualHost + '\'' +
+                ", username='" + username + '\'' +
+                ", password='" + password + '\'' +
+                ", uri='" + uri + '\'' +
+                ", networkRecoveryInterval=" + networkRecoveryInterval +
+                ", automaticRecovery=" + automaticRecovery +
+                ", topologyRecovery=" + topologyRecovery +
+                ", connectionTimeout=" + connectionTimeout +
+                ", requestedChannelMax=" + requestedChannelMax +
+                ", requestedFrameMax=" + requestedFrameMax +
+                ", requestedHeartbeat=" + requestedHeartbeat +
+                ", prefetchCount=" + prefetchCount +
+                ", deliveryTimeout=" + deliveryTimeout +
+                ", queueName='" + queueName + '\'' +
+                ", routingKey='" + routingKey + '\'' +
+                '}';
     }
 
     public String getHost() {
@@ -247,11 +218,4 @@ public class RabbitConfiguration {
         this.routingKey = routingKey;
     }
 
-    public String getSchema() {
-        return schema;
-    }
-
-    public void setSchema(String schema) {
-        this.schema = schema;
-    }
 }