154
}
155
157
>
TemplateGetMessagesQuery,
158
>
request.QueueType,
159
>
request.QueueName,
160
>
0,
161
>
int(minMessageID),
162
>
request.PageSize,
163
>
).WithContext(ctx).Iter()
164
>
165
>
var (
166
>
messages []persistence.QueueV2Message
167
>
// messageID is the ID of the last message returned by the query.
168
>
messageID int64
169
>
)
170
>
171
>
for {
172
>
var (
173
>
messagePayload []byte
174
>
messageEncoding string
175
>
)
176
>
if !iter.Scan(&messageID, &messagePayload, &messageEncoding) {
177
break
178
}