Connecting EventHubBufferedProducerClient to internal classes.#30194

Merged

conniey merged 32 commits intoAzure:conniey/feature/buffered-producerfrom

conniey:connecting-api

Aug 1, 2022

Commits on Aug 1, 2022

Adds flush to PartitionProcessor.
conniey
committed
Adds implementation to methods for async client.
conniey
committed
Fixes build breaks.
conniey
committed
Remove idempotent retries for next release.
conniey
committed
Connect asynchronous client.
conniey
committed
Closing producer client after test case.
conniey
committed
Make default retry options package-private.
conniey
committed
Adding integration test for BufferedProducerAsyncClient.
conniey
committed
Adding partition id to EventDataAggregator
conniey
committed
Adding defaults to builder and documentation.
conniey
committed
Remove localizedBy usages.
conniey
committed
Fixing switchMap logic.
conniey
committed
(WIP) Have PartitionProducer throw an UncheckedInterruptedException when a batch creation occurs while the thread is interrrupted.
conniey
committed
Update PublishResultSubscriber to clear remaining queue items when closed.
conniey
committed
Delay computation of EventDataAggregator to prevent multiple instances being created.
conniey
committed
Adding support for flush().
conniey
committed
Add emitResult constant.
conniey
committed
Complete EventDataAggregator when it is cancelled.
conniey
committed
Implement flush and clean up logging.
conniey
committed
Fix spot bugs issues.
conniey
committed
Add implementation for sync-client.
conniey
committed
Making non-implemented methods package-private.
conniey
committed
Fix build break.
conniey
committed
Add changelog entry.
conniey
committed
Remove unused formatter.
conniey
committed
Updating timeout interval.
conniey
committed
Rename variable to isFlushing.
conniey
committed
Remove else-if
conniey
committed
Adding documentation.
conniey
committed
Update exceptions.
conniey
committed
Clean up failing tests.
conniey
committed
Fixing test failure
conniey
committed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Connecting EventHubBufferedProducerClient to internal classes.#30194

Connecting EventHubBufferedProducerClient to internal classes.#30194
conniey merged 32 commits intoAzure:conniey/feature/buffered-producerfrom
conniey:connecting-api

Commits on Aug 1, 2022

Adds flush to PartitionProcessor.

Adds implementation to methods for async client.

Fixes build breaks.

Remove idempotent retries for next release.

Connect asynchronous client.

Closing producer client after test case.

Make default retry options package-private.

Adding integration test for BufferedProducerAsyncClient.

Adding partition id to EventDataAggregator

Adding defaults to builder and documentation.

Remove localizedBy usages.

Fixing switchMap logic.

(WIP) Have PartitionProducer throw an UncheckedInterruptedException when a batch creation occurs while the thread is interrrupted.

Update PublishResultSubscriber to clear remaining queue items when closed.

Delay computation of EventDataAggregator to prevent multiple instances being created.

Adding support for flush().

Add emitResult constant.

Complete EventDataAggregator when it is cancelled.

Implement flush and clean up logging.

Fix spot bugs issues.

Add implementation for sync-client.

Making non-implemented methods package-private.

Fix build break.

Add changelog entry.

Remove unused formatter.

Updating timeout interval.

Rename variable to isFlushing.

Remove else-if

Adding documentation.

Update exceptions.

Clean up failing tests.

Fixing test failure