private def recreateReceiver()

in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala [163:177]

• 12 lines of code
• 2 McCabe index (conditional complexity)

  private def recreateReceiver(seqNo: SequenceNumber): Unit = {
    val taskId = EventHubsUtils.getTaskId
    val startTimeNs = System.nanoTime()
    def elapsedTimeNs = System.nanoTime() - startTimeNs

    if (!ehConf.useExclusiveReceiver) {
      Await.result(closeReceiver(), ehConf.internalOperationTimeout)
    }

    receiver = createReceiver(seqNo)

    val elapsedTimeMs = TimeUnit.NANOSECONDS.toMillis(elapsedTimeNs)
    logInfo(s"(TID $taskId) Finished recreating a receiver for namespaceUri: $namespaceUri EventHubNameAndPartition: " +
      s"$nAndP consumer group: $consumerGroup: $elapsedTimeMs ms")
  }