67
}
68
69
>
func (s *queueMessageSuite) TestInsert_Multiple_Success() {
queue_message.go
70
>
queueType := persistence.NamespaceReplicationQueueType
71
>
messageID := rand.Int63()
72
>
73
>
message1 := s.newRandomQueueMessageRow(queueType, messageID)
74
>
messageID++
75
>
message2 := s.newRandomQueueMessageRow(queueType, messageID)
76
>
result, err := s.store.InsertIntoMessages(newExecutionContext(), []sqlplugin.QueueMessageRow{message1, message2})
77
>
s.NoError(err)
78
>
rowsAffected, err := result.RowsAffected()
79
>
s.NoError(err)
80
>
s.Equal(2, int(rowsAffected))
81
>
}
82
83
func (s *queueMessageSuite) TestInsert_Single_Fail_Duplicate() {