com.microsoft.azure.cosmosdb.internal.directconnectivity

Class StoreClient

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.StoreClient

All Implemented Interfaces:

IStoreClient

public class StoreClient
extends Object
implements IStoreClient

Instantiated to issue direct connectivity requests to the backend on: - Gateway (for gateway mode clients) - Client (for direct mode clients) StoreClient uses the ReplicatedResourceClient to make requests to the backend.

Constructor Summary

Constructors

Constructor and Description
StoreClient(com.microsoft.azure.cosmosdb.rx.internal.Configs configs, IAddressResolver addressResolver, com.microsoft.azure.cosmosdb.internal.SessionContainer sessionContainer, GatewayServiceConfigurationReader serviceConfigurationReader, com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider userTokenProvider, TransportClient transportClient, boolean useMultipleWriteLocations)

Method Summary

Modifier and Type	Method and Description
rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse>	processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request, com.microsoft.azure.cosmosdb.rx.internal.IRetryPolicy retryPolicy, rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.microsoft.azure.cosmosdb.internal.directconnectivity.IStoreClient

processMessageAsync, processMessageAsync, processMessageAsync

Constructor Detail

StoreClient

public StoreClient(com.microsoft.azure.cosmosdb.rx.internal.Configs configs,
                   IAddressResolver addressResolver,
                   com.microsoft.azure.cosmosdb.internal.SessionContainer sessionContainer,
                   GatewayServiceConfigurationReader serviceConfigurationReader,
                   com.microsoft.azure.cosmosdb.rx.internal.IAuthorizationTokenProvider userTokenProvider,
                   TransportClient transportClient,
                   boolean useMultipleWriteLocations)

Method Detail

processMessageAsync

public rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceResponse> processMessageAsync(com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest request,
                                                                                                         com.microsoft.azure.cosmosdb.rx.internal.IRetryPolicy retryPolicy,
                                                                                                         rx.functions.Func1<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest,rx.Single<com.microsoft.azure.cosmosdb.rx.internal.RxDocumentServiceRequest>> prepareRequestAsyncDelegate)

Specified by:

processMessageAsync in interface IStoreClient