Skip to content

Commit 8e701a5

Browse files
Merge pull request apache#1063 from nanfengonline/fixTypo
Fix typo Unknow -> Unknown
2 parents 49f0448 + 49eb1fc commit 8e701a5

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

examples/producer/transaction/main.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,14 +49,14 @@ func (dl *DemoListener) ExecuteLocalTransaction(msg *primitive.Message) primitiv
4949
dl.localTrans.Store(msg.TransactionId, primitive.LocalTransactionState(status+1))
5050

5151
fmt.Printf("dl")
52-
return primitive.UnknowState
52+
return primitive.UnkonwnState
5353
}
5454

5555
func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState {
5656
fmt.Printf("%v msg transactionID : %v\n", time.Now(), msg.TransactionId)
5757
v, existed := dl.localTrans.Load(msg.TransactionId)
5858
if !existed {
59-
fmt.Printf("unknow msg: %v, return Commit", msg)
59+
fmt.Printf("unknown msg: %v, return Commit", msg)
6060
return primitive.CommitMessageState
6161
}
6262
state := v.(primitive.LocalTransactionState)
@@ -68,8 +68,8 @@ func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primiti
6868
fmt.Printf("checkLocalTransaction ROLLBACK_MESSAGE: %v\n", msg)
6969
return primitive.RollbackMessageState
7070
case 3:
71-
fmt.Printf("checkLocalTransaction unknow: %v\n", msg)
72-
return primitive.UnknowState
71+
fmt.Printf("checkLocalTransaction unknown: %v\n", msg)
72+
return primitive.UnkonwnState
7373
default:
7474
fmt.Printf("checkLocalTransaction default COMMIT_MESSAGE: %v\n", msg)
7575
return primitive.CommitMessageState

primitive/message.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -445,7 +445,7 @@ type LocalTransactionState int
445445
const (
446446
CommitMessageState LocalTransactionState = iota + 1
447447
RollbackMessageState
448-
UnknowState
448+
UnkonwnState
449449
)
450450

451451
type TransactionListener interface {

producer/producer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -712,7 +712,7 @@ func (tp *transactionProducer) SendMessageInTransaction(ctx context.Context, msg
712712
if err != nil {
713713
return nil, err
714714
}
715-
localTransactionState := primitive.UnknowState
715+
localTransactionState := primitive.UnkonwnState
716716
switch rsp.Status {
717717
case primitive.SendOK:
718718
if len(rsp.TransactionID) > 0 {
@@ -782,7 +782,7 @@ func (tp *transactionProducer) transactionState(state primitive.LocalTransaction
782782
return primitive.TransactionCommitType
783783
case primitive.RollbackMessageState:
784784
return primitive.TransactionRollbackType
785-
case primitive.UnknowState:
785+
case primitive.UnkonwnState:
786786
return primitive.TransactionNotType
787787
default:
788788
return primitive.TransactionNotType

0 commit comments

Comments
 (0)