A B C D E F G H I J L M N O P Q R S T U V W
All Classes All Packages

A

ACCEPTED - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

acquireToken(String, String, Object) - Method in interface com.microsoft.azure.eventhubs.AzureActiveDirectoryTokenProvider.AuthenticationCallback

addTransportLayers(Event, TransportInternal) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

addTransportLayers(Event, TransportInternal) - Method in class com.microsoft.azure.eventhubs.impl.WebSocketConnectionHandler

addTransportLayers(Event, TransportInternal) - Method in class com.microsoft.azure.eventhubs.impl.WebSocketProxyConnectionHandler

AMQP - com.microsoft.azure.eventhubs.TransportType

AMQP over TCP.

AMQP_ANNOTATION_FORMAT - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_BATCH_MESSAGE_FORMAT - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_ABSOLUTE_EXPRITY_TIME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_CONTENT_ENCODING - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_CONTENT_TYPE - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_CORRELATION_ID - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_CREATION_TIME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_GROUP_ID - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_GROUP_SEQUENCE - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_MESSAGE_ID - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_REPLY_TO - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_REPLY_TO_GROUP_ID - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_SUBJECT - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_TO - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_PROPERTY_USER_ID - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

AMQP_REQUEST_FAILED_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

AMQP_WEB_SOCKETS - com.microsoft.azure.eventhubs.TransportType

AMQP over Web Sockets.

AmqpConnection - Interface in com.microsoft.azure.eventhubs.impl

AmqpConstants - Class in com.microsoft.azure.eventhubs.impl

AmqpErrorCode - Class in com.microsoft.azure.eventhubs.impl

AmqpErrorCode() - Constructor for class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

AmqpException - Exception in com.microsoft.azure.eventhubs.impl

All AmqpExceptions - which EventHub client handles internally.

AmqpException(ErrorCondition) - Constructor for exception com.microsoft.azure.eventhubs.impl.AmqpException

AmqpLink - Interface in com.microsoft.azure.eventhubs.impl

AmqpLinkDetachForced - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

AmqpReceiver - Interface in com.microsoft.azure.eventhubs.impl

AmqpResponseCode - Enum in com.microsoft.azure.eventhubs.impl

AMQPS_PORT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

AmqpSender - Interface in com.microsoft.azure.eventhubs.impl

AmqpUtil - Class in com.microsoft.azure.eventhubs.impl

APACHE - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

ARGUMENT_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

ARGUMENT_OUT_OF_RANGE_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

authentication() - Method in class com.microsoft.azure.eventhubs.ProxyConfiguration

Gets the proxy authentication type to use.

AuthorizationFailedException - Exception in com.microsoft.azure.eventhubs

Authorization failed exception is thrown when error is encountered during authorizing user's permission to run the intended operations.

AuthorizationFailedException(String) - Constructor for exception com.microsoft.azure.eventhubs.AuthorizationFailedException

Constructor for the exception class

AzureActiveDirectoryTokenProvider - Class in com.microsoft.azure.eventhubs

AzureActiveDirectoryTokenProvider(AzureActiveDirectoryTokenProvider.AuthenticationCallback, String, Object) - Constructor for class com.microsoft.azure.eventhubs.AzureActiveDirectoryTokenProvider

AzureActiveDirectoryTokenProvider.AuthenticationCallback - Interface in com.microsoft.azure.eventhubs

B

BAD_REQUEST - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

BaseLinkHandler - Class in com.microsoft.azure.eventhubs.impl

BaseLinkHandler(AmqpLink, String) - Constructor for class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

BASIC - com.microsoft.azure.eventhubs.ProxyConfiguration.ProxyAuthenticationType

Authenticates against proxy with basic authentication scheme.

BatchOptions - Class in com.microsoft.azure.eventhubs

BatchOptions is used to create EventDataBatches.

BatchOptions() - Constructor for class com.microsoft.azure.eventhubs.BatchOptions

build() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

C

CBS_ADDRESS - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

clearMessage() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

ClientConstants - Class in com.microsoft.azure.eventhubs.impl

close() - Method in interface com.microsoft.azure.eventhubs.EventHubClient

close() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

close() - Method in interface com.microsoft.azure.eventhubs.PartitionSender

close() - Method in class com.microsoft.azure.eventhubs.ProxyConfiguration

close(OperationResult<Void, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

close(ReactorDispatcher, OperationResult<Void, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.FaultTolerantObject

CLOSED - com.microsoft.azure.eventhubs.impl.IOObject.IOObjectState

closeSync() - Method in interface com.microsoft.azure.eventhubs.EventHubClient

closeSync() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

closeSync() - Method in interface com.microsoft.azure.eventhubs.PartitionSender

CLOSING - com.microsoft.azure.eventhubs.impl.IOObject.IOObjectState

com.microsoft.azure.eventhubs - package com.microsoft.azure.eventhubs

com.microsoft.azure.eventhubs.impl - package com.microsoft.azure.eventhubs.impl

COMMUNICATION_EXCEPTION_GENERIC_MESSAGE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

CommunicationException - Exception in com.microsoft.azure.eventhubs

This exception is thrown when there is a client side connectivity issue.

CommunicationException(String, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.CommunicationException

compareTo(EventData) - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

ConnectionForced - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

ConnectionHandler - Class in com.microsoft.azure.eventhubs.impl

ConnectionHandler(AmqpConnection, String, SslDomain.VerifyMode) - Constructor for class com.microsoft.azure.eventhubs.impl.ConnectionHandler

ConnectionStringBuilder - Class in com.microsoft.azure.eventhubs

ConnectionStringBuilder can be used to construct a connection string which can establish communication with Event Hub instances.

ConnectionStringBuilder() - Constructor for class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Creates an empty ConnectionStringBuilder.

ConnectionStringBuilder(String) - Constructor for class com.microsoft.azure.eventhubs.ConnectionStringBuilder

ConnectionString format: Endpoint=sb://namespace_DNS_Name;EntityPath=EVENT_HUB_NAME;SharedAccessKeyName=SHARED_ACCESS_KEY_NAME;SharedAccessKey=SHARED_ACCESS_KEY

create(byte[]) - Static method in interface com.microsoft.azure.eventhubs.EventData

Construct EventData to Send to EventHubs.

create(byte[], int, int) - Static method in interface com.microsoft.azure.eventhubs.EventData

Construct EventData to Send to EventHubs.

create(MessagingFactory, String, String) - Static method in class com.microsoft.azure.eventhubs.impl.MessageSender

create(MessagingFactory, String, String, int, ReceiverSettingsProvider) - Static method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

create(ReactorHandler, int, String) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.ReactorFactory

create(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration) - Static method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

create(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration, Duration) - Static method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

create(URI, String, ITokenProvider, ScheduledExecutorService, EventHubClientOptions) - Static method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

create(ByteBuffer) - Static method in interface com.microsoft.azure.eventhubs.EventData

Construct EventData to Send to EventHubs.

create(Duration) - Static method in class com.microsoft.azure.eventhubs.impl.TimeoutTracker

create(Duration, String) - Static method in class com.microsoft.azure.eventhubs.impl.TimeoutTracker

createBatch() - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Creates an Empty Collection of EventData.

createBatch() - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Creates an Empty Collection of EventData.

createBatch(BatchOptions) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Creates an Empty Collection of EventData.

createBatch(BatchOptions) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

createBatch(BatchOptions) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Creates an Empty Collection of EventData.

createEpochReceiver(String, String, EventPosition, long) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Create a Epoch based EventHub receiver with given partition id and start receiving from the beginning of the partition stream.

createEpochReceiver(String, String, EventPosition, long) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

createEpochReceiver(String, String, EventPosition, long, ReceiverOptions) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Create a Epoch based EventHub receiver with given partition id and start receiving from the beginning of the partition stream.

createEpochReceiver(String, String, EventPosition, long, ReceiverOptions) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

createEpochReceiverSync(String, String, EventPosition, long) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createEpochReceiver(String, String, EventPosition, long).

createEpochReceiverSync(String, String, EventPosition, long, ReceiverOptions) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createEpochReceiver(String, String, EventPosition, long).

createFromConnectionString(String, RetryPolicy, ScheduledExecutorService) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Factory method to create an instance of EventHubClient using the supplied connectionString.

createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, MessagingFactory.ReactorFactory, ProxyConfiguration, Duration) - Static method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Factory method to create an instance of EventHubClient using the supplied connectionString.

createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration) - Static method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration, Duration) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Factory method to create an instance of EventHubClient using the supplied connectionString.

createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration, Duration) - Static method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

createFromConnectionString(String, ScheduledExecutorService) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Factory method to create an instance of EventHubClient using the supplied connectionString.

createFromConnectionString(String, ScheduledExecutorService) - Static method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

createFromConnectionStringSync(String, RetryPolicy, ScheduledExecutorService) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createFromConnectionString(String, ScheduledExecutorService).

createFromConnectionStringSync(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration).

createFromConnectionStringSync(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration, Duration) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createFromConnectionString(String, RetryPolicy, ScheduledExecutorService, ProxyConfiguration, Duration).

createFromConnectionStringSync(String, ScheduledExecutorService) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createFromConnectionString(String, ScheduledExecutorService).

createPartitionSender(String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Create a PartitionSender which can publish EventData's directly to a specific EventHub partition (sender type iii.

createPartitionSender(String) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

createPartitionSenderSync(String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createPartitionSender(String).

createReceiver(String, String, EventPosition) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Create the EventHub receiver with given partition id and start receiving from the specified starting offset.

createReceiver(String, String, EventPosition) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

createReceiver(String, String, EventPosition, ReceiverOptions) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Create the EventHub receiver with given partition id and start receiving from the specified starting offset.

createReceiver(String, String, EventPosition, ReceiverOptions) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

createReceiverSync(String, String, EventPosition) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createReceiver(String, String, EventPosition).

createReceiverSync(String, String, EventPosition, ReceiverOptions) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.createReceiver(String, String, EventPosition).

createWithAzureActiveDirectory(URI, String, AzureActiveDirectoryTokenProvider.AuthenticationCallback, String, ScheduledExecutorService, EventHubClientOptions) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Factory method to create an instance of EventHubClient using the supplied namespace endpoint address, eventhub name and authentication mechanism.

createWithTokenProvider(URI, String, ITokenProvider, ScheduledExecutorService, EventHubClientOptions) - Static method in interface com.microsoft.azure.eventhubs.EventHubClient

Factory method to create an instance of EventHubClient using the supplied namespace endpoint address, eventhub name and authentication mechanism.

credentials() - Method in class com.microsoft.azure.eventhubs.ProxyConfiguration

Gets credentials to authenticate against proxy with.

CURRENT_JAVACLIENT_VERSION - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

CustomIOHandler - Class in com.microsoft.azure.eventhubs.impl

CustomIOHandler(String) - Constructor for class com.microsoft.azure.eventhubs.impl.CustomIOHandler

D

DEFAULT_CONSUMER_GROUP_NAME - Static variable in interface com.microsoft.azure.eventhubs.EventHubClient

DEFAULT_IS_TRANSIENT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

DEFAULT_MAX_RETRY_COUNT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

DEFAULT_PREFETCH_COUNT - Static variable in interface com.microsoft.azure.eventhubs.PartitionReceiver

DEFAULT_RETRY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

DEFAULT_RETRY_MAX_BACKOFF - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

DEFAULT_RETRY_MIN_BACKOFF - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

DefaultOperationTimeout - Static variable in class com.microsoft.azure.eventhubs.impl.MessagingFactory

deregisterForConnectionError(Link) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpConnection

deregisterForConnectionError(Link) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

DIGEST - com.microsoft.azure.eventhubs.ProxyConfiguration.ProxyAuthenticationType

Authenticates against proxy with digest access authentication.

DispatchHandler - Class in com.microsoft.azure.eventhubs.impl

DispatchHandler() - Constructor for class com.microsoft.azure.eventhubs.impl.DispatchHandler

E

elapsed() - Method in class com.microsoft.azure.eventhubs.impl.TimeoutTracker

EMPTY - Static variable in class com.microsoft.azure.eventhubs.impl.StringUtil

ENABLE_RECEIVER_RUNTIME_METRIC_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

ENQUEUED_TIME_UTC - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

ENQUEUED_TIME_UTC_ANNOTATION_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

ENTITY_DISABLED_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

EPOCH - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

equals(Object) - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

ErrorContext - Class in com.microsoft.azure.eventhubs

ErrorContext(String) - Constructor for class com.microsoft.azure.eventhubs.ErrorContext

EventData - Interface in com.microsoft.azure.eventhubs

The data structure encapsulating the Event being sent-to and received-from EventHubs.

EventData.SystemProperties - Class in com.microsoft.azure.eventhubs

EventDataBatch - Interface in com.microsoft.azure.eventhubs

Helper for creating a batch/collection of EventData objects to be used while Sending to EventHubs

EventDataImpl - Class in com.microsoft.azure.eventhubs.impl

EventDataImpl(byte[]) - Constructor for class com.microsoft.azure.eventhubs.impl.EventDataImpl

EventDataImpl(byte[], int, int) - Constructor for class com.microsoft.azure.eventhubs.impl.EventDataImpl

EventDataImpl(ByteBuffer) - Constructor for class com.microsoft.azure.eventhubs.impl.EventDataImpl

EventHubClient - Interface in com.microsoft.azure.eventhubs

Anchor class - all EventHub client operations STARTS here.

EventHubClientImpl - Class in com.microsoft.azure.eventhubs.impl

EventHubClientOptions - Class in com.microsoft.azure.eventhubs

Convenient container for options for creating an EventHubClient All options default to not specified (null)

EventHubClientOptions() - Constructor for class com.microsoft.azure.eventhubs.EventHubClientOptions

Create with all defaults

EventHubException - Exception in com.microsoft.azure.eventhubs

This is the base exception that service bus will produce for all error cases.

EventHubException(boolean, String) - Constructor for exception com.microsoft.azure.eventhubs.EventHubException

EventHubException(boolean, String, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.EventHubException

EventHubException(boolean, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.EventHubException

EventHubRuntimeInformation - Class in com.microsoft.azure.eventhubs

Holds information about Event Hubs which can come handy while performing data-plane operations like EventHubClient.createPartitionSender(String) and EventHubClient.createReceiver(String, String, EventPosition)

EventHubRuntimeInformation(String, Instant, int, String[]) - Constructor for class com.microsoft.azure.eventhubs.EventHubRuntimeInformation

EVENTHUBS_AUDIENCE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

EventPosition - Interface in com.microsoft.azure.eventhubs

Defines a position of an EventData in the event hub partition.

EventPositionImpl - Class in com.microsoft.azure.eventhubs.impl

ExceptionUtil - Class in com.microsoft.azure.eventhubs.impl

ExceptionUtil() - Constructor for class com.microsoft.azure.eventhubs.impl.ExceptionUtil

ExceptionUtil.SyncFactory<T> - Interface in com.microsoft.azure.eventhubs.impl

ExceptionUtil.SyncFactoryVoid - Interface in com.microsoft.azure.eventhubs.impl

ExceptionUtil.SyncFactoryWithIllegalArgException<T> - Interface in com.microsoft.azure.eventhubs.impl

ExceptionUtil.SyncFactoryWithIOException<T> - Interface in com.microsoft.azure.eventhubs.impl

execute() - Method in interface com.microsoft.azure.eventhubs.impl.ExceptionUtil.SyncFactory

execute() - Method in interface com.microsoft.azure.eventhubs.impl.ExceptionUtil.SyncFactoryVoid

execute() - Method in interface com.microsoft.azure.eventhubs.impl.ExceptionUtil.SyncFactoryWithIllegalArgException

execute() - Method in interface com.microsoft.azure.eventhubs.impl.ExceptionUtil.SyncFactoryWithIOException

F

FaultTolerantObject<T extends IOObject> - Class in com.microsoft.azure.eventhubs.impl

FaultTolerantObject(Operation<T>, Operation<Void>, String, String) - Constructor for class com.microsoft.azure.eventhubs.impl.FaultTolerantObject

FORBIDDEN - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

FRAMEWORK - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

FRAMEWORK_INFO - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

fromEndOfStream() - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Returns the position for the end of a stream.

fromEndOfStream() - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

fromEnqueuedTime(Instant) - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Creates a position at the given Instant.

fromEnqueuedTime(Instant) - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

fromOffset(String) - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Creates a position at the given offset.

fromOffset(String) - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

fromOffset(String, boolean) - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Creates a position at the given offset.

fromOffset(String, boolean) - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

fromSequenceNumber(Long) - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Creates a position at the given sequence number.

fromSequenceNumber(Long) - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

fromSequenceNumber(Long, boolean) - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Creates a position at the given sequence number.

fromSequenceNumber(Long, boolean) - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

fromStartOfStream() - Static method in interface com.microsoft.azure.eventhubs.EventPosition

Returns the position for the start of a stream.

fromStartOfStream() - Static method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

G

generateSharedAccessSignature(String, String, String, Duration) - Static method in class com.microsoft.azure.eventhubs.impl.SharedAccessSignatureTokenProvider

get() - Method in class com.microsoft.azure.eventhubs.impl.PassByRef

getAmqpConnection() - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

getAudience() - Method in class com.microsoft.azure.eventhubs.SecurityToken

Get the audience of the token.

getAuthentication() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Get the authentication type in the Connection String.

getBeginSequenceNumber() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getBytes() - Method in interface com.microsoft.azure.eventhubs.EventData

Get Actual Payload/Data wrapped by EventData.

getBytes() - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

getCBSChannel() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getContext() - Method in exception com.microsoft.azure.eventhubs.EventHubException

getContext() - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

getContext() - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

getContext() - Method in class com.microsoft.azure.eventhubs.impl.TimeoutTracker

getCreatedAt() - Method in class com.microsoft.azure.eventhubs.EventHubRuntimeInformation

Time at which Event Hub was created at.

getDataSerializedSize(Message) - Static method in class com.microsoft.azure.eventhubs.impl.AmqpUtil

getDefault() - Static method in class com.microsoft.azure.eventhubs.RetryPolicy

getDesiredCapabilities() - Method in interface com.microsoft.azure.eventhubs.impl.ReceiverSettingsProvider

getEncodedMessageSize() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

getEndpoint() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Get the endpoint which can be used to connect to the EventHub instance.

getEnqueuedTime() - Method in class com.microsoft.azure.eventhubs.EventData.SystemProperties

getEnqueuedTime() - Method in interface com.microsoft.azure.eventhubs.EventPosition

Gets the enqueued time.

getEnqueuedTime() - Method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

getEpoch() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Get the epoch value that this receiver is currently using for partition ownership.

getError() - Method in exception com.microsoft.azure.eventhubs.impl.AmqpException

getEventHubName() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Get the entity path value from the connection string.

getEventHubName() - Method in interface com.microsoft.azure.eventhubs.EventHubClient

getEventHubName() - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

getEventHubPath() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getEventPosition() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Get the EventPosition that corresponds to an EventData which was returned last by the receiver.

getExceptionFromCompletedFuture(CompletableFuture<?>) - Static method in class com.microsoft.azure.eventhubs.impl.ExceptionUtil

getFilter(Message) - Method in interface com.microsoft.azure.eventhubs.impl.ReceiverSettingsProvider

getFirst(Iterable<T>) - Static method in class com.microsoft.azure.eventhubs.impl.IteratorUtil

getHostName() - Method in interface com.microsoft.azure.eventhubs.impl.AmqpConnection

Host name intended to be used on Amqp Connection Open frame

getHostName() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getId() - Method in interface com.microsoft.azure.eventhubs.impl.IOObject

getId() - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

getIdentifier() - Method in class com.microsoft.azure.eventhubs.ReceiverOptions

Gets the identifier of the PartitionReceiver

getInclusiveFlag() - Method in interface com.microsoft.azure.eventhubs.EventPosition

Gets the inclusive value.

getInclusiveFlag() - Method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

getIsEmpty() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getIsOpen() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Determine the current state of the receiver.

getIsTransient() - Method in exception com.microsoft.azure.eventhubs.EventHubException

A boolean indicating if the exception is a transient error or not.

getLast(Iterator<T>) - Static method in class com.microsoft.azure.eventhubs.impl.IteratorUtil

getLastEnqueuedOffset() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getLastEnqueuedOffset() - Method in class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

The last enqueued EventData's offset on this EventHubs Partition

getLastEnqueuedSequenceNumber() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getLastEnqueuedSequenceNumber() - Method in class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

The last enqueued EventData's sequence number on this EventHubs Partition

getLastEnqueuedTime() - Method in class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

The last enqueued EventData's enqueue time stamp on this EventHubs Partition

getLastEnqueuedTimeUtc() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getLastKnownError() - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

getLastKnownError() - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

getLastKnownException() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

getLastReceivedTime() - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

getLinkName(Session) - Static method in class com.microsoft.azure.eventhubs.impl.TrackingUtil

getManagementChannel() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getMaxEventCount() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiveHandler

Maximum number of EventData to supply while invoking PartitionReceiveHandler.onReceive(Iterable)

getMaxFrameSize() - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

getMaxFrameSize() - Method in class com.microsoft.azure.eventhubs.impl.WebSocketConnectionHandler

getMaximumSilentTime() - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Gets the maximum silent time in seconds.

getMaxMessageSize() - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

getMessage() - Method in exception com.microsoft.azure.eventhubs.EventHubException

getMessage() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

getMessageFormat() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

getNamespaceName() - Method in class com.microsoft.azure.eventhubs.ErrorContext

getNextRetryInterval(String, Exception, Duration) - Method in class com.microsoft.azure.eventhubs.RetryPolicy

Gets the Interval after which nextRetry should be done.

getNoRetry() - Static method in class com.microsoft.azure.eventhubs.RetryPolicy

getObject() - Method in interface com.microsoft.azure.eventhubs.EventData

Use this method only if, the sender could be sending messages using third-party AMQP libraries.

getObject() - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

getOffset() - Method in class com.microsoft.azure.eventhubs.EventData.SystemProperties

getOffset() - Method in interface com.microsoft.azure.eventhubs.EventPosition

Gets the offset.

getOffset() - Method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

getOperationTimeout() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

OperationTimeout is applied in erroneous situations to notify the caller about the relevant EventHubException

getOperationTimeout() - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Get the operation timeout.

getOperationTimeout() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getPartitionCount() - Method in class com.microsoft.azure.eventhubs.EventHubRuntimeInformation

Number of partitions in the Event Hub.

getPartitionId() - Method in interface com.microsoft.azure.eventhubs.impl.ReceivePump.IPartitionReceiver

getPartitionId() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Get EventHubs partition identifier.

getPartitionId() - Method in class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

getPartitionId() - Method in interface com.microsoft.azure.eventhubs.PartitionSender

The partition id that will receive events from this sender.

getPartitionId() - Method in class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

The Event Hubs partition id to which this information belongs to

getPartitionIds() - Method in class com.microsoft.azure.eventhubs.EventHubRuntimeInformation

List of Partition identifiers of the Event Hub.

getPartitionKey() - Method in class com.microsoft.azure.eventhubs.EventData.SystemProperties

getPartitionRuntimeInformation(String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Retrieves dynamic information about a partition of an event hub (see PartitionRuntimeInformation for details.

getPartitionRuntimeInformation(String) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

getPath() - Method in class com.microsoft.azure.eventhubs.EventHubRuntimeInformation

Event Hub name

getPrefetchCount() - Method in class com.microsoft.azure.eventhubs.ReceiverOptions

Get Prefetch Count.

getProperties() - Method in interface com.microsoft.azure.eventhubs.EventData

Application property bag

getProperties() - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

getProperties() - Method in interface com.microsoft.azure.eventhubs.impl.ReceiverSettingsProvider

getProtocolPort() - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

Port used on connection open frame

getProtocolPort() - Method in class com.microsoft.azure.eventhubs.impl.WebSocketConnectionHandler

getProxyConfiguration() - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Gets the proxy configuration for this set of options.

getPublisher() - Method in class com.microsoft.azure.eventhubs.EventData.SystemProperties

getRandomString(String) - Static method in class com.microsoft.azure.eventhubs.impl.StringUtil

getReactorDispatcher() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getReactorDispatcher() - Method in class com.microsoft.azure.eventhubs.impl.ReactorHandler

getReceiveLink() - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

getReceivePath() - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

getReceiverRuntimeMetricEnabled() - Method in class com.microsoft.azure.eventhubs.ReceiverOptions

Knob to enable/disable runtime metric of the receiver.

getReceiveTimeout() - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

getReceiveTimeout() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

getRemoteHostName() - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

HostName to be used for socket creation.

getRemoteHostName() - Method in class com.microsoft.azure.eventhubs.impl.WebSocketProxyConnectionHandler

getRemotePort() - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

port used to create socket.

getRemotePort() - Method in class com.microsoft.azure.eventhubs.impl.WebSocketProxyConnectionHandler

getRetrievalTime() - Method in class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

The value indicating when this information was retrieved from the Event Hubs service

getRetryCount(String) - Method in class com.microsoft.azure.eventhubs.RetryPolicy

getRetryPolicy() - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Get the retry policy

getRetryPolicy() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getRuntimeInformation() - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Retrieves general information about an event hub (see EventHubRuntimeInformation for details).

getRuntimeInformation() - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

getRuntimeInformation() - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Gets the temporal ReceiverRuntimeInformation for this EventHub partition.

getSasKey() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Get the shared access policy key value from the connection string

getSasKeyName() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Get the shared access policy owner name from the connection string

getSendLink() - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

getSendPath() - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

getSequenceNumber() - Method in class com.microsoft.azure.eventhubs.EventData.SystemProperties

getSequenceNumber() - Method in interface com.microsoft.azure.eventhubs.EventPosition

Gets the sequence number.

getSequenceNumber() - Method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

getSession(String, Consumer<Session>, BiConsumer<ErrorCondition, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getSession(String, Consumer<Session>, BiConsumer<ErrorCondition, Exception>) - Method in interface com.microsoft.azure.eventhubs.impl.SessionProvider

getSharedAccessSignature() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Get the shared access signature (also referred as SAS Token) from the connection string

getSize() - Method in interface com.microsoft.azure.eventhubs.EventDataBatch

Get the number of events present in this EventDataBatch

getState() - Method in interface com.microsoft.azure.eventhubs.impl.IOObject

getState() - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

getSystemProperties() - Method in interface com.microsoft.azure.eventhubs.EventData

SystemProperties that are populated by EventHubService.

getSystemProperties() - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

getTimeoutTask() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

getTimeoutTracker() - Method in class com.microsoft.azure.eventhubs.impl.WorkItem

getToken() - Method in class com.microsoft.azure.eventhubs.SecurityToken

Get the token itself.

getToken(String, Duration) - Method in class com.microsoft.azure.eventhubs.AzureActiveDirectoryTokenProvider

getToken(String, Duration) - Method in class com.microsoft.azure.eventhubs.impl.SharedAccessSignatureTokenProvider

getToken(String, Duration) - Method in interface com.microsoft.azure.eventhubs.ITokenProvider

getToken(String, Duration) - Method in class com.microsoft.azure.eventhubs.ManagedIdentityTokenProvider

getTokenProvider() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

getTokenType() - Method in class com.microsoft.azure.eventhubs.SecurityToken

Get the type of the token.

getTransportType() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

TransportType on which all the communication for the EventHub objects created using this ConnectionString.

getTransportType() - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Get the transport type

getValue() - Method in enum com.microsoft.azure.eventhubs.impl.AmqpResponseCode

getWork() - Method in class com.microsoft.azure.eventhubs.impl.WorkItem

H

hashCode() - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

hasUserDefinedCredentials() - Method in class com.microsoft.azure.eventhubs.ProxyConfiguration

Gets whether the user has defined credentials.

HTTPS_PORT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

HTTPS_URI_FORMAT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

I

IllegalConnectionStringFormatException - Exception in com.microsoft.azure.eventhubs

This exception is thrown when the connection string provided does not meet the requirement for connection.

IllegalEntityException - Exception in com.microsoft.azure.eventhubs

This exception is thrown for the following reasons: When the entity user attempted to connect does not exist The entity user wants to connect is disabled

IllegalEntityException(String) - Constructor for exception com.microsoft.azure.eventhubs.IllegalEntityException

IllegalEntityException(String, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.IllegalEntityException

IllegalEntityException(Throwable) - Constructor for exception com.microsoft.azure.eventhubs.IllegalEntityException

IllegalState - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

incrementRetryCount(String) - Method in class com.microsoft.azure.eventhubs.RetryPolicy

INTERNAL_SERVER_ERROR - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

InternalError - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

invoke(int, DispatchHandler) - Method in class com.microsoft.azure.eventhubs.impl.ReactorDispatcher

invoke(DispatchHandler) - Method in class com.microsoft.azure.eventhubs.impl.ReactorDispatcher

IOObject - Interface in com.microsoft.azure.eventhubs.impl

IOObject.IOObjectState - Enum in com.microsoft.azure.eventhubs.impl

isNullOrEmpty(String) - Static method in class com.microsoft.azure.eventhubs.impl.StringUtil

isNullOrWhiteSpace(String) - Static method in class com.microsoft.azure.eventhubs.impl.StringUtil

isProxyAddressConfigured() - Method in class com.microsoft.azure.eventhubs.ProxyConfiguration

Gets whether the proxy address has been configured.

isRetryableException(Exception) - Static method in class com.microsoft.azure.eventhubs.RetryPolicy

isRunning() - Method in class com.microsoft.azure.eventhubs.impl.ReceivePump

isWaitingForAck() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

IteratorUtil - Class in com.microsoft.azure.eventhubs.impl

ITokenProvider - Interface in com.microsoft.azure.eventhubs

J

JsonSecurityToken - Class in com.microsoft.azure.eventhubs

Extend SecurityToken with some specifics for a JSon Web Token

JsonSecurityToken(String, String) - Constructor for class com.microsoft.azure.eventhubs.JsonSecurityToken

Construct from a raw JWT.

JWT_TOKEN_TYPE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

L

LAST_ENQUEUED_OFFSET - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

LAST_ENQUEUED_SEQUENCE_NUMBER - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

LAST_ENQUEUED_TIME_UTC - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

LINK_ERROR_DELAY_MILLIS - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

M

MANAGED_IDENTITY_AUTHENTICATION - Static variable in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

ManagedIdentityTokenProvider - Class in com.microsoft.azure.eventhubs

ManagedIdentityTokenProvider() - Constructor for class com.microsoft.azure.eventhubs.ManagedIdentityTokenProvider

MANAGEMENT_ADDRESS - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_ENTITY_NAME_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_ENTITY_TYPE_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_EVENTHUB_ENTITY_TYPE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_OPERATION_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_PARTITION_ENTITY_TYPE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_PARTITION_NAME_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESPONSE_ERROR_CONDITION - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_BEGIN_SEQUENCE_NUMBER - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_CREATED_AT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_LAST_ENQUEUED_OFFSET - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_LAST_ENQUEUED_SEQUENCE_NUMBER - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_LAST_ENQUEUED_TIME_UTC - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_PARTITION_COUNT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_PARTITION_IDS - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_RESULT_PARTITION_IS_EMPTY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_SECURITY_TOKEN_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_STATUS_CODE_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MANAGEMENT_STATUS_DESCRIPTION_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MAX_EVENTHUB_AMQP_HEADER_SIZE_BYTES - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MAX_FRAME_SIZE - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

MAX_FRAME_SIZE_BYTES - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MAX_MESSAGE_LENGTH_BYTES - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MAX_PARTITION_KEY_LENGTH - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MAX_RECEIVER_NAME_LENGTH - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MAX_USER_AGENT_LENGTH - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

MAXIMUM_PREFETCH_COUNT - Static variable in interface com.microsoft.azure.eventhubs.PartitionReceiver

maxMessageSize - Variable in class com.microsoft.azure.eventhubs.BatchOptions

The maximum size in bytes of EventDataBatch being constructed.

MessageReceiver - Class in com.microsoft.azure.eventhubs.impl

Common Receiver that abstracts all amqp related details translates event-driven reactor model into async receive Api

MessageSender - Class in com.microsoft.azure.eventhubs.impl

Abstracts all amqp related details translates event-driven reactor model into async send Api

MessagingFactory - Class in com.microsoft.azure.eventhubs.impl

Abstracts all amqp related details and exposes AmqpConnection object Manages connection life-cycle

MessagingFactory.MessagingFactoryBuilder - Class in com.microsoft.azure.eventhubs.impl

MessagingFactory.ReactorFactory - Class in com.microsoft.azure.eventhubs.impl

MessagingFactoryBuilder(String, ITokenProvider, ScheduledExecutorService) - Constructor for class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

MGMT_CHANNEL_MIN_RETRY_IN_MILLIS - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

MINIMUM_PREFETCH_COUNT - Static variable in interface com.microsoft.azure.eventhubs.PartitionReceiver

N

NO_RETRY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

NONE - com.microsoft.azure.eventhubs.ProxyConfiguration.ProxyAuthenticationType

Proxy requires no authentication.

NOT_FOUND - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

NotAllowed - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

NotFound - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

notifyTransportErrors(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

notifyTransportErrors(Event) - Method in class com.microsoft.azure.eventhubs.impl.WebSocketProxyConnectionHandler

NotImplemented - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

NULL_EPOCH - Static variable in interface com.microsoft.azure.eventhubs.PartitionReceiver

O

OFFSET - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

OFFSET_ANNOTATION_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

OK - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

onClose() - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

onClose() - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

onClose() - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

onClose() - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

onClose(ErrorCondition, String) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpLink

onClose(ErrorCondition, String) - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

onClose(ErrorCondition, String) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

onComplete(T) - Method in interface com.microsoft.azure.eventhubs.impl.OperationResult

onConnectionBound(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionError(ErrorCondition) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpConnection

onConnectionError(ErrorCondition) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

onConnectionFinal(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionInit(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionLocalClose(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionLocalOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionRemoteClose(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionRemoteOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onConnectionUnbound(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onDelivery(Event) - Method in class com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler

onDelivery(Event) - Method in class com.microsoft.azure.eventhubs.impl.SendLinkHandler

onError(E) - Method in interface com.microsoft.azure.eventhubs.impl.OperationResult

onError(Exception, String) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpLink

onError(Exception, String) - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

onError(Exception, String) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

onError(Throwable) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiveHandler

Implement this method to Listen to errors which lead to Closure of the PartitionReceiveHandler pump.

onEvent() - Method in class com.microsoft.azure.eventhubs.impl.DispatchHandler

onFlow(int) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpSender

onFlow(int) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

onGetNextRetryInterval(String, Exception, Duration, int) - Method in class com.microsoft.azure.eventhubs.impl.RetryExponential

onGetNextRetryInterval(String, Exception, Duration, int) - Method in class com.microsoft.azure.eventhubs.RetryPolicy

onLinkFinal(Event) - Method in class com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler

onLinkFinal(Event) - Method in class com.microsoft.azure.eventhubs.impl.SendLinkHandler

onLinkFlow(Event) - Method in class com.microsoft.azure.eventhubs.impl.SendLinkHandler

onLinkLocalClose(Event) - Method in class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

onLinkLocalOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler

onLinkLocalOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.SendLinkHandler

onLinkRemoteClose(Event) - Method in class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

onLinkRemoteDetach(Event) - Method in class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

onLinkRemoteOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler

onLinkRemoteOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.SendLinkHandler

onOpenComplete(Exception) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpConnection

onOpenComplete(Exception) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpLink

onOpenComplete(Exception) - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

onOpenComplete(Exception) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

onOpenComplete(Exception) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

onReactorFinal(Event) - Method in class com.microsoft.azure.eventhubs.impl.ReactorHandler

onReactorInit(Event) - Method in class com.microsoft.azure.eventhubs.impl.ReactorHandler

onReceive(Iterable<EventData>) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiveHandler

user should implement this method to specify the action to be performed on the received events.

onReceiveComplete(Delivery) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpReceiver

onReceiveComplete(Delivery) - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

onSendComplete(Delivery) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpSender

onSendComplete(Delivery) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

onSessionFinal(Event) - Method in class com.microsoft.azure.eventhubs.impl.SessionHandler

onSessionLocalClose(Event) - Method in class com.microsoft.azure.eventhubs.impl.SessionHandler

onSessionLocalOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.SessionHandler

onSessionRemoteClose(Event) - Method in class com.microsoft.azure.eventhubs.impl.SessionHandler

onSessionRemoteOpen(Event) - Method in class com.microsoft.azure.eventhubs.impl.SessionHandler

onTimerTask(Event) - Method in class com.microsoft.azure.eventhubs.impl.DispatchHandler

onTransportClosed(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

onTransportClosed(Event) - Method in class com.microsoft.azure.eventhubs.impl.CustomIOHandler

onTransportError(Event) - Method in class com.microsoft.azure.eventhubs.impl.ConnectionHandler

open(OperationResult<Void, Exception>, OperationResult<Void, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

OPENED - com.microsoft.azure.eventhubs.impl.IOObject.IOObjectState

OPENING - com.microsoft.azure.eventhubs.impl.IOObject.IOObjectState

Operation<T> - Interface in com.microsoft.azure.eventhubs.impl

OperationCancelledException - Exception in com.microsoft.azure.eventhubs

This exception is thrown when the underlying AMQP layer encounter an abnormal link abort or disconnect of connection in an unexpected fashion.

OperationCancelledException(String) - Constructor for exception com.microsoft.azure.eventhubs.OperationCancelledException

OperationCancelledException(String, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.OperationCancelledException

OperationResult<T,E extends Throwable> - Interface in com.microsoft.azure.eventhubs.impl

P

PARTITION_KEY - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

PARTITION_KEY_ANNOTATION_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

PARTITION_NOT_OWNED_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

partitionKey - Variable in class com.microsoft.azure.eventhubs.BatchOptions

The partitionKey to use for all EventDatas sent in the current EventDataBatch.

PartitionReceiveHandler - Interface in com.microsoft.azure.eventhubs

The handler to invoke after receiving EventDatas from Microsoft Azure EventHubs.

PartitionReceiver - Interface in com.microsoft.azure.eventhubs

This is a logical representation of receiving from a EventHub partition.

PartitionRuntimeInformation - Class in com.microsoft.azure.eventhubs

PartitionRuntimeInformation(String, String, long, long, String, Instant, boolean) - Constructor for class com.microsoft.azure.eventhubs.PartitionRuntimeInformation

PartitionSender - Interface in com.microsoft.azure.eventhubs

This sender class is a logical representation of sending events to a specific EventHub partition.

PassByRef<T> - Class in com.microsoft.azure.eventhubs.impl

PassByRef() - Constructor for class com.microsoft.azure.eventhubs.impl.PassByRef

PayloadSizeExceeded - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

PayloadSizeExceededException - Exception in com.microsoft.azure.eventhubs

this exception is thrown when user attempts to send a event data or brokered message that has exceeded the allowed payload size as defined by the service.

PayloadSizeExceededException(String) - Constructor for exception com.microsoft.azure.eventhubs.PayloadSizeExceededException

PayloadSizeExceededException(String, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.PayloadSizeExceededException

PLATFORM - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

PLATFORM_INFO - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

processOnClose(Link, Exception) - Method in class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

processOnClose(Link, ErrorCondition) - Method in class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

PRODUCT - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

PRODUCT_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PROTON - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

PROTON_IO_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

PROTON_IO_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

ProtonUtil - Class in com.microsoft.azure.eventhubs.impl

proxyAddress() - Method in class com.microsoft.azure.eventhubs.ProxyConfiguration

Gets the proxy address.

ProxyConfiguration - Class in com.microsoft.azure.eventhubs

ProxyConfiguration(ProxyConfiguration.ProxyAuthenticationType, Proxy, String, String) - Constructor for class com.microsoft.azure.eventhubs.ProxyConfiguration

Creates a proxy configuration that uses the proxyAddress and authenticates with provided username, password and authentication.

ProxyConfiguration.ProxyAuthenticationType - Enum in com.microsoft.azure.eventhubs

Supported methods of proxy authentication.

PUBLISHER_ANNOTATION_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

PUBLISHER_REVOKED_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_AUDIENCE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_EXPIRY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_OPERATION - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_OPERATION_VALUE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_STATUS_CODE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_STATUS_DESCRIPTION - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

PUT_TOKEN_TYPE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

Q

QuotaExceededException - Exception in com.microsoft.azure.eventhubs

QuotaExceededException(String) - Constructor for exception com.microsoft.azure.eventhubs.QuotaExceededException

QuotaExceededException(Throwable) - Constructor for exception com.microsoft.azure.eventhubs.QuotaExceededException

R

reactor(ReactorHandler, int, String) - Static method in class com.microsoft.azure.eventhubs.impl.ProtonUtil

REACTOR_IO_POLL_TIMEOUT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

ReactorDispatcher - Class in com.microsoft.azure.eventhubs.impl

Reactor is not thread-safe - all calls to Proton API's should be - on the Reactor Thread.

ReactorDispatcher(Reactor) - Constructor for class com.microsoft.azure.eventhubs.impl.ReactorDispatcher

ReactorFactory() - Constructor for class com.microsoft.azure.eventhubs.impl.MessagingFactory.ReactorFactory

ReactorHandler - Class in com.microsoft.azure.eventhubs.impl

ReactorHandler(String) - Constructor for class com.microsoft.azure.eventhubs.impl.ReactorHandler

READ_OPERATION_VALUE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

receive(int) - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

receive(int) - Method in interface com.microsoft.azure.eventhubs.impl.ReceivePump.IPartitionReceiver

receive(int) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Receive a batch of EventData's from an EventHub partition

receiveAndProcess() - Method in class com.microsoft.azure.eventhubs.impl.ReceivePump

ReceiveLinkHandler - Class in com.microsoft.azure.eventhubs.impl

ReceiveLinkHandler(AmqpReceiver, String, ScheduledExecutorService) - Constructor for class com.microsoft.azure.eventhubs.impl.ReceiveLinkHandler

ReceivePump - Class in com.microsoft.azure.eventhubs.impl

ReceivePump(String, String, ReceivePump.IPartitionReceiver, PartitionReceiveHandler, boolean, Executor) - Constructor for class com.microsoft.azure.eventhubs.impl.ReceivePump

ReceivePump.IPartitionReceiver - Interface in com.microsoft.azure.eventhubs.impl

RECEIVER_IDENTIFIER_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

ReceiverContext - Class in com.microsoft.azure.eventhubs.impl

ReceiverDisconnectedException - Exception in com.microsoft.azure.eventhubs

This exception is thrown when a EventHubReceiver is being disconnected because of one of the following reason: user attempts to connect a non-epoch receiver to a event hub partition, when there is an epoch receiver connected to the partition.

ReceiverDisconnectedException(String) - Constructor for exception com.microsoft.azure.eventhubs.ReceiverDisconnectedException

ReceiverOptions - Class in com.microsoft.azure.eventhubs

Represents various optional behaviors which can be turned on or off during the creation of a PartitionReceiver.

ReceiverOptions() - Constructor for class com.microsoft.azure.eventhubs.ReceiverOptions

ReceiverRuntimeInformation - Class in com.microsoft.azure.eventhubs

Represents the temporal end of stream information of an EventHubs Partition.

ReceiverRuntimeInformation(String) - Constructor for class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

ReceiverSettingsProvider - Interface in com.microsoft.azure.eventhubs.impl

receiveSync(int) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Synchronous version of PartitionReceiver.receive(int).

registerForConnectionError(Link) - Method in interface com.microsoft.azure.eventhubs.impl.AmqpConnection

registerForConnectionError(Link) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

registerForWatchdog(MessageReceiver) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

remaining() - Method in class com.microsoft.azure.eventhubs.impl.TimeoutTracker

ReplayableWorkItem<T> - Class in com.microsoft.azure.eventhubs.impl

ReplayableWorkItem(byte[], int, int, CompletableFuture<T>, TimeoutTracker) - Constructor for class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

ReplayableWorkItem(byte[], int, int, CompletableFuture<T>, Duration) - Constructor for class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

request(Message, OperationResult<Message, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

RequestResponseChannel - Class in com.microsoft.azure.eventhubs.impl

RequestResponseChannel(String, String, Session, ScheduledExecutorService) - Constructor for class com.microsoft.azure.eventhubs.impl.RequestResponseChannel

RequestResponseCloser - Class in com.microsoft.azure.eventhubs.impl

RequestResponseCloser() - Constructor for class com.microsoft.azure.eventhubs.impl.RequestResponseCloser

RequestResponseOpener - Class in com.microsoft.azure.eventhubs.impl

RequestResponseOpener(SessionProvider, String, String, String, String, AmqpConnection, ScheduledExecutorService) - Constructor for class com.microsoft.azure.eventhubs.impl.RequestResponseOpener

RESERVED_PROPERTY_NAMES - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

resetRetryCount(String) - Method in class com.microsoft.azure.eventhubs.RetryPolicy

ResourceLimitExceeded - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

RetryExponential - Class in com.microsoft.azure.eventhubs.impl

RetryPolicy implementation where the delay between retries will grow in an exponential manner.

RetryExponential(Duration, Duration, int, String) - Constructor for class com.microsoft.azure.eventhubs.impl.RetryExponential

RetryPolicy - Class in com.microsoft.azure.eventhubs

RetryPolicy(String) - Constructor for class com.microsoft.azure.eventhubs.RetryPolicy

run() - Method in class com.microsoft.azure.eventhubs.impl.ReceivePump

run(OperationResult<RequestResponseChannel, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseOpener

run(OperationResult<Void, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseCloser

run(OperationResult<T, Exception>) - Method in interface com.microsoft.azure.eventhubs.impl.Operation

runOnOpenedObject(ReactorDispatcher, OperationResult<T, Exception>) - Method in class com.microsoft.azure.eventhubs.impl.FaultTolerantObject

S

SAS_TOKEN_TYPE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

scheduleOnReactorThread(int, DispatchHandler) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

scheduleOnReactorThread(DispatchHandler) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

SecurityToken - Class in com.microsoft.azure.eventhubs

A generic representation of a security token.

SecurityToken(String, Date, String, String) - Constructor for class com.microsoft.azure.eventhubs.SecurityToken

Constructor.

send(EventData) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Send EventData to EventHub.

send(EventData) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

send(EventData) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Send EventData to a specific EventHub partition.

send(EventDataBatch) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Send EventDataBatch to EventHub.

send(EventDataBatch) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

send(EventDataBatch) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Send EventDataBatch to a specific EventHub partition.

send(EventData, String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Send an 'EventData with a partitionKey' to EventHub.

send(EventData, String) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

send(Iterable<EventData>) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Send a batch of EventData to EventHub.

send(Iterable<EventData>) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

send(Iterable<EventData>) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Send EventData to a specific EventHub partition.

send(Iterable<EventData>, String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Send a 'batch of EventData with the same partitionKey' to EventHub.

send(Iterable<EventData>, String) - Method in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

send(Iterable<Message>) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

send(Message) - Method in class com.microsoft.azure.eventhubs.impl.MessageSender

SenderContext - Class in com.microsoft.azure.eventhubs.impl

SendLinkHandler - Class in com.microsoft.azure.eventhubs.impl

SendLinkHandler(AmqpSender, String, ScheduledExecutorService) - Constructor for class com.microsoft.azure.eventhubs.impl.SendLinkHandler

sendSync(EventData) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.send(EventData).

sendSync(EventData) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Synchronous version of PartitionSender.send(EventData) Api.

sendSync(EventDataBatch) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.send(EventDataBatch).

sendSync(EventDataBatch) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Synchronous version of PartitionSender.send(EventDataBatch)

sendSync(EventData, String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.send(EventData, String).

sendSync(Iterable<EventData>) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.send(Iterable).

sendSync(Iterable<EventData>) - Method in interface com.microsoft.azure.eventhubs.PartitionSender

Synchronous version of PartitionSender.send(Iterable) .

sendSync(Iterable<EventData>, String) - Method in interface com.microsoft.azure.eventhubs.EventHubClient

Synchronous version of EventHubClient.send(Iterable, String).

SEPARATOR - Static variable in class com.microsoft.azure.eventhubs.impl.StringUtil

SEQUENCE_NUMBER - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

SEQUENCE_NUMBER_ANNOTATION_NAME - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

SERVER_BUSY_BASE_SLEEP_TIME_IN_SECS - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

SERVER_BUSY_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

ServerBusyException - Exception in com.microsoft.azure.eventhubs

Server busy exception is thrown when the current entity's activity has put excessive load onto the service.

ServerBusyException() - Constructor for exception com.microsoft.azure.eventhubs.ServerBusyException

Default constructor for the exception

ServerBusyException(String) - Constructor for exception com.microsoft.azure.eventhubs.ServerBusyException

SessionHandler - Class in com.microsoft.azure.eventhubs.impl

SessionHandler(String, Consumer<Session>, BiConsumer<ErrorCondition, Exception>, Duration, String) - Constructor for class com.microsoft.azure.eventhubs.impl.SessionHandler

SessionProvider - Interface in com.microsoft.azure.eventhubs.impl

set(T) - Method in class com.microsoft.azure.eventhubs.impl.PassByRef

setAuthentication(String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the authentication type in the Connection String.

setContext(ErrorContext) - Method in exception com.microsoft.azure.eventhubs.EventHubException

setEndpoint(String, String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set an endpoint which can be used to connect to the EventHub instance.

setEndpoint(URI) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set an endpoint which can be used to connect to the EventHub instance.

setEventHubName(String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the entity path value from the connection string.

setIdentifier(String) - Method in class com.microsoft.azure.eventhubs.ReceiverOptions

Set an identifier to PartitionReceiver.

setInnerChannel(FaultTolerantObject<RequestResponseChannel>) - Method in class com.microsoft.azure.eventhubs.impl.RequestResponseCloser

setLastKnownException(Exception) - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

setMaximumSilentTime(Duration) - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Sets the maximum silent time, in seconds.

setNamespaceName(String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set a namespace name which will be used to connect to an EventHubs instance.

setOperationTimeout(Duration) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the OperationTimeout value in the Connection String.

setOperationTimeout(Duration) - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Set the operation timeout.

setOperationTimeout(Duration) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

setPrefetchCount(int) - Method in class com.microsoft.azure.eventhubs.ReceiverOptions

Set the number of events that can be pre-fetched and cached at the PartitionReceiver.

setProxyConfiguration(ProxyConfiguration) - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Sets the proxy configuration for the client options.

setProxyConfiguration(ProxyConfiguration) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

setReactorFactory(MessagingFactory.ReactorFactory) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

setReceiveHandler(PartitionReceiveHandler) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Register a receive handler that will be called when an event is available.

setReceiveHandler(PartitionReceiveHandler, boolean) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

Register a receive handler that will be called when an event is available.

setReceiverRuntimeMetricEnabled(boolean) - Method in class com.microsoft.azure.eventhubs.ReceiverOptions

Knob to enable/disable runtime metric of the receiver.

setReceiveTimeout(Duration) - Method in class com.microsoft.azure.eventhubs.impl.MessageReceiver

setReceiveTimeout(Duration) - Method in interface com.microsoft.azure.eventhubs.PartitionReceiver

setRetryPolicy(RetryPolicy) - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Set the RetryPolicy for operations

setRetryPolicy(RetryPolicy) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

setRuntimeInformation(long, Instant, String) - Method in class com.microsoft.azure.eventhubs.ReceiverRuntimeInformation

setSasKey(String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the shared access policy key value from the connection string

setSasKeyName(String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the shared access policy owner name from the connection string

setSharedAccessSignature(String) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the shared access signature (also referred as SAS Token) from the connection string

setSystemProperties(EventData.SystemProperties) - Method in interface com.microsoft.azure.eventhubs.EventData

setSystemProperties(EventData.SystemProperties) - Method in class com.microsoft.azure.eventhubs.impl.EventDataImpl

setTimeoutTask(CompletableFuture<?>) - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

setTransportType(TransportType) - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Set the TransportType value in the Connection String.

setTransportType(TransportType) - Method in class com.microsoft.azure.eventhubs.EventHubClientOptions

Set the TransportType for the connection to the Event Hubs service

setTransportType(TransportType) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

setWaitingForAck() - Method in class com.microsoft.azure.eventhubs.impl.ReplayableWorkItem

setWatchdogTriggerTime(Duration) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory.MessagingFactoryBuilder

SharedAccessSignatureTokenProvider - Class in com.microsoft.azure.eventhubs.impl

shouldUseProxy(String) - Static method in class com.microsoft.azure.eventhubs.impl.WebSocketProxyConnectionHandler

SILENT_MINIMUM - Static variable in class com.microsoft.azure.eventhubs.EventHubClientOptions

SILENT_OFF - Static variable in class com.microsoft.azure.eventhubs.EventHubClientOptions

sizeEquals(Iterable<T>, int) - Static method in class com.microsoft.azure.eventhubs.impl.IteratorUtil

START_OF_STREAM - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

This is a constant defined to represent the start of a partition stream in EventHub.

Stolen - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

stop() - Method in class com.microsoft.azure.eventhubs.impl.ReceivePump

STORE_LOCK_LOST_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

STRING_FILTER - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

StringUtil - Class in com.microsoft.azure.eventhubs.impl

StringUtil() - Constructor for class com.microsoft.azure.eventhubs.impl.StringUtil

sync(ExceptionUtil.SyncFactory<T>) - Static method in class com.microsoft.azure.eventhubs.impl.ExceptionUtil

syncVoid(ExceptionUtil.SyncFactoryVoid) - Static method in class com.microsoft.azure.eventhubs.impl.ExceptionUtil

syncWithIllegalArgException(ExceptionUtil.SyncFactoryWithIllegalArgException<T>) - Static method in class com.microsoft.azure.eventhubs.impl.ExceptionUtil

syncWithIOException(ExceptionUtil.SyncFactoryWithIOException<T>) - Static method in class com.microsoft.azure.eventhubs.impl.ExceptionUtil

SYSTEM_DEFAULTS - Static variable in class com.microsoft.azure.eventhubs.ProxyConfiguration

Gets the system defaults for proxy configuration and authentication.

SystemProperties(long, Instant, String, String) - Constructor for class com.microsoft.azure.eventhubs.EventData.SystemProperties

SystemProperties(HashMap<String, Object>) - Constructor for class com.microsoft.azure.eventhubs.EventData.SystemProperties

T

TIMEOUT_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

TimeoutException - Exception in com.microsoft.azure.eventhubs

This exception is thrown when the operation has exceeded the predetermined time limit.

TimeoutException() - Constructor for exception com.microsoft.azure.eventhubs.TimeoutException

Default constructor for exception type.

TimeoutException(String) - Constructor for exception com.microsoft.azure.eventhubs.TimeoutException

TimeoutException(String, Throwable) - Constructor for exception com.microsoft.azure.eventhubs.TimeoutException

TimeoutException(Throwable) - Constructor for exception com.microsoft.azure.eventhubs.TimeoutException

TimeoutTracker - Class in com.microsoft.azure.eventhubs.impl

TimeoutTracker(Duration, boolean) - Constructor for class com.microsoft.azure.eventhubs.impl.TimeoutTracker

TimeoutTracker(Duration, boolean, String) - Constructor for class com.microsoft.azure.eventhubs.impl.TimeoutTracker

TIMER_TOLERANCE - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

TOKEN_AUDIENCE_FORMAT - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

TOKEN_REFRESH_INTERVAL - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

TOKEN_VALIDITY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

toStackTraceString(Throwable, String) - Static method in class com.microsoft.azure.eventhubs.impl.ExceptionUtil

toString() - Method in class com.microsoft.azure.eventhubs.ConnectionStringBuilder

Returns an inter-operable connection string that can be used to connect to EventHubs instances.

toString() - Method in class com.microsoft.azure.eventhubs.ErrorContext

toString() - Method in class com.microsoft.azure.eventhubs.impl.EventPositionImpl

toString() - Method in class com.microsoft.azure.eventhubs.impl.ReceiverContext

toString() - Method in class com.microsoft.azure.eventhubs.impl.SenderContext

toString() - Method in class com.microsoft.azure.eventhubs.RetryPolicy

toString() - Method in enum com.microsoft.azure.eventhubs.TransportType

TRACE_LOGGER - Static variable in class com.microsoft.azure.eventhubs.impl.BaseLinkHandler

TRACE_LOGGER - Static variable in class com.microsoft.azure.eventhubs.impl.SessionHandler

TRACKING_ID_PROPERTY - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

TRACKING_ID_TOKEN_SEPARATOR - Static variable in class com.microsoft.azure.eventhubs.impl.TrackingUtil

TrackingUtil - Class in com.microsoft.azure.eventhubs.impl

TRANSPORT_IDLE_TIMEOUT_MILLIS - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

TransportType - Enum in com.microsoft.azure.eventhubs

All TransportType switches available for communicating to EventHubs service.

tryAdd(EventData) - Method in interface com.microsoft.azure.eventhubs.EventDataBatch

Add's EventData to EventDataBatch, if permitted by the batch's size limit.

U

UNAUTHORIZED - com.microsoft.azure.eventhubs.impl.AmqpResponseCode

UnauthorizedAccess - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpErrorCode

unregisterForWatchdog(MessageReceiver) - Method in class com.microsoft.azure.eventhubs.impl.MessagingFactory

unsafeSetReactorDispatcher(ReactorDispatcher) - Method in class com.microsoft.azure.eventhubs.impl.ReactorHandler

USER_AGENT - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

USER_AGENT - Static variable in class com.microsoft.azure.eventhubs.impl.EventHubClientImpl

It will be truncated to 128 characters

V

validTo() - Method in class com.microsoft.azure.eventhubs.SecurityToken

Get the expiration date/time of the token.

valueOf(int) - Static method in enum com.microsoft.azure.eventhubs.impl.AmqpResponseCode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.eventhubs.impl.AmqpResponseCode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.eventhubs.impl.IOObject.IOObjectState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.eventhubs.ProxyConfiguration.ProxyAuthenticationType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum com.microsoft.azure.eventhubs.TransportType

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.microsoft.azure.eventhubs.impl.AmqpResponseCode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.eventhubs.impl.IOObject.IOObjectState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.eventhubs.ProxyConfiguration.ProxyAuthenticationType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum com.microsoft.azure.eventhubs.TransportType

Returns an array containing the constants of this enum type, in the order they are declared.

VENDOR - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

VERSION - Static variable in class com.microsoft.azure.eventhubs.impl.AmqpConstants

W

WATCHDOG_ERROR - Static variable in class com.microsoft.azure.eventhubs.impl.ClientConstants

WebSocketConnectionHandler - Class in com.microsoft.azure.eventhubs.impl

WebSocketConnectionHandler(AmqpConnection, String, SslDomain.VerifyMode) - Constructor for class com.microsoft.azure.eventhubs.impl.WebSocketConnectionHandler

WebSocketProxyConnectionHandler - Class in com.microsoft.azure.eventhubs.impl

WebSocketProxyConnectionHandler(AmqpConnection, String, SslDomain.VerifyMode, ProxyConfiguration) - Constructor for class com.microsoft.azure.eventhubs.impl.WebSocketProxyConnectionHandler

Creates a WebSocket proxy connection handler for the amqpConnection and proxyConfiguration.

with(Consumer<BatchOptions>) - Method in class com.microsoft.azure.eventhubs.BatchOptions

WorkItem<T> - Class in com.microsoft.azure.eventhubs.impl

WorkItem(CompletableFuture<T>, TimeoutTracker) - Constructor for class com.microsoft.azure.eventhubs.impl.WorkItem

WorkItem(CompletableFuture<T>, Duration) - Constructor for class com.microsoft.azure.eventhubs.impl.WorkItem

A B C D E F G H I J L M N O P Q R S T U V W
All Classes All Packages