Merge pull request #1063 from nanfengonline/fixTypo

Fix typo Unknow -> Unknown

examples/producer/transaction/main.go

@@ -49,14 +49,14 @@ func (dl *DemoListener) ExecuteLocalTransaction(msg *primitive.Message) primitiv
 	dl.localTrans.Store(msg.TransactionId, primitive.LocalTransactionState(status+1))
 
 	fmt.Printf("dl")
-	return primitive.UnknowState
+	return primitive.UnkonwnState
 }
 
 func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primitive.LocalTransactionState {
 	fmt.Printf("%v msg transactionID : %v\n", time.Now(), msg.TransactionId)
 	v, existed := dl.localTrans.Load(msg.TransactionId)
 	if !existed {
-		fmt.Printf("unknow msg: %v, return Commit", msg)
+		fmt.Printf("unknown msg: %v, return Commit", msg)
 		return primitive.CommitMessageState
 	}
 	state := v.(primitive.LocalTransactionState)
@@ -68,8 +68,8 @@ func (dl *DemoListener) CheckLocalTransaction(msg *primitive.MessageExt) primiti
 		fmt.Printf("checkLocalTransaction ROLLBACK_MESSAGE: %v\n", msg)
 		return primitive.RollbackMessageState
 	case 3:
-		fmt.Printf("checkLocalTransaction unknow: %v\n", msg)
-		return primitive.UnknowState
+		fmt.Printf("checkLocalTransaction unknown: %v\n", msg)
+		return primitive.UnkonwnState
 	default:
 		fmt.Printf("checkLocalTransaction default COMMIT_MESSAGE: %v\n", msg)
 		return primitive.CommitMessageState

primitive/message.go

@@ -445,7 +445,7 @@ type LocalTransactionState int
 const (
 	CommitMessageState LocalTransactionState = iota + 1
 	RollbackMessageState
-	UnknowState
+	UnkonwnState
 )
 
 type TransactionListener interface {

producer/producer.go

@@ -712,7 +712,7 @@ func (tp *transactionProducer) SendMessageInTransaction(ctx context.Context, msg
 	if err != nil {
 		return nil, err
 	}
-	localTransactionState := primitive.UnknowState
+	localTransactionState := primitive.UnkonwnState
 	switch rsp.Status {
 	case primitive.SendOK:
 		if len(rsp.TransactionID) > 0 {
@@ -782,7 +782,7 @@ func (tp *transactionProducer) transactionState(state primitive.LocalTransaction
 		return primitive.TransactionCommitType
 	case primitive.RollbackMessageState:
 		return primitive.TransactionRollbackType
-	case primitive.UnknowState:
+	case primitive.UnkonwnState:
 		return primitive.TransactionNotType
 	default:
 		return primitive.TransactionNotType