Package de.elo.ix.client

Class IXConnFactory.MyWireClient

java.lang.Object
byps.BWire
byps.http.HWireClient
de.elo.ix.client.IXWireClient
de.elo.ix.client.IXConnFactory.MyWireClient
Enclosing class:
IXConnFactory
protected static class IXConnFactory.MyWireClient extends IXWireClient

  • Nested Class Summary

    Nested classes/interfaces inherited from class byps.http.HWireClient

    byps.http.HWireClient.AsyncResultAfterAllRequests, byps.http.HWireClient.MyInputStream, byps.http.HWireClient.RequestToCancel

    Nested classes/interfaces inherited from class byps.BWire

    byps.BWire.InputStreamByteCount, byps.BWire.InputStreamWrapper, byps.BWire.OutputStreamByteCount, byps.BWire.Statistics

  • Field Summary

    Fields inherited from class de.elo.ix.client.IXWireClient

    NEW_HTTP_SESSION

    Fields inherited from class byps.http.HWireClient

    CHUNK_SIZE, httpClient, isDone, isMyThreadPool, log, MAX_STREAM_PART_SIZE, MESSAGEID_CANCEL_ALL_REQUESTS, MESSAGEID_DISCONNECT, openRequestsToCancel, stats, surl, SYSTEM_PROPERTY_HTTP_CLIENT_FACTORY, testAdapter, threadPool, timeoutSecondsClient

    Fields inherited from class byps.BWire

    FLAG_DEFAULT, FLAG_GZIP, flags, rand, sess

  • Constructor Summary

    Constructors
    Constructor
    Description
    MyWireClient(String url, int flags, int timeoutSeconds, HttpCookie sessionCookie, Executor threadPool)
    Create a HWireClient object that counts the requests.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    sendR(byps.BMessage msg, byps.BAsyncResult<byps.BMessage> asyncResult)
    Send message with infinite read timeout.

    Methods inherited from class de.elo.ix.client.IXWireClient

    addRef, done, executeInBackground, getServletPathForNegotiationAndAuthentication, getTimeoutSeconds, getUrlForAuthentication

    Methods inherited from class byps.http.HWireClient

    addRequest, applyNegotiateForUtilityRequests, clearStatistics, createRequestForCancelMessage, createRequestForGetStream, createRequestForMessage, createRequestForPutStream, executeRequest, findRequest, getHttpClient, getHttpCookie, getHttpCookies, getHttpSession, getServletPathForReverseRequest, getStatistics, getStream, getTestAdapter, internalCancelAllRequests, putStreams, removeRequest, replaceAsyncResultOfRequestForPollProcessing, send, sendCancelMessage, setHttpCookie, setHttpCookies, toString

    Methods inherited from class byps.BWire

    bufferFromStream, bufferFromStream, bufferToStream, getFlags, getInvalidUntilMillis, getSessionContext, internalInit, isRetryException, makeMessageId, setSessionContext

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • MyWireClient

      public MyWireClient(String url, int flags, int timeoutSeconds, HttpCookie sessionCookie, Executor threadPool)
      Create a HWireClient object that counts the requests.
      Parameters:
      url - Indexserver URL
      flags - Options forwarded to byps.BWire
      timeoutSeconds - HTTP connection timeout
      sessionCookie - Optional session cookie or null.
      threadPool - Optional thread pool or null.

  • Method Details

    • sendR

      public void sendR(byps.BMessage msg, byps.BAsyncResult<byps.BMessage> asyncResult)
      Description copied from class: byps.BWire
      Send message with infinite read timeout.
      Overrides:
      sendR in class byps.http.HWireClient