lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

javadoc

Browse Source
This commit is contained in:
redkale
2024-08-18 11:06:11 +08:00
parent 74823fe2fe
commit 2c65bb5996
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
docs/agent-message.md
View File

@@ -20,8 +20,10 @@ public class TestMessageConsumer implements MessageConsumer<TestBean> {
} }
@Override @Override
public void onMessage(MessageConext context, TestBean message) { public void onMessage(MessageEvent<TestBean>[] events) {
System.out.println("消费消息, message: " + message); for (MessageEvent<TestBean> event : events) {
System.out.println("消费消息, message: " + event.getMessage());
}
} }
@Override @Override
@@ -36,8 +38,10 @@ public class TestMessageConsumer implements MessageConsumer<TestBean> {
public class TestMessageService extends AbstractService { public class TestMessageService extends AbstractService {
@Messaged(mq = "mymq", topics = "test_bean_topic") @Messaged(mq = "mymq", topics = "test_bean_topic")
protected void runMessage(TestBean message) { protected void runMessage(MessageEvent<TestBean>[] events) {
System.out.println("消费消息, message: " + message); for (MessageEvent<TestBean> event : events) {
System.out.println("消费消息, message: " + event.getMessage());
}
} }
} }
``` ```
@@ -48,8 +52,10 @@ public class TestMessageService extends AbstractService {
public final class TestMessageService extends AbstractService { public final class TestMessageService extends AbstractService {
@Messaged(mq = "mymq", topics = "test_bean_topic") @Messaged(mq = "mymq", topics = "test_bean_topic")
public int runMessage(TestBean message) { public int runMessage(MessageEvent<TestBean>[] events) {
System.out.println("消费消息, message: " + message); for (MessageEvent<TestBean> event : events) {
System.out.println("消费消息, message: " + event.getMessage());
}
return 0; return 0;
} }
} }