This is an automated email from the ASF dual-hosted git repository.
liuhongyu 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 1b245d325d feat: extracted public data entities (#6084)
1b245d325d is described below
commit 1b245d325d3edb20bad33c3ae901eb46947b7183
Author: shown <[email protected]>
AuthorDate: Tue Aug 5 09:00:43 2025 +0800
feat: extracted public data entities (#6084)
Signed-off-by: shown.Ji <[email protected]>
---
.../{event/DataEvent.java => common/Data.java} | 9 +++------
.../disruptor/consumer/QueueConsumerExecutor.java | 22 +++-------------------
.../apache/shenyu/disruptor/event/DataEvent.java | 22 +++-------------------
3 files changed, 9 insertions(+), 44 deletions(-)
diff --git
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/common/Data.java
similarity index 89%
copy from
shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
copy to
shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/common/Data.java
index 36dceee00a..1dec5bbce8 100644
---
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
+++
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/common/Data.java
@@ -15,13 +15,9 @@
* limitations under the License.
*/
-package org.apache.shenyu.disruptor.event;
+package org.apache.shenyu.disruptor.common;
-/**
- * DataEvent.
- * disruptor data carrier .
- */
-public class DataEvent<T> {
+public class Data<T> {
private T data;
@@ -40,4 +36,5 @@ public class DataEvent<T> {
public void setData(final T data) {
this.data = data;
}
+
}
diff --git
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumerExecutor.java
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumerExecutor.java
index ecbb88f1eb..24e8dcfeeb 100644
---
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumerExecutor.java
+++
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/consumer/QueueConsumerExecutor.java
@@ -17,28 +17,12 @@
package org.apache.shenyu.disruptor.consumer;
+import org.apache.shenyu.disruptor.common.Data;
+
/**
* The type Queue consumer executor.
*
* @param <T> the type parameter
*/
-public abstract class QueueConsumerExecutor<T> implements Runnable {
-
- private T data;
-
- /**
- * get data.
- * @return data
- */
- public T getData() {
- return data;
- }
-
- /**
- * set data.
- * @param data data
- */
- public void setData(final T data) {
- this.data = data;
- }
+public abstract class QueueConsumerExecutor<T> extends Data<T> implements
Runnable {
}
diff --git
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
index 36dceee00a..83f7e7eafa 100644
---
a/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
+++
b/shenyu-disruptor/src/main/java/org/apache/shenyu/disruptor/event/DataEvent.java
@@ -17,27 +17,11 @@
package org.apache.shenyu.disruptor.event;
+import org.apache.shenyu.disruptor.common.Data;
+
/**
* DataEvent.
* disruptor data carrier .
*/
-public class DataEvent<T> {
-
- private T data;
-
- /**
- * get data.
- * @return data
- */
- public T getData() {
- return data;
- }
-
- /**
- * set data.
- * @param data data
- */
- public void setData(final T data) {
- this.data = data;
- }
+public class DataEvent<T> extends Data<T> {
}