You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/04/22 02:31:00 UTC
[incubator-eventmesh] branch master updated: [ISSUE #838] Removed redundant code (#842)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 3df63b53 [ISSUE #838] Removed redundant code (#842)
3df63b53 is described below
commit 3df63b53e6d17e04cb01a26b881d7422510ed9b1
Author: RSTdefg <34...@users.noreply.github.com>
AuthorDate: Thu Apr 21 22:30:55 2022 -0400
[ISSUE #838] Removed redundant code (#842)
---
.../http/processor/ReplyMessageProcessor.java | 45 ----------------------
.../http/processor/SendAsyncMessageProcessor.java | 21 ----------
.../tcp/client/group/ClientGroupWrapper.java | 6 ---
.../core/protocol/tcp/client/session/Session.java | 6 ---
.../tcp/client/session/push/ClientAckContext.java | 2 -
.../client/session/push/DownStreamMsgContext.java | 4 --
.../tcp/client/session/send/SessionSender.java | 22 -----------
.../core/protocol/tcp/client/task/HelloTask.java | 8 ----
.../core/protocol/tcp/client/task/ListenTask.java | 4 --
.../eventmesh/runtime/domain/NonStandardKeys.java | 34 ----------------
.../runtime/domain/RocketMQConstants.java | 31 ---------------
11 files changed, 183 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java
index a65f7f7e..aadb17e4 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/ReplyMessageProcessor.java
@@ -205,33 +205,6 @@ public class ReplyMessageProcessor implements HttpRequestProcessor {
.withExtension(EventMeshConstants.REQ_C2EVENTMESH_TIMESTAMP, String.valueOf(System.currentTimeMillis()))
.build();
- //omsMsg.setTopic(replyTopic);
- // topic
- //omsMsg.putSystemProperties(Constants.PROPERTY_MESSAGE_DESTINATION, replyTopic);
- //if (!StringUtils.isBlank(sendMessageRequestBody.getTag())) {
- // omsMsg.putUserHeaders("Tag", sendMessageRequestBody.getTag());
- //}
- //rocketMQMsg = new Message(replyTopic,
- // replyMessageRequestBody.getContent().getBytes(EventMeshConstants.DEFAULT_CHARSET));
- //omsMsg.putUserProperties("msgType", "persistent");
- //rocketMQMsg.putUserProperty(DeFiBusConstant.KEY, DeFiBusConstant.PERSISTENT);
- //for (Map.Entry<String, String> entry : extFields.entrySet()) {
- // omsMsg.putUserProperties(entry.getKey(), entry.getValue());
- //}
- //
- ////for rocketmq support
- //MessageAccessor.putProperty(rocketMQMsg, MessageConst.PROPERTY_MESSAGE_TYPE, MixAll.REPLY_MESSAGE_FLAG);
- //MessageAccessor.putProperty(rocketMQMsg, MessageConst.PROPERTY_CORRELATION_ID,
- // rocketMQMsg.getProperty(DeFiBusConstant.PROPERTY_RR_REQUEST_ID));
- //MessageAccessor.putProperty(rocketMQMsg, MessageConst.PROPERTY_MESSAGE_REPLY_TO_CLIENT,
- // rocketMQMsg.getProperty(DeFiBusConstant.PROPERTY_MESSAGE_REPLY_TO));
- // ttl
- //omsMsg.putSystemProperties(Constants.PROPERTY_MESSAGE_TIMEOUT,
- // String.valueOf(EventMeshConstants.DEFAULT_TIMEOUT_IN_MILLISECONDS));
- ////MessageAccessor.putProperty(rocketMQMsg, DeFiBusConstant.PROPERTY_MESSAGE_TTL,
- // String.valueOf(EventMeshConstants.DEFAULT_TIMEOUT_IN_MILLISECONDS));
- //omsMsg.putUserProperties(EventMeshConstants.REQ_C2EVENTMESH_TIMESTAMP,
- // String.valueOf(System.currentTimeMillis()));
if (messageLogger.isDebugEnabled()) {
messageLogger.debug("msg2MQMsg suc, bizSeqNo={}, topic={}", bizNo, replyTopic);
}
@@ -297,24 +270,6 @@ public class ReplyMessageProcessor implements HttpRequestProcessor {
endTime - startTime, replyMQCluster + "-" + EventMeshConstants.RR_REPLY_TOPIC,
origTopic, bizNo, uniqueId, context.getException());
}
-
- //@Override
- //public void onException(Throwable e) {
- // HttpCommand err = asyncContext.getRequest().createHttpCommandResponse(
- // replyMessageResponseHeader,
- // SendMessageResponseBody.buildBody(EventMeshRetCode.EVENTMESH_REPLY_MSG_ERR.getRetCode(),
- // EventMeshRetCode.EVENTMESH_REPLY_MSG_ERR.getErrMsg() + EventMeshUtil.stackTrace(e, 2)));
- // asyncContext.onComplete(err, handler);
- // long endTime = System.currentTimeMillis();
- // eventMeshHTTPServer.metrics.summaryMetrics.recordReplyMsgFailed();
- // eventMeshHTTPServer.metrics.summaryMetrics.recordReplyMsgCost(endTime - startTime);
- // messageLogger.error("message|eventMesh2mq|RSP|SYNC|reply2MQCost={}|topic={}|origTopic={}|bizSeqNo={}|uniqueId={}",
- // endTime - startTime,
- // replyMQCluster + "-" + EventMeshConstants.RR_REPLY_TOPIC,
- // replyMessageRequestBody.getOrigTopic(),
- // replyMessageRequestBody.getBizSeqNo(),
- // replyMessageRequestBody.getUniqueId(), e);
- //}
});
} catch (Exception ex) {
HttpCommand err = asyncContext.getRequest().createHttpCommandResponse(
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java
index 07fb4df6..0392e21e 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/processor/SendAsyncMessageProcessor.java
@@ -83,7 +83,6 @@ public class SendAsyncMessageProcessor implements HttpRequestProcessor {
RemotingHelper.parseChannelRemoteAddr(ctx.channel()), IPUtils.getLocalAddress());
SendMessageRequestHeader sendMessageRequestHeader = (SendMessageRequestHeader) asyncContext.getRequest().getHeader();
- //SendMessageRequestBody sendMessageRequestBody = (SendMessageRequestBody) asyncContext.getRequest().getBody();
SendMessageResponseHeader sendMessageResponseHeader =
SendMessageResponseHeader.buildHeader(Integer.valueOf(asyncContext.getRequest().getRequestCode()),
@@ -210,31 +209,11 @@ public class SendAsyncMessageProcessor implements HttpRequestProcessor {
}
try {
- // body
- //omsMsg.setBody(sendMessageRequestBody.getContent().getBytes(EventMeshConstants.DEFAULT_CHARSET));
- //// topic
- //omsMsg.setTopic(sendMessageRequestBody.getTopic());
- //omsMsg.putSystemProperties(Constants.PROPERTY_MESSAGE_DESTINATION, sendMessageRequestBody.getTopic());
- //
- //if (!StringUtils.isBlank(sendMessageRequestBody.getTag())) {
- // omsMsg.putUserProperties(EventMeshConstants.TAG, sendMessageRequestBody.getTag());
- //}
- // ttl
- //omsMsg.putUserProperties(Constants.PROPERTY_MESSAGE_TIMEOUT, ttl);
- //// bizNo
- //omsMsg.putSystemProperties(Constants.PROPERTY_MESSAGE_SEARCH_KEYS, sendMessageRequestBody.getBizSeqNo());
event = CloudEventBuilder.from(event)
.withExtension("msgtype", "persistent")
.withExtension(EventMeshConstants.REQ_C2EVENTMESH_TIMESTAMP, String.valueOf(System.currentTimeMillis()))
.withExtension(EventMeshConstants.REQ_EVENTMESH2MQ_TIMESTAMP, String.valueOf(System.currentTimeMillis()))
.build();
- //omsMsg.putUserProperties("msgType", "persistent");
- //omsMsg.putUserProperties(EventMeshConstants.REQ_C2EVENTMESH_TIMESTAMP, String.valueOf(System.currentTimeMillis()));
- //omsMsg.putUserProperties(Constants.RMB_UNIQ_ID, sendMessageRequestBody.getUniqueId());
- //omsMsg.putUserProperties(EventMeshConstants.REQ_EVENTMESH2MQ_TIMESTAMP, String.valueOf(System.currentTimeMillis()));
-
- // new rocketmq client can't support put DeFiBusConstant.PROPERTY_MESSAGE_TTL
- //rocketMQMsg.putUserProperty(DeFiBusConstant.PROPERTY_MESSAGE_TTL, ttl);
if (messageLogger.isDebugEnabled()) {
messageLogger.debug("msg2MQMsg suc, bizSeqNo={}, topic={}", bizNo, topic);
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
index e6937f14..e5bfc1d6 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
@@ -524,11 +524,6 @@ public class ClientGroupWrapper {
.withExtension(EventMeshConstants.REQ_RECEIVE_EVENTMESH_IP,
eventMeshTCPConfiguration.eventMeshServerIp).build();
String topic = event.getSubject();
- // message.getSystemProperties(Constants.PROPERTY_MESSAGE_DESTINATION);
- //message.getSystemProperties().put(EventMeshConstants.REQ_MQ2EVENTMESH_TIMESTAMP,
- // String.valueOf(System.currentTimeMillis()));
- //message.getSystemProperties().put(EventMeshConstants.REQ_RECEIVE_EVENTMESH_IP,
- // eventMeshTCPConfiguration.eventMeshServerIp);
EventMeshAsyncConsumeContext eventMeshAsyncConsumeContext =
(EventMeshAsyncConsumeContext) context;
@@ -692,7 +687,6 @@ public class ClientGroupWrapper {
3000);
} catch (Exception e) {
logger.error("httpPost " + targetUrl + " is fail,", e);
- //throw new RuntimeException("httpPost " + targetUrl + " is fail," , e);
throw e;
}
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java
index 09b73966..e847e261 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/Session.java
@@ -339,10 +339,4 @@ public class Session {
return true;
}
- //@Override
- //public int hashCode() {
- // int code = 37 + (client != null ? client.hashCode() : 0) + (context != null ? context.hashCode() : 0)
- // + (sessionState != null ? sessionState.hashCode() : 0);
- // return code;
- //}
}
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java
index 608655bb..ffcf9368 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/ClientAckContext.java
@@ -111,8 +111,6 @@ public class ClientAckContext {
public void ackMsg() {
if (consumer != null && context != null && events != null) {
consumer.updateOffset(events, context);
- //ConsumeMessageService consumeMessageService = consumer..getDefaultMQPushConsumerImpl().getConsumeMessageService();
- //((ConsumeMessageConcurrentlyService)consumeMessageService).updateOffset(msgs, context);
logger.info("ackMsg topic:{}, bizSeq:{}", events.get(0).getSubject(), EventMeshUtil.getMessageBizSeq(events.get(0)));
} else {
logger.warn("ackMsg failed,consumer is null:{}, context is null:{} , msgs is null:{}",
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java
index f4244e76..d01469c7 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java
@@ -70,7 +70,6 @@ public class DownStreamMsgContext extends RetryContext {
this.createTime = System.currentTimeMillis();
this.subscriptionItem = subscriptionItem;
String ttlStr = (String) event.getExtension("TTL");
- //String ttlStr = msgExt.getUserProperties("TTL");
long ttl = StringUtils.isNumeric(ttlStr) ? Long.parseLong(ttlStr) :
EventMeshConstants.DEFAULT_TIMEOUT_IN_MILLISECONDS;
this.expireTime = System.currentTimeMillis() + ttl;
@@ -86,9 +85,6 @@ public class DownStreamMsgContext extends RetryContext {
List<CloudEvent> events = new ArrayList<CloudEvent>();
events.add(event);
consumer.updateOffset(events, consumeConcurrentlyContext);
- //ConsumeMessageService consumeMessageService =
- // consumer.getDefaultMQPushConsumer().getDefaultMQPushConsumerImpl().getConsumeMessageService();
- //((ConsumeMessageConcurrentlyService)consumeMessageService).updateOffset(msgs, consumeConcurrentlyContext);
logger.info("ackMsg seq:{}, topic:{}, bizSeq:{}", seq, events.get(0).getSubject(),
events.get(0).getExtension(EventMeshConstants.PROPERTY_MESSAGE_KEYS));
} else {
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java
index 44fccadb..7ff0d6a4 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/send/SessionSender.java
@@ -93,31 +93,18 @@ public class SessionSender {
ttl = Long.parseLong((String) Objects.requireNonNull(
event.getExtension(EventMeshConstants.PROPERTY_MESSAGE_TTL)));
}
- //long ttl = msg.getSystemProperties(EventMeshConstants.PROPERTY_MESSAGE_TTL) != null ?
- // Long.parseLong(msg.getSystemProperties(EventMeshConstants.PROPERTY_MESSAGE_TTL))
- // : EventMeshConstants.DEFAULT_TIMEOUT_IN_MILLISECONDS;
upStreamMsgContext = new UpStreamMsgContext(session, event, header, startTime, taskExecuteTime);
session.getClientGroupWrapper().get().request(upStreamMsgContext, initSyncRRCallback(header,
startTime, taskExecuteTime), ttl);
upstreamBuff.release();
} else if (Command.RESPONSE_TO_SERVER == cmd) {
String cluster = (String) event.getExtension(EventMeshConstants.PROPERTY_MESSAGE_CLUSTER);
- //String cluster = msg.getUserProperties(EventMeshConstants.PROPERTY_MESSAGE_CLUSTER);
if (!StringUtils.isEmpty(cluster)) {
String replyTopic = EventMeshConstants.RR_REPLY_TOPIC;
replyTopic = cluster + "-" + replyTopic;
event = CloudEventBuilder.from(event).withSubject(replyTopic).build();
- //msg.getSystemProperties().put(Constants.PROPERTY_MESSAGE_DESTINATION, replyTopic);
- //event(replyTopic);
}
- ////for rocketmq support
- //MessageAccessor.putProperty(msg, MessageConst.PROPERTY_MESSAGE_TYPE, MixAll.REPLY_MESSAGE_FLAG);
- //MessageAccessor.putProperty(msg, MessageConst.PROPERTY_CORRELATION_ID,
- // msg.getProperty(DeFiBusConstant.PROPERTY_RR_REQUEST_ID));
- //MessageAccessor.putProperty(msg, MessageConst.PROPERTY_MESSAGE_REPLY_TO_CLIENT,
- // msg.getProperty(DeFiBusConstant.PROPERTY_MESSAGE_REPLY_TO));
-
upStreamMsgContext = new UpStreamMsgContext(session, event, header, startTime, taskExecuteTime);
session.getClientGroupWrapper().get().reply(upStreamMsgContext);
upstreamBuff.release();
@@ -148,12 +135,6 @@ public class SessionSender {
public void onSuccess(CloudEvent event) {
String seq = header.getSeq();
// TODO: How to assign values here
- //if (msg instanceof MessageExt) {
- // msg.putUserProperty(EventMeshConstants.BORN_TIMESTAMP, String.valueOf(((MessageExt) msg)
- // .getBornTimestamp()));
- // msg.putUserProperty(EventMeshConstants.STORE_TIMESTAMP, String.valueOf(((MessageExt) msg)
- // .getStoreTimestamp()));
- //}
event = CloudEventBuilder.from(event)
.withExtension(EventMeshConstants.RSP_MQ2EVENTMESH_TIMESTAMP, String.valueOf(System.currentTimeMillis()))
.withExtension(EventMeshConstants.RSP_RECEIVE_EVENTMESH_IP, session.getEventMeshTCPConfiguration().eventMeshServerIp)
@@ -176,9 +157,7 @@ public class SessionSender {
Package pkg = new Package();
- //msg.getSystemProperties().put(EventMeshConstants.RSP_EVENTMESH2C_TIMESTAMP, String.valueOf(System.currentTimeMillis()));
try {
- //pkg.setBody(EventMeshUtil.encodeMessage(msg));
pkg = (Package) protocolAdaptor.fromCloudEvent(event);
pkg.setHeader(new Header(cmd, OPStatus.SUCCESS.getCode(), null, seq));
pkg.getHeader().putProperty(Constants.PROTOCOL_TYPE, protocolType);
@@ -186,7 +165,6 @@ public class SessionSender {
pkg.setHeader(new Header(cmd, OPStatus.FAIL.getCode(), null, seq));
} finally {
Utils.writeAndFlush(pkg, startTime, taskExecuteTime, session.getContext(), session);
- //session.write2Client(pkg);
}
}
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/HelloTask.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/HelloTask.java
index 12ca6ff9..bde06590 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/HelloTask.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/HelloTask.java
@@ -101,14 +101,6 @@ public class HelloTask extends AbstractTask {
throw new Exception("client version cannot be null");
}
- //if (user.getUsername() == null) {
- // throw new Exception("client EventMeshUser cannot be null");
- //}
- //
- //if (user.getPassword() == null) {
- // throw new Exception("client EventMeshPasswd cannot be null");
- //}
-
if (!(StringUtils.equals(EventMeshConstants.PURPOSE_PUB, user.getPurpose()) || StringUtils.equals(
EventMeshConstants.PURPOSE_SUB, user.getPurpose()))) {
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/ListenTask.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/ListenTask.java
index 7d26fe66..8c606154 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/ListenTask.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/ListenTask.java
@@ -46,10 +46,6 @@ public class ListenTask extends AbstractTask {
Integer status = OPStatus.FAIL.getCode();
header = new Header(LISTEN_RESPONSE, status, e.toString(), pkg.getHeader().getSeq());
} finally {
- //res.setHeader(header);
- //writeAndFlush(res, startTime, session.getContext(), session);
- //session.write2Client(res);
-
//check to avoid send repeatedly
session.trySendListenResponse(header, startTime, taskExecuteTime);
}
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/NonStandardKeys.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/NonStandardKeys.java
deleted file mode 100644
index a82c71e4..00000000
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/NonStandardKeys.java
+++ /dev/null
@@ -1,34 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.eventmesh.runtime.domain;
-
-/**
- * NonStandardKeys
- */
-public interface NonStandardKeys {
- String CONSUMER_GROUP = "rmq.consumer.group";
- String PRODUCER_GROUP = "rmq.producer.group";
- String MAX_REDELIVERY_TIMES = "rmq.max.redelivery.times";
- String MESSAGE_CONSUME_TIMEOUT = "rmq.message.consume.timeout";
- String MAX_CONSUME_THREAD_NUMS = "rmq.max.consume.thread.nums";
- String MIN_CONSUME_THREAD_NUMS = "rmq.min.consume.thread.nums";
- String MESSAGE_CONSUME_STATUS = "rmq.message.consume.status";
- String MESSAGE_DESTINATION = "rmq.message.destination";
- String PULL_MESSAGE_BATCH_NUMS = "rmq.pull.message.batch.nums";
- String PULL_MESSAGE_CACHE_CAPACITY = "rmq.pull.message.cache.capacity";
-}
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/RocketMQConstants.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/RocketMQConstants.java
deleted file mode 100644
index 95fb1aee..00000000
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/RocketMQConstants.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-
-package org.apache.eventmesh.runtime.domain;
-
-/**
- * RocketMQConstants
- */
-public interface RocketMQConstants {
-
- /**
- * Key of scheduled message delivery time
- */
- String START_DELIVER_TIME = "__STARTDELIVERTIME";
-
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org