EventHubPartitionPump Class

Pulls and messages from lease partition from eventhub and sends them to processor.

Inheritance

PartitionPump

EventHubPartitionPump

Constructor

EventHubPartitionPump(host, lease)

Parameters

host

lease

Methods

clean_up_clients_async	Resets the pump swallows all exceptions.
on_closing_async	Overides partition pump on closing.
on_open_async	Eventhub Override for on_open_async.
open_clients_async	Responsible for establishing connection to event hub client throws EventHubsException, IOException, InterruptedException, ExecutionException.

clean_up_clients_async

Resets the pump swallows all exceptions.

async clean_up_clients_async()

on_closing_async

Overides partition pump on closing.

async on_closing_async(reason)

Parameters

reason

str

Required

The reason for the shutdown.

on_open_async

Eventhub Override for on_open_async.

async on_open_async()

open_clients_async

Responsible for establishing connection to event hub client throws EventHubsException, IOException, InterruptedException, ExecutionException.

async open_clients_async()