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 <yuluo08290...@gmail.com>
AuthorDate: Tue Aug 5 09:00:43 2025 +0800

    feat: extracted public data entities (#6084)
    
    Signed-off-by: shown.Ji <yuluo08290...@gmail.com>
---
 .../{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> {
 }

Reply via email to