code: public void run() {
          try {
              ReceivePump.this.receiveAndProcess();
          } catch (final Exception exception) {
              if (TRACE_LOGGER.isErrorEnabled()) {
                  TRACE_LOGGER.error(
                          String.format(Locale.US, "Receive pump for eventHub (%s), consumerGroup (%s), partition (%s) "
                                  + "encountered unrecoverable error and exited with exception %s.",
                                  this.eventHubName, this.consumerGroupName, this.receiver.getPartitionId(), exception.toString()));
              }
  
              throw exception;
          }
      }
docs: entry-point - for runnable