Class CommandFetchUserEmoteSets

java.lang.Object
com.netflix.hystrix.HystrixCommand<T>
com.github.twitch4j.graphql.command.BaseCommand<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>
com.github.twitch4j.graphql.command.CommandFetchUserEmoteSets
All Implemented Interfaces:
com.netflix.hystrix.HystrixExecutable<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>, com.netflix.hystrix.HystrixInvokable<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>, com.netflix.hystrix.HystrixInvokableInfo<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>, com.netflix.hystrix.HystrixObservable<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>

public class CommandFetchUserEmoteSets extends BaseCommand<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>
  • Field Details

    • circuitBreaker

      protected final com.netflix.hystrix.HystrixCircuitBreaker circuitBreaker
    • threadPool

      protected final com.netflix.hystrix.HystrixThreadPool threadPool
    • threadPoolKey

      protected final com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey
    • properties

      protected final com.netflix.hystrix.HystrixCommandProperties properties
    • metrics

      protected final com.netflix.hystrix.HystrixCommandMetrics metrics
    • commandKey

      protected final com.netflix.hystrix.HystrixCommandKey commandKey
    • commandGroup

      protected final com.netflix.hystrix.HystrixCommandGroupKey commandGroup
    • eventNotifier

      protected final com.netflix.hystrix.strategy.eventnotifier.HystrixEventNotifier eventNotifier
    • concurrencyStrategy

      protected final com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy concurrencyStrategy
    • executionHook

      protected final com.netflix.hystrix.strategy.executionhook.HystrixCommandExecutionHook executionHook
    • fallbackSemaphoreOverride

      protected final com.netflix.hystrix.AbstractCommand.TryableSemaphore fallbackSemaphoreOverride
    • fallbackSemaphorePerCircuit

      protected static final ConcurrentHashMap<String,com.netflix.hystrix.AbstractCommand.TryableSemaphore> fallbackSemaphorePerCircuit
    • executionSemaphoreOverride

      protected final com.netflix.hystrix.AbstractCommand.TryableSemaphore executionSemaphoreOverride
    • executionSemaphorePerCircuit

      protected static final ConcurrentHashMap<String,com.netflix.hystrix.AbstractCommand.TryableSemaphore> executionSemaphorePerCircuit
    • timeoutTimer

      protected final AtomicReference<Reference<com.netflix.hystrix.util.HystrixTimer.TimerListener>> timeoutTimer
    • commandState

      protected AtomicReference<com.netflix.hystrix.AbstractCommand.CommandState> commandState
    • threadState

      protected AtomicReference<com.netflix.hystrix.AbstractCommand.ThreadState> threadState
    • executionResult

      protected volatile com.netflix.hystrix.ExecutionResult executionResult
    • isResponseFromCache

      protected volatile boolean isResponseFromCache
    • executionResultAtTimeOfCancellation

      protected volatile com.netflix.hystrix.ExecutionResult executionResultAtTimeOfCancellation
    • commandStartTimestamp

      protected volatile long commandStartTimestamp
    • isCommandTimedOut

      protected final AtomicReference<com.netflix.hystrix.AbstractCommand.TimedOutStatus> isCommandTimedOut
    • endCurrentThreadExecutingCommand

      protected volatile rx.functions.Action0 endCurrentThreadExecutingCommand
    • requestCache

      protected final com.netflix.hystrix.HystrixRequestCache requestCache
    • currentRequestLog

      protected final com.netflix.hystrix.HystrixRequestLog currentRequestLog
    • commandContainsFallback

      protected static ConcurrentHashMap<com.netflix.hystrix.HystrixCommandKey,Boolean> commandContainsFallback
  • Constructor Details

    • CommandFetchUserEmoteSets

      public CommandFetchUserEmoteSets(com.apollographql.apollo.ApolloClient apolloClient, @NonNull @NonNull String userId)
      Constructor
      Parameters:
      apolloClient - Apollo Client
      userId - The ID of the authenticated user
  • Method Details

    • getGraphQLCall

      protected com.apollographql.apollo.ApolloCall<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data> getGraphQLCall()
      Description copied from class: BaseCommand
      Abstract GraphQL Call
      Specified by:
      getGraphQLCall in class BaseCommand<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data>
      Returns:
      ApolloCall
    • observe

      public rx.Observable<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data> observe()
      Specified by:
      observe in interface com.netflix.hystrix.HystrixObservable<R extends Object>
    • toObservable

      public rx.Observable<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data> toObservable()
      Specified by:
      toObservable in interface com.netflix.hystrix.HystrixObservable<R extends Object>
    • shouldNotBeWrapped

      protected boolean shouldNotBeWrapped(Throwable arg0)
    • handleThreadEnd

      protected void handleThreadEnd(com.netflix.hystrix.AbstractCommand<com.github.twitch4j.graphql.internal.FetchUserEmoteSetsQuery.Data> arg0)
    • shouldOutputOnNextEvents

      protected boolean shouldOutputOnNextEvents()
    • getFallbackSemaphore

      protected com.netflix.hystrix.AbstractCommand.TryableSemaphore getFallbackSemaphore()
    • getExecutionSemaphore

      protected com.netflix.hystrix.AbstractCommand.TryableSemaphore getExecutionSemaphore()
    • getCommandGroup

      public com.netflix.hystrix.HystrixCommandGroupKey getCommandGroup()
      Specified by:
      getCommandGroup in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getCommandKey

      public com.netflix.hystrix.HystrixCommandKey getCommandKey()
      Specified by:
      getCommandKey in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getThreadPoolKey

      public com.netflix.hystrix.HystrixThreadPoolKey getThreadPoolKey()
      Specified by:
      getThreadPoolKey in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getMetrics

      public com.netflix.hystrix.HystrixCommandMetrics getMetrics()
      Specified by:
      getMetrics in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getProperties

      public com.netflix.hystrix.HystrixCommandProperties getProperties()
      Specified by:
      getProperties in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • decomposeException

      protected Throwable decomposeException(Exception arg0)
    • getCacheKey

      protected String getCacheKey()
    • getPublicCacheKey

      public String getPublicCacheKey()
      Specified by:
      getPublicCacheKey in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isRequestCachingEnabled

      protected boolean isRequestCachingEnabled()
    • getLogMessagePrefix

      protected String getLogMessagePrefix()
    • isCircuitBreakerOpen

      public boolean isCircuitBreakerOpen()
      Specified by:
      isCircuitBreakerOpen in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isExecutionComplete

      public boolean isExecutionComplete()
      Specified by:
      isExecutionComplete in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isExecutedInThread

      public boolean isExecutedInThread()
      Specified by:
      isExecutedInThread in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isSuccessfulExecution

      public boolean isSuccessfulExecution()
      Specified by:
      isSuccessfulExecution in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isFailedExecution

      public boolean isFailedExecution()
      Specified by:
      isFailedExecution in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getFailedExecutionException

      public Throwable getFailedExecutionException()
      Specified by:
      getFailedExecutionException in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getExecutionException

      public Throwable getExecutionException()
    • isResponseFromFallback

      public boolean isResponseFromFallback()
      Specified by:
      isResponseFromFallback in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isResponseTimedOut

      public boolean isResponseTimedOut()
      Specified by:
      isResponseTimedOut in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isResponseShortCircuited

      public boolean isResponseShortCircuited()
      Specified by:
      isResponseShortCircuited in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isResponseFromCache

      public boolean isResponseFromCache()
      Specified by:
      isResponseFromCache in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isResponseSemaphoreRejected

      public boolean isResponseSemaphoreRejected()
      Specified by:
      isResponseSemaphoreRejected in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isResponseThreadPoolRejected

      public boolean isResponseThreadPoolRejected()
      Specified by:
      isResponseThreadPoolRejected in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • isResponseRejected

      public boolean isResponseRejected()
      Specified by:
      isResponseRejected in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getExecutionEvents

      public List<com.netflix.hystrix.HystrixEventType> getExecutionEvents()
      Specified by:
      getExecutionEvents in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getNumberEmissions

      public int getNumberEmissions()
      Specified by:
      getNumberEmissions in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getNumberFallbackEmissions

      public int getNumberFallbackEmissions()
      Specified by:
      getNumberFallbackEmissions in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getNumberCollapsed

      public int getNumberCollapsed()
      Specified by:
      getNumberCollapsed in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getOriginatingCollapserKey

      public com.netflix.hystrix.HystrixCollapserKey getOriginatingCollapserKey()
      Specified by:
      getOriginatingCollapserKey in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getExecutionTimeInMilliseconds

      public int getExecutionTimeInMilliseconds()
      Specified by:
      getExecutionTimeInMilliseconds in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getCommandRunStartTimeInNanos

      public long getCommandRunStartTimeInNanos()
      Specified by:
      getCommandRunStartTimeInNanos in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getEventCounts

      public com.netflix.hystrix.ExecutionResult.EventCounts getEventCounts()
      Specified by:
      getEventCounts in interface com.netflix.hystrix.HystrixInvokableInfo<R extends Object>
    • getExceptionFromThrowable

      protected Exception getExceptionFromThrowable(Throwable arg0)