UIMA
  1. UIMA
  2. UIMA-1799

UIMA AS should provide a way to increase prefetch size on a reply queue

    Details

    • Type: Improvement Improvement
    • Status: Closed
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: 2.3AS
    • Fix Version/s: 2.3.1AS
    • Component/s: Async Scaleout
    • Labels:
      None

      Description

      UIMA AS currently provides no way to change prefetch size on a reply queue. A default of 1 is used. This slows down the rate of processing messages by a service. Each UIMA AS service has a dedicated submitter thread whose main job is to deliver a message to a thread pool for processing. Since the submitter thread executes very fast and the prefetch=1 , the submitter thread is constantly waiting for the Broker to deliver the next message. Increasing prefetch forces the Broker to deliver multiple messages to a service which buffers them until the submitter thread is ready. The size of the prefetch should be equal to a scalout factor defined on each reply queue. The default is still 1.

      NOTE: increasing prefetch effects memory requirement for the service. The larger the prefetch the more messages are buffered taking up more memory.

        Activity

        Hide
        Jerry Cwiklik added a comment -

        Modified UIMA AS listener code to override prefetch on a reply queue. The override value comes from the scaleout factor defined on a reply queue in the deployment descriptor.

        Show
        Jerry Cwiklik added a comment - Modified UIMA AS listener code to override prefetch on a reply queue. The override value comes from the scaleout factor defined on a reply queue in the deployment descriptor.
        Hide
        Jerry Cwiklik added a comment -

        Accidentally commented out a chunk of code that registers temp queue listener with InputChannel. This leads to a hang when stopping a service using JMX or from a command line.

        Show
        Jerry Cwiklik added a comment - Accidentally commented out a chunk of code that registers temp queue listener with InputChannel. This leads to a hang when stopping a service using JMX or from a command line.
        Hide
        Jerry Cwiklik added a comment -

        Uncommented code in UimaDefaultMessageListenerContainer.setDestination() that registers temp queue listener with InputChannel.

        Show
        Jerry Cwiklik added a comment - Uncommented code in UimaDefaultMessageListenerContainer.setDestination() that registers temp queue listener with InputChannel.

          People

          • Assignee:
            Jerry Cwiklik
            Reporter:
            Jerry Cwiklik
          • Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development