Package com.microsoft.azure.eventhubs.impl

Interface Summary

Interface	Description
AmqpConnection
AmqpLink
AmqpReceiver
AmqpSender
ExceptionUtil.SyncFactory<T>
ExceptionUtil.SyncFactoryVoid
ExceptionUtil.SyncFactoryWithIllegalArgException<T>
ExceptionUtil.SyncFactoryWithIOException<T>
IOObject
Operation<T>
OperationResult<T,E extends Throwable>
ReceivePump.IPartitionReceiver
ReceiverSettingsProvider
SessionProvider

Class Summary

Class	Description
AmqpConstants
AmqpErrorCode
AmqpUtil
BaseLinkHandler
ClientConstants
ConnectionHandler
CustomIOHandler
DispatchHandler
EventDataImpl
EventHubClientImpl
EventPositionImpl
ExceptionUtil
FaultTolerantObject<T extends IOObject>
IteratorUtil
MessageReceiver	Common Receiver that abstracts all amqp related details translates event-driven reactor model into async receive Api
MessageSender	Abstracts all amqp related details translates event-driven reactor model into async send Api
MessagingFactory	Abstracts all amqp related details and exposes AmqpConnection object Manages connection life-cycle
MessagingFactory.MessagingFactoryBuilder
MessagingFactory.ReactorFactory
PassByRef<T>
ProtonUtil
ReactorDispatcher	Reactor is not thread-safe - all calls to Proton API's should be - on the Reactor Thread.
ReactorHandler
ReceiveLinkHandler
ReceivePump
ReceiverContext
ReplayableWorkItem<T>
RequestResponseChannel
RequestResponseCloser
RequestResponseOpener
RetryExponential	RetryPolicy implementation where the delay between retries will grow in an exponential manner.
SenderContext
SendLinkHandler
SessionHandler
SharedAccessSignatureTokenProvider
StringUtil
TimeoutTracker
TrackingUtil
WebSocketConnectionHandler
WebSocketProxyConnectionHandler
WorkItem<T>

Enum Summary

Enum	Description
AmqpResponseCode
IOObject.IOObjectState

Exception Summary

Exception	Description
AmqpException	All AmqpExceptions - which EventHub client handles internally.