Package com.github.twitch4j.graphql.command

Class CommandFetchModComments

java.lang.Object
com.netflix.hystrix.HystrixCommand<T>
com.github.twitch4j.graphql.command.BaseCommand<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.Data>
com.github.twitch4j.graphql.command.CommandFetchModComments
All Implemented Interfaces:
com.netflix.hystrix.HystrixExecutable<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.Data>, com.netflix.hystrix.HystrixInvokable<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.Data>, com.netflix.hystrix.HystrixInvokableInfo<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.Data>, com.netflix.hystrix.HystrixObservable<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.Data>
public class CommandFetchModComments extends BaseCommand<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.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

    • CommandFetchModComments

      public CommandFetchModComments(@NonNull @NonNull com.apollographql.apollo.ApolloClient apolloClient, @NonNull @NonNull String channelId, @NonNull @NonNull String targetId, @Nullable @Nullable String after)
      Constructor
      Parameters:
      apolloClient - Apollo Client
      channelId - The id of the channel where the moderator comment should be queried
      targetId - The id of the target user of the moderator comment
      after - Cursor for pagination

  • Method Details

    • getGraphQLCall

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

    • observe

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

    • toObservable

      public rx.Observable<com.github.twitch4j.graphql.internal.FetchModCommentsQuery.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.FetchModCommentsQuery.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)