code: func (n *NetworkServerAPI) GetMulticastQueueItemsForMulticastGroup(ctx context.Context, req *ns.GetMulticastQueueItemsForMulticastGroupRequest) (*ns.GetMulticastQueueItemsForMulticastGroupResponse, error) {
  	var mgID uuid.UUID
  	copy(mgID[:], req.MulticastGroupId)
  
  	items, err := storage.GetMulticastQueueItemsForMulticastGroup(storage.DB(), mgID)
  	if err != nil {
  		return nil, errToRPCError(err)
  	}
  
  	counterSeen := make(map[uint32]struct{})
  	var out ns.GetMulticastQueueItemsForMulticastGroupResponse
  	for i := range items {
  		// we need to de-duplicate the queue-items as they are created per-gateway
  		if _, seen := counterSeen[items[i].FCnt]; seen {
  			continue
  		}
  
  		qi := ns.MulticastQueueItem{
  			MulticastGroupId: items[i].MulticastGroupID.Bytes(),
  			FrmPayload:       items[i].FRMPayload,
  			FCnt:             items[i].FCnt,
  			FPort:            uint32(items[i].FPort),
  		}
  		counterSeen[items[i].FCnt] = struct{}{}
  		out.MulticastQueueItems = append(out.MulticastQueueItems, &qi)
  	}
  
  	return &out, nil
  }
docs: // GetMulticastQueueItemsForMulticastGroup returns the queue-items given a multicast-group id.