96
ctx context.Context,
97
queueType persistence.QueueType,
99
>
var lastMessageID *int64
100
>
err := mdb.GetContext(ctx,
101
>
&lastMessageID,
102
>
templateGetLastMessageIDQuery,
103
>
queueType,
104
>
)
105
>
if lastMessageID == nil {
106
>
// The layer of code above us expects ErrNoRows when the queue is empty. MAX() yields
107
>
// null when the queue is empty, so we need to turn that into the correct error.
108
>
return 0, sql.ErrNoRows
109
>
} else {
110
>
return *lastMessageID, err
111
>
}
112
}
113