com.microsoft.azure.cosmosdb.internal.directconnectivity

Class ErrorUtils

java.lang.Object

com.microsoft.azure.cosmosdb.internal.directconnectivity.ErrorUtils

public class ErrorUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
ErrorUtils()

Method Summary

Modifier and Type	Method and Description
protected static rx.Single<String>	getErrorFromStream(rx.Observable<io.netty.buffer.ByteBuf> stream, int contentLength)
protected static rx.Single<String>	getErrorResponseAsync(io.reactivex.netty.protocol.http.client.HttpClientResponse<io.netty.buffer.ByteBuf> responseMessage)
protected static void	logException(String physicalAddress, String activityId)
protected static void	logException(URI physicalAddress, String activityId)
protected static void	logGoneException(String physicalAddress, String activityId)
protected static void	logGoneException(URI physicalAddress, String activityId)

Methods inherited from class java.lang.Object

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

Constructor Detail

ErrorUtils

public ErrorUtils()

Method Detail

getErrorResponseAsync

protected static rx.Single<String> getErrorResponseAsync(io.reactivex.netty.protocol.http.client.HttpClientResponse<io.netty.buffer.ByteBuf> responseMessage)

getErrorFromStream

protected static rx.Single<String> getErrorFromStream(rx.Observable<io.netty.buffer.ByteBuf> stream,
                                                      int contentLength)

logGoneException

protected static void logGoneException(URI physicalAddress,
                                       String activityId)

logGoneException

protected static void logGoneException(String physicalAddress,
                                       String activityId)

logException

protected static void logException(URI physicalAddress,
                                   String activityId)

logException

protected static void logException(String physicalAddress,
                                   String activityId)