Skip to content

Commit 18b9f43

Browse files
committed
readme
1 parent 7a45a38 commit 18b9f43

File tree

2 files changed

+3
-4
lines changed

2 files changed

+3
-4
lines changed

README.md

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,7 @@ bus.Subscribe("topic1").Middleware(common.Middleware1, common.Middleware2).Handl
3737
`common.Middleware1`,`common.Middleware2`,`common.EchoHandler` 的代码在 [common.go](_example/common/common.go)
3838

3939

40-
## 普通发布
40+
## 发布
4141

4242
```go
4343
msg := common.GeneralMessage{Type: "simple message", Count: 100}
@@ -48,8 +48,7 @@ if err != nil {
4848
}
4949
```
5050

51-
###
52-
51+
更多消息发布策略在 [message_policy.go](./message/message_policy.go)
5352

5453
## 关联本地事务发布
5554

message/message_policy.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ func DefaultMessagePolicy() *Policy {
2323

2424
type PolicyOption func(c *Policy)
2525

26-
// WithConfirm 开启Confirm,决定消息是否一定发送成功。默认开启
26+
// WithConfirm 开启Confirm,会使用本地消息表保存消息,联合mq的Confirm机制
2727
func WithConfirm(use bool) PolicyOption {
2828
return func(c *Policy) {
2929
c.Confirm = use

0 commit comments

Comments
 (0)