109
}
110
111
>
func (mdb *db) GetLastEnqueuedMessageIDForUpdateV2(ctx context.Context, filter sqlplugin.QueueV2Filter) (int64, error) {
queue_v2.go
112
>
var lastMessageID *int64
113
>
err := mdb.GetContext(ctx,
114
>
&lastMessageID,
115
>
templateGetLastMessageIDQueryV2,
116
>
filter.QueueType,
117
>
filter.QueueName,
118
>
filter.Partition,
119
>
filter.QueueType,
120
>
filter.QueueName,
121
>
filter.Partition,
122
>
)
123
>
if lastMessageID == nil {
124
>
// The layer of code above us expects ErrNoRows when the queue is empty. MAX() yields
125
>
// null when the queue is empty, so we need to turn that into the correct error.
126
>
return 0, sql.ErrNoRows
127
>
}
128
return *lastMessageID, err
129
}