Package com.sun.jersey.api.client.WebResource

Examples of com.sun.jersey.api.client.WebResource.Builder

436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
    }

    @Override
    public CreateSubscriptionResult createSubscription(String topicPath,
            SubscriptionInfo subscriptionInfo) {
        Builder webResourceBuilder = getResource().path(topicPath)
                .path("subscriptions").path(subscriptionInfo.getName())
                .type("application/atom+xml;type=entry;charset=utf-8");
        if ((subscriptionInfo.getForwardTo() != null)
                && (!subscriptionInfo.getForwardTo().isEmpty())) {
            webResourceBuilder.header("ServiceBusSupplementaryAuthorization",
                    subscriptionInfo.getForwardTo());

        }
        return new CreateSubscriptionResult(webResourceBuilder.put(
                SubscriptionInfo.class, subscriptionInfo));
    }
View Full Code Here
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
    }

    @Override
    public SubscriptionInfo updateSubscription(String topicName,
            SubscriptionInfo subscriptionInfo) throws ServiceException {
        Builder webResourceBuilder = getResource().path(topicName)
                .path("subscriptions").path(subscriptionInfo.getName())
                .type("application/atom+xml;type=entry;charset=utf-8")
                .header("If-Match", "*");
        if ((subscriptionInfo.getForwardTo() != null)
                && !subscriptionInfo.getForwardTo().isEmpty()) {
            webResourceBuilder.header("ServiceBusSupplementaryAuthorization",
                    subscriptionInfo.getForwardTo());
        }
        return webResourceBuilder.put(SubscriptionInfo.class, subscriptionInfo);
    }
View Full Code Here
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
        String path = createPathFromContainer(container);
        WebResource webResource = getResource(options).path(path).path(blob);
        webResource = addOptionalQueryParam(webResource, "snapshot",
                options.getSnapshot());

        Builder builder = webResource.header("x-ms-version", API_VERSION);
        builder = addOptionalHeader(builder, "x-ms-lease-id",
                options.getLeaseId());
        if (options.getDeleteSnaphotsOnly() != null) {
            builder = addOptionalHeader(builder, "x-ms-delete-snapshots",
                    options.getDeleteSnaphotsOnly() ? "only" : "include");
        }
        builder = addOptionalAccessConditionHeader(builder,
                options.getAccessCondition());

        builder.delete();
    }
View Full Code Here
298
299
300
301
302
303
304
305
306
        webResource = addOptionalQueryParam(webResource, "maxresults",
                options.getMaxResults(), 0);
        webResource = addOptionalContainerIncludeQueryParam(options,
                webResource);

        Builder builder = webResource.header("x-ms-version", API_VERSION);

        return builder.get(ListContainersResult.class);
    }
View Full Code Here
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
            InputStream contentStream, CreateBlobOptions options)
            throws ServiceException {
        String path = createPathFromContainer(container);
        WebResource webResource = getResource(options).path(path).path(blob);

        Builder builder = webResource.header("x-ms-version", API_VERSION);

        builder = builder.header("x-ms-blob-type", "BlockBlob");
        builder = addPutBlobHeaders(options, builder);

        Object contentObject = (contentStream == null ? new byte[0]
                : contentStream);
        ClientResponse clientResponse = builder.put(ClientResponse.class,
                contentObject);
        throwIfError(clientResponse);

        CreateBlobResult createBlobResult = new CreateBlobResult();
        createBlobResult.setEtag(clientResponse.getHeaders().getFirst("ETag"));
View Full Code Here
357
358
359
360
361
362
363
364
365
366
367
368
369
                    new String(Base64.encode(blockId), "UTF-8"));
        } catch (UnsupportedEncodingException e) {
            throw new RuntimeException(e);
        }

        Builder builder = webResource.header("x-ms-version", API_VERSION);
        builder = addOptionalHeader(builder, "x-ms-lease-id",
                options.getLeaseId());
        builder = addOptionalHeader(builder, "Content-MD5",
                options.getContentMD5());

        builder.put(contentStream);
    }
View Full Code Here
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
            throws ServiceException {
        String path = createPathFromContainer(container);
        WebResource webResource = getResource(options).path(path).path(blob)
                .queryParam("comp", "blocklist");

        Builder builder = webResource.header("x-ms-version", API_VERSION);
        builder = addOptionalHeader(builder, "x-ms-lease-id",
                options.getLeaseId());
        builder = addOptionalHeader(builder, "x-ms-blob-cache-control",
                options.getBlobCacheControl());
        builder = addOptionalHeader(builder, "x-ms-blob-content-type",
                options.getBlobContentType());
        builder = addOptionalHeader(builder, "x-ms-blob-content-encoding",
                options.getBlobContentEncoding());
        builder = addOptionalHeader(builder, "x-ms-blob-content-language",
                options.getBlobContentLanguage());
        builder = addOptionalHeader(builder, "x-ms-blob-content-md5",
                options.getBlobContentMD5());
        builder = addOptionalMetadataHeader(builder, options.getMetadata());
        builder = addOptionalAccessConditionHeader(builder,
                options.getAccessCondition());

        builder.put(blockList);
    }
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
        String path = createPathFromContainer(container);
        WebResource webResource = getResource(options).path(path).path(blob);
        webResource = addOptionalQueryParam(webResource, "snapshot",
                options.getSnapshot());

        Builder builder = webResource.header("x-ms-version", API_VERSION);
        builder = addOptionalHeader(builder, "x-ms-lease-id",
                options.getLeaseId());
        builder = addOptionalAccessConditionHeader(builder,
                options.getAccessCondition());

        ClientResponse response = builder.method("HEAD", ClientResponse.class);
        throwIfNotSuccess(response);

        return getBlobPropertiesResultFromResponse(response);
    }
View Full Code Here
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
        String path = createPathFromContainer(container);
        WebResource webResource = getResource(options).path(path).path(blob);
        webResource = addOptionalQueryParam(webResource, "snapshot",
                options.getSnapshot());

        Builder builder = webResource.header("x-ms-version", API_VERSION);
        builder = addOptionalHeader(builder, "x-ms-lease-id",
                options.getLeaseId());
        builder = addOptionalRangeHeader(builder, options.getRangeStart(),
                options.getRangeEnd());
        builder = addOptionalAccessConditionHeader(builder,
                options.getAccessCondition());
        if (options.isComputeRangeMD5()) {
            builder = addOptionalHeader(builder, "x-ms-range-get-content-md5",
                    "true");
        }

        ClientResponse response = builder.get(ClientResponse.class);
        throwIfNotSuccess(response);

        GetBlobPropertiesResult properties = getBlobPropertiesResultFromResponse(response);
        GetBlobResult blobResult = new GetBlobResult();
        blobResult.setProperties(properties.getProperties());
View Full Code Here
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
        } else if (options.isUncommittedList()) {
            webResource = addOptionalQueryParam(webResource, "blocklisttype",
                    "uncommitted");
        }

        Builder builder = webResource.header("x-ms-version", API_VERSION);
        builder = addOptionalHeader(builder, "x-ms-lease-id",
                options.getLeaseId());

        ClientResponse response = builder.get(ClientResponse.class);
        throwIfError(response);

        ListBlobBlocksResult result = response
                .getEntity(ListBlobBlocksResult.class);
        result.setEtag(response.getHeaders().getFirst("ETag"));
View Full Code Here
TOP

Related Classes of com.sun.jersey.api.client.WebResource.Builder

  • com.cumulocity.sdk.client.RestConnector
  • com.eclipsesource.restfuse.internal.InternalRequest
  • com.fluxcapacitor.edge.EdgeIntegrationTest
  • com.kpelykh.docker.client.DockerClient
  • com.mercadopago.MP$RestClient
  • com.microsoft.windowsazure.core.pipeline.PipelineHelpersTest
  • com.microsoft.windowsazure.services.blob.implementation.BlobOperationRestProxy
  • com.microsoft.windowsazure.services.media.entityoperations.EntityRestProxy
  • com.microsoft.windowsazure.services.queue.implementation.QueueRestProxy
  • com.microsoft.windowsazure.services.servicebus.implementation.ServiceBusRestProxy
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.