Uploaded image for project: 'Apache RocketMQ'
  1. Apache RocketMQ
  2. ROCKETMQ-306

Specify thread's name of DefaultMQProducerImpl's checkExecutor

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Critical
    • Resolution: Invalid
    • Affects Version/s: 4.1.0-incubating
    • Fix Version/s: None
    • Component/s: rocketmq-client
    • Labels:
      None

      Description

      Current the way of initializing checkExecutor didn't specify a threadFactory with provided a meaningful thread name which is very helpful to trace the error information,so we better assign a name of this thread pool.

              this.checkExecutor = new ThreadPoolExecutor(
                  producer.getCheckThreadPoolMinSize(),
                  producer.getCheckThreadPoolMaxSize(),
                  1000 * 60,
                  TimeUnit.MILLISECONDS,
                  this.checkRequestQueue);
      

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                vintagewang Xiaorui Wang
                Reporter:
                acoder2014 acoder2014

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Issue deployment