private void addIngestionResource()

in ingest/src/main/java/com/microsoft/azure/kusto/ingest/ResourceManager.java [173:194]


        private void addIngestionResource(IngestionResourceSet ingestionResourceSet, String resourceTypeName, String storageUrl) throws URISyntaxException {
            ResourceType resourceType = ResourceType.findByResourceTypeName(resourceTypeName);
            switch (resourceType) {
                case TEMP_STORAGE:
                    ingestionResourceSet.containers.addResource(new ContainerWithSas(storageUrl, httpClient));
                    break;
                case INGESTIONS_STATUS_TABLE:
                    ingestionResourceSet.statusTable.addResource(new TableWithSas(storageUrl, httpClient));
                    break;
                case SECURED_READY_FOR_AGGREGATION_QUEUE:
                    ingestionResourceSet.queues.addResource(new QueueWithSas(storageUrl, httpClient, queueRequestOptions));
                    break;
                case SUCCESSFUL_INGESTIONS_QUEUE:
                    ingestionResourceSet.successfulIngestionsQueues.addResource(new QueueWithSas(storageUrl, httpClient, queueRequestOptions));
                    break;
                case FAILED_INGESTIONS_QUEUE:
                    ingestionResourceSet.failedIngestionsQueues.addResource(new QueueWithSas(storageUrl, httpClient, queueRequestOptions));
                    break;
                default:
                    throw new IllegalStateException("Unexpected value: " + resourceType);
            }
        }