174
}
175
177
>
queueType := persistence.NamespaceReplicationQueueType
178
>
messageID := rand.Int63()
179
>
180
>
filter := sqlplugin.QueueMessagesFilter{
181
>
QueueType: queueType,
182
>
MessageID: messageID,
183
>
}
184
>
result, err := s.store.DeleteFromMessages(newExecutionContext(), filter)
185
>
s.NoError(err)
186
>
rowsAffected, err := result.RowsAffected()
187
>
s.NoError(err)
188
>
s.Equal(0, int(rowsAffected))
189
>
190
>
rows, err := s.store.SelectFromMessages(newExecutionContext(), filter)
191
>
s.NoError(err)
192
>
for index := range rows {
193
rows[index].QueueType = queueType
194
}
196
}
197