}
queueType := persistence.NamespaceReplicationQueueType
messageID := rand.Int63()
message := s.newRandomQueueMessageRow(queueType, messageID)
result, err := s.store.InsertIntoMessages(newExecutionContext(), []sqlplugin.QueueMessageRow{message})
s.NoError(err)
rowsAffected, err := result.RowsAffected()
s.NoError(err)
s.Equal(1, int(rowsAffected))
}
func (s *queueMessageSuite) TestInsert_Multiple_Success() {