Package org.mule.extension.jsonlogger.internal.destinations.amq.client

Class AsyncMuleCourierRestClient

java.lang.Object
com.mulesoft.mq.restclient.client.mq.AbstractCourierRestClient
org.mule.extension.jsonlogger.internal.destinations.amq.client.AsyncMuleCourierRestClient
All Implemented Interfaces:
com.mulesoft.mq.restclient.client.mq.CourierRestClient
public class AsyncMuleCourierRestClient extends com.mulesoft.mq.restclient.client.mq.AbstractCourierRestClient

  • Field Summary

    Fields inherited from class com.mulesoft.mq.restclient.client.mq.AbstractCourierRestClient

    BATCH_SIZE_QUERY_PARAM, DEFAULT_TIMEOUT_MILLIS, EXTRA_RECEIVE_TIMEOUT, LOCK_TTL_QUERY_PARAM, MAX_RETRIES, POOLING_TIME_QUERY_PARAM

  • Constructor Summary

    Constructors
    Constructor
    Description
    AsyncMuleCourierRestClient(String courierApiUrl, com.mulesoft.mq.restclient.client.mq.domain.OAuthCredentials oAuthCredentials, String userAgentInfo, org.mule.runtime.http.api.client.HttpClient httpClient, org.mule.runtime.api.scheduler.Scheduler scheduler)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected static com.mulesoft.mq.restclient.client.Response
    convert(org.mule.runtime.http.api.domain.message.response.HttpResponse httpResponse)
     
    protected com.mulesoft.mq.restclient.client.RequestBuilder
    newRequestBuilder()
     
    protected rx.Observable<com.mulesoft.mq.restclient.client.Response>
    process(com.mulesoft.mq.restclient.client.Request request)
     

    Methods inherited from class com.mulesoft.mq.restclient.client.mq.AbstractCourierRestClient

    ack, ack, dispose, ensureAccessToken, getAccessToken, getBaseUri, getDefaultEnvironmentId, getDefaultOrganizationId, getDestinationLocation, getFallbackConfig, init, logProcessError, logProcessStart, logProcessSuccess, modifyTtl, modifyTtl, nack, nack, obtainBaseURL, receive, send, send, validate, validateAndSetCourierURL, validateInputURL

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AsyncMuleCourierRestClient

      public AsyncMuleCourierRestClient(String courierApiUrl, com.mulesoft.mq.restclient.client.mq.domain.OAuthCredentials oAuthCredentials, String userAgentInfo, org.mule.runtime.http.api.client.HttpClient httpClient, org.mule.runtime.api.scheduler.Scheduler scheduler)

  • Method Details

    • process

      protected rx.Observable<com.mulesoft.mq.restclient.client.Response> process(com.mulesoft.mq.restclient.client.Request request)
      Specified by:
      process in class com.mulesoft.mq.restclient.client.mq.AbstractCourierRestClient

    • convert

      protected static com.mulesoft.mq.restclient.client.Response convert(org.mule.runtime.http.api.domain.message.response.HttpResponse httpResponse)

    • newRequestBuilder

      protected com.mulesoft.mq.restclient.client.RequestBuilder newRequestBuilder()
      Specified by:
      newRequestBuilder in class com.mulesoft.mq.restclient.client.mq.AbstractCourierRestClient