This is an automated email from the ASF dual-hosted git repository.
yunlong 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 f02b31df67 [type:fix] fix bug when refresh config (#5280)
f02b31df67 is described below
commit f02b31df67983f133c520f146c608795bf7bd986
Author: 0xmkzt <[email protected]>
AuthorDate: Tue Nov 7 16:32:37 2023 +0800
[type:fix] fix bug when refresh config (#5280)
---
.../logging/elasticsearch/config/ElasticSearchLogCollectConfig.java | 4 ++--
.../shenyu/plugin/huawei/lts/config/HuaweiLogCollectConfig.java | 2 +-
.../shenyu/plugin/logging/kafka/config/KafkaLogCollectConfig.java | 4 ++--
.../shenyu/plugin/logging/pulsar/config/PulsarLogCollectConfig.java | 4 ++--
.../plugin/logging/rocketmq/config/RocketMQLogCollectConfig.java | 4 ++--
5 files changed, 9 insertions(+), 9 deletions(-)
diff --git
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-elasticsearch/src/main/java/org/apache/shenyu/plugin/logging/elasticsearch/config/ElasticSearchLogCollectConfig.java
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-elasticsearch/src/main/java/org/apache/shenyu/plugin/logging/elasticsearch/config/ElasticSearchLogCollectConfig.java
index fd6160d815..7997476f60 100644
---
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-elasticsearch/src/main/java/org/apache/shenyu/plugin/logging/elasticsearch/config/ElasticSearchLogCollectConfig.java
+++
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-elasticsearch/src/main/java/org/apache/shenyu/plugin/logging/elasticsearch/config/ElasticSearchLogCollectConfig.java
@@ -207,8 +207,8 @@ public class ElasticSearchLogCollectConfig {
&& Objects.equals(getPort(), that.getPort())
&& Objects.equals(getSampleRate(), that.getSampleRate())
&& Objects.equals(getBufferQueueSize(),
that.getBufferQueueSize())
- && Objects.equals(getMaxResponseBody(),
that.getMaxRequestBody())
- && Objects.equals(getMaxRequestBody(),
that.getMaxResponseBody())
+ && Objects.equals(getMaxRequestBody(),
that.getMaxRequestBody())
+ && Objects.equals(getMaxResponseBody(),
that.getMaxResponseBody())
&& Objects.equals(getIndexName(), that.getIndexName());
}
diff --git
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/config/HuaweiLogCollectConfig.java
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/config/HuaweiLogCollectConfig.java
index 9d0d831caa..f59cdabe9d 100644
---
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/config/HuaweiLogCollectConfig.java
+++
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-huawei-lts/src/main/java/org/apache/shenyu/plugin/huawei/lts/config/HuaweiLogCollectConfig.java
@@ -459,7 +459,7 @@ public class HuaweiLogCollectConfig {
&& Objects.equals(getLogStreamId(), that.getLogStreamId())
&& Objects.equals(getAccessKeyId(), that.getAccessKeyId())
&& Objects.equals(getAccessKeySecret(),
that.getAccessKeySecret())
- && Objects.equals(getRegionName(),
that.getTotalSizeInBytes())
+ && Objects.equals(getRegionName(), that.getRegionName())
&& Objects.equals(getTotalSizeInBytes(),
that.getTotalSizeInBytes())
&& Objects.equals(getMaxBlockMs(), that.getMaxBlockMs())
&& Objects.equals(getIoThreadCount(),
that.getIoThreadCount())
diff --git
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/main/java/org/apache/shenyu/plugin/logging/kafka/config/KafkaLogCollectConfig.java
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/main/java/org/apache/shenyu/plugin/logging/kafka/config/KafkaLogCollectConfig.java
index 620c96d144..e055cf1ac6 100644
---
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/main/java/org/apache/shenyu/plugin/logging/kafka/config/KafkaLogCollectConfig.java
+++
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-kafka/src/main/java/org/apache/shenyu/plugin/logging/kafka/config/KafkaLogCollectConfig.java
@@ -234,8 +234,8 @@ public class KafkaLogCollectConfig {
&& Objects.equals(getProducerGroup(),
that.getProducerGroup())
&& Objects.equals(getSampleRate(), that.getSampleRate())
&& Objects.equals(getBufferQueueSize(),
that.getBufferQueueSize())
- && Objects.equals(getMaxResponseBody(),
that.getMaxRequestBody())
- && Objects.equals(getMaxRequestBody(),
that.getMaxResponseBody());
+ && Objects.equals(getMaxRequestBody(),
that.getMaxRequestBody())
+ && Objects.equals(getMaxResponseBody(),
that.getMaxResponseBody());
}
@Override
diff --git
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-pulsar/src/main/java/org/apache/shenyu/plugin/logging/pulsar/config/PulsarLogCollectConfig.java
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-pulsar/src/main/java/org/apache/shenyu/plugin/logging/pulsar/config/PulsarLogCollectConfig.java
index 65dcfb51d7..c11a35ff54 100644
---
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-pulsar/src/main/java/org/apache/shenyu/plugin/logging/pulsar/config/PulsarLogCollectConfig.java
+++
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-pulsar/src/main/java/org/apache/shenyu/plugin/logging/pulsar/config/PulsarLogCollectConfig.java
@@ -123,8 +123,8 @@ public class PulsarLogCollectConfig {
&& Objects.equals(getServiceUrl(), that.getServiceUrl())
&& Objects.equals(getSampleRate(), that.getSampleRate())
&& Objects.equals(getBufferQueueSize(),
that.getBufferQueueSize())
- && Objects.equals(getMaxResponseBody(),
that.getMaxRequestBody())
- && Objects.equals(getMaxRequestBody(),
that.getMaxResponseBody());
+ && Objects.equals(getMaxRequestBody(),
that.getMaxRequestBody())
+ && Objects.equals(getMaxResponseBody(),
that.getMaxResponseBody());
}
@Override
diff --git
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-rocketmq/src/main/java/org/apache/shenyu/plugin/logging/rocketmq/config/RocketMQLogCollectConfig.java
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-rocketmq/src/main/java/org/apache/shenyu/plugin/logging/rocketmq/config/RocketMQLogCollectConfig.java
index b241443eb1..a9c866b35a 100644
---
a/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-rocketmq/src/main/java/org/apache/shenyu/plugin/logging/rocketmq/config/RocketMQLogCollectConfig.java
+++
b/shenyu-plugin/shenyu-plugin-logging/shenyu-plugin-logging-rocketmq/src/main/java/org/apache/shenyu/plugin/logging/rocketmq/config/RocketMQLogCollectConfig.java
@@ -196,8 +196,8 @@ public class RocketMQLogCollectConfig {
&& Objects.equals(getSecretKey(), that.getSecretKey())
&& Objects.equals(getSampleRate(), that.getSampleRate())
&& Objects.equals(getBufferQueueSize(),
that.getBufferQueueSize())
- && Objects.equals(getMaxResponseBody(),
that.getMaxRequestBody())
- && Objects.equals(getMaxRequestBody(),
that.getMaxResponseBody());
+ && Objects.equals(getMaxRequestBody(),
that.getMaxRequestBody())
+ && Objects.equals(getMaxResponseBody(),
that.getMaxResponseBody());
}
@Override
