apache / rocketmq

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
https://rocketmq.apache.org/
Apache License 2.0
21.19k stars 11.67k forks source link

what's diff between rocketmq-client and rocketmq-client-java on 5.0.0 version #5525

Closed ilovedumplings closed 1 year ago

ilovedumplings commented 1 year ago

in the int the rocket mq 5.0.0 quick start , it use rocketmq-client-java i wanna know what's diff between rocketmq-client-java and rocketmq -client

  <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-client</artifactId>
        <version>5.0.0</version>
    </dependency>
    <dependency>
        <groupId>org.apache.rocketmq</groupId>
        <artifactId>rocketmq-client-java</artifactId>
        <version>5.0.0</version>
    </dependency>

thanks.

aaron-ai commented 1 year ago

rocketmq-client-java is the gRPC/protobuf-based SDK, while rocketmq-client is the remoting-based SDK.

They works by different communication protocols, and rocketmq-client-java adopts the brand new APIs and is recommended.

ilovedumplings commented 1 year ago

rocketmq-client-java is the gRPC/protobuf-based SDK, while rocketmq-client is the remoting-based SDK.

They works by different communication protocols, and rocketmq-client-java adopts the brand new APIs and is recommended.

thanks.

i also wanna know both them support customized delay queue(int 24 hours) ??

aaron-ai commented 1 year ago

@ilovedumplings you mean delay message? Of course!

ilovedumplings commented 1 year ago

@ilovedumplings you mean delay message? Of course!

yeah yeah yeah ,thanks !big man !!!

in rocketmq-client i wanna use delay message can i use this : ⬇ org.apache.rocketmq.common.message.Message

public void setDelayTimeSec(long sec) {
    this.putProperty(MessageConst.PROPERTY_TIMER_DELAY_SEC, String.valueOf(sec));
}
public void setDelayTimeMs(long timeMs) {
    this.putProperty(MessageConst.PROPERTY_TIMER_DELAY_MS, String.valueOf(timeMs));
}
public void setDeliverTimeMs(long timeMs) {
    this.putProperty(MessageConst.PROPERTY_TIMER_DELIVER_MS, String.valueOf(timeMs));
}
ilovedumplings commented 1 year ago

@ilovedumplings you mean delay message? Of course!

因为我看rocket-mq-client的,似乎没有调用PROPERTY_TIMER_DELIVER_MS/PROPERTY_TIMER_DELAY_SEC 这几个参数的地方

ilovedumplings commented 1 year ago

sorry . i use wrong version of broker ....shit....