File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
examples/producer/transaction Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -56,7 +56,7 @@ func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primiti
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,7 +68,7 @@ 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 )
71+ fmt .Printf ("checkLocalTransaction unknown : %v\n " , msg )
7272 return primitive .UnkonwnState
7373 default :
7474 fmt .Printf ("checkLocalTransaction default COMMIT_MESSAGE: %v\n " , msg )
You can’t perform that action at this time.
0 commit comments