Package com.azure.messaging.eventhubs

Class EventHubBufferedProducerClientBuilder

java.lang.Object
com.azure.messaging.eventhubs.EventHubBufferedProducerClientBuilder
All Implemented Interfaces:
AmqpTrait<EventHubBufferedProducerClientBuilder>, AzureNamedKeyCredentialTrait<EventHubBufferedProducerClientBuilder>, AzureSasCredentialTrait<EventHubBufferedProducerClientBuilder>, ConfigurationTrait<EventHubBufferedProducerClientBuilder>, ConnectionStringTrait<EventHubBufferedProducerClientBuilder>, TokenCredentialTrait<EventHubBufferedProducerClientBuilder>
public final class EventHubBufferedProducerClientBuilder extends Object implements TokenCredentialTrait<EventHubBufferedProducerClientBuilder>, AzureNamedKeyCredentialTrait<EventHubBufferedProducerClientBuilder>, ConnectionStringTrait<EventHubBufferedProducerClientBuilder>, AzureSasCredentialTrait<EventHubBufferedProducerClientBuilder>, AmqpTrait<EventHubBufferedProducerClientBuilder>, ConfigurationTrait<EventHubBufferedProducerClientBuilder>
Builder used to instantiate EventHubBufferedProducerClient and EventHubBufferedProducerAsyncClient.

To create an instance of EventHubBufferedProducerClient or EventHubBufferedProducerAsyncClient, the following fields are required:

Creating an EventHubBufferedProducerAsyncClient

 TokenCredential credential = new DefaultAzureCredentialBuilder().build();
 EventHubBufferedProducerAsyncClient client = new EventHubBufferedProducerClientBuilder()
     .credential("fully-qualifed-namespace", "event-hub-name", credential)
     .onSendBatchSucceeded(succeededContext -> {
         System.out.println("Successfully published events to: " + succeededContext.getPartitionId());
     })
     .onSendBatchFailed(failedContext -> {
         System.out.printf("Failed to published events to %s. Error: %s%n",
             failedContext.getPartitionId(), failedContext.getThrowable());
     })
     .maxWaitTime(Duration.ofSeconds(60))
     .maxEventBufferLengthPerPartition(1500)
     .buildAsyncClient();

Creating an EventHubBufferedProducerClient

 TokenCredential credential = new DefaultAzureCredentialBuilder().build();
 EventHubBufferedProducerClient client = new EventHubBufferedProducerClientBuilder()
     .connectionString("event-hub-namespace-connection-string", "event-hub-name")
     .onSendBatchSucceeded(succeededContext -> {
         System.out.println("Successfully published events to: " + succeededContext.getPartitionId());
     })
     .onSendBatchFailed(failedContext -> {
         System.out.printf("Failed to published events to %s. Error: %s%n",
             failedContext.getPartitionId(), failedContext.getThrowable());
     })
     .buildClient();
See Also: