Function getEventsGroupQueueShard

packages/queue/src/queues.ts:218–225

(groupId: string)

);

export const getEventsGroupQueueShard = (groupId: string) => {
  const shard = pickShard(groupId);
  const queue = eventsGroupQueues[shard];
  if (!queue) {
    throw new Error(`Queue not found for group ${groupId}`);
  }
  return queue;
};

export const sessionsQueue = new Queue<SessionsQueuePayload>(
  getQueueName('sessions'),