100
}
101
103
>
queueType := persistence.QueueType(rand.Int31())
104
>
105
>
queueMetadata := s.newRandomQueueMetadataRow(queueType)
106
>
result, err := s.store.InsertIntoQueueMetadata(newExecutionContext(), &queueMetadata)
107
>
s.NoError(err)
108
>
rowsAffected, err := result.RowsAffected()
109
>
s.NoError(err)
110
>
s.Equal(1, int(rowsAffected))
111
>
112
>
queueMetadata = s.newRandomQueueMetadataRow(queueType)
113
>
result, err = s.store.UpdateQueueMetadata(newExecutionContext(), &queueMetadata)
114
>
s.NoError(err)
115
>
rowsAffected, err = result.RowsAffected()
116
>
s.NoError(err)
117
>
s.Equal(1, int(rowsAffected))
118
>
}
119
120
func (s *queueMetadataSuite) TestUpdate_Fail() {