|
- /*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
- package message
-
- import (
- "testing"
-
- "github.com/stretchr/testify/assert"
- )
-
- func TestConstantMessageType(t *testing.T) {
- assert.Equal(t, int(MessageTypeGlobalBegin), 1)
- assert.Equal(t, int(MessageTypeGlobalBeginResult), 2)
- assert.Equal(t, int(MessageTypeBranchCommit), 3)
- assert.Equal(t, int(MessageTypeBranchCommitResult), 4)
- assert.Equal(t, int(MessageTypeBranchRollback), 5)
- assert.Equal(t, int(MessageTypeBranchRollbackResult), 6)
- assert.Equal(t, int(MessageTypeGlobalCommit), 7)
- assert.Equal(t, int(MessageTypeGlobalCommitResult), 8)
- assert.Equal(t, int(MessageTypeGlobalRollback), 9)
- assert.Equal(t, int(MessageTypeGlobalRollbackResult), 10)
- assert.Equal(t, int(MessageTypeBranchRegister), 11)
- assert.Equal(t, int(MessageTypeBranchRegisterResult), 12)
- assert.Equal(t, int(MessageTypeBranchStatusReport), 13)
- assert.Equal(t, int(MessageTypeBranchStatusReportResult), 14)
- assert.Equal(t, int(MessageTypeGlobalStatus), 15)
- assert.Equal(t, int(MessageTypeGlobalStatusResult), 16)
- assert.Equal(t, int(MessageTypeGlobalReport), 17)
- assert.Equal(t, int(MessageTypeGlobalReportResult), 18)
- assert.Equal(t, int(MessageTypeGlobalLockQuery), 21)
- assert.Equal(t, int(MessageTypeGlobalLockQueryResult), 22)
- assert.Equal(t, int(MessageTypeSeataMerge), 59)
- assert.Equal(t, int(MessageTypeSeataMergeResult), 60)
- assert.Equal(t, int(MessageTypeRegClt), 101)
- assert.Equal(t, int(MessageTypeRegCltResult), 102)
- assert.Equal(t, int(MessageTypeRegRm), 103)
- assert.Equal(t, int(MessageTypeRegRmResult), 104)
- assert.Equal(t, int(MessageTypeRmDeleteUndolog), 111)
- assert.Equal(t, int(MessageTypeHeartbeatMsg), 120)
- assert.Equal(t, int(MessageTypeBatchResultMsg), 121)
- }
|