[CAMEL-18596] camel-azure-eventhubs consumer is invoking a blocking method

• Type: Improvement
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 3.20.0
• Component/s: camel-azure-eventhubs
• Labels: pull-request-available
• Estimated Complexity: Unknown
• Assignee: Unassigned
• Reporter: Jani Yli-Paavola
• Created: 07/Oct/22 07:04
• Updated: 15/Oct/22 07:59
• Resolved: 15/Oct/22 07:58

Description

EventHubsConsumer and EventHubsCheckpointUpdaterTimerTask are calling a blocking method from Azure EventContext when updating a CheckPoint.

In EventHubsConsumer:

private void processCommit(final Exchange exchange, final EventContext eventContext) {
...
   try {
      var completionCondition = processCheckpoint(exchange);
      if (completionCondition.equals(COMPLETED_BY_SIZE)) {
          eventContext.updateCheckpoint();   <-- HERE
          processedEvents.set(0);
        ...
} 

In EventHubsCheckpointUpdaterTimerTaks

@Override
public void run() {
    if (processedEvents.get() > 0) {
  ...
        eventContext.updateCheckpoint();   <-- HERE
        processedEvents.set(0);
    } 
  ...
} 

And corresponding method in Azure EventContext:

 public void updateCheckpoint() {
        this.updateCheckpointAsync().block();
    }

I suppose EventContext's async update method should be invoked (and subscribed)

Issue Links

• links to: GitHub Pull Request #8492