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> { }