Package | Description |
---|---|
com.azure.messaging.eventhubs |
Package containing classes for creating
EventHubProducerAsyncClient ,
EventHubProducerClient ,
EventHubConsumerAsyncClient ,
EventHubConsumerClient , or
EventProcessorClient to perform operations on Azure Event Hubs. |
Modifier and Type | Method and Description |
---|---|
EventProcessorClientBuilder |
EventProcessorClientBuilder.checkpointStore(CheckpointStore checkpointStore)
Sets the
CheckpointStore the EventProcessorClient will use for storing partition ownership and
checkpoint information. |
EventProcessorClientBuilder |
EventProcessorClientBuilder.configuration(Configuration configuration)
Sets the configuration store that is used during construction of the service client.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.connectionString(String connectionString)
Sets the credential information given a connection string to the Event Hub instance.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.connectionString(String connectionString,
String eventHubName)
Sets the credential information given a connection string to the Event Hubs namespace and name to a specific
Event Hub instance.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.consumerGroup(String consumerGroup)
Sets the consumer group name from which the
EventProcessorClient should consume events. |
EventProcessorClientBuilder |
EventProcessorClientBuilder.credential(String fullyQualifiedNamespace,
String eventHubName,
TokenCredential credential)
Sets the credential information for which Event Hub instance to connect to, and how to authorize against it.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.processError(Consumer<ErrorContext> processError)
The function that is called when an error occurs while processing events.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.processEvent(Consumer<EventContext> processEvent)
The function that is called for each event received by this
EventProcessorClient . |
EventProcessorClientBuilder |
EventProcessorClientBuilder.processPartitionClose(Consumer<CloseContext> closePartition)
The function that is called when a processing for a partition stops.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.processPartitionInitialization(Consumer<InitializationContext> initializePartition)
The function that is called before processing starts for a partition.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.proxyOptions(ProxyOptions proxyOptions)
Sets the proxy configuration to use for
EventHubAsyncClient . |
EventProcessorClientBuilder |
EventProcessorClientBuilder.retry(AmqpRetryOptions retryOptions)
Sets the retry policy for
EventHubAsyncClient . |
EventProcessorClientBuilder |
EventProcessorClientBuilder.trackLastEnqueuedEventProperties(boolean trackLastEnqueuedEventProperties)
Sets whether or not the event processor should request information on the last enqueued event on its associated
partition, and track that information as events are received.
|
EventProcessorClientBuilder |
EventProcessorClientBuilder.transportType(AmqpTransportType transport)
Sets the transport type by which all the communication with Azure Event Hubs occurs.
|
Copyright © 2019 Microsoft Corporation. All rights reserved.