Member Junction
    Preparing search index...

    Module

    Classes

    BaseTransportDriverFactory
    BaseWorkHandler
    BoundWorkHandler
    DatabaseTransportConsumer
    DatabaseTransportDriver
    DatabaseTransportDriverFactory
    DatabaseTransportOperator
    DeduplicationLedger
    ListenerSet
    ManifestEnricherRegistry
    MJWorkLogger
    MJWorkQueueDeduplicationEntityServer
    MJWorkQueueDeliveryEntityServer
    MJWorkQueueMessageEntityServer
    MJWorkQueueSubscriptionEntityServer
    MJWorkQueueTopicEntityServer
    MJWorkQueueTransportEntityServer
    OwnedExecutor
    ProcedureCallBuilder
    PublishListenerSet
    SharedProviderSource
    SqlParamList
    WorkQueueConsumeSql
    WorkQueueDiscardDeliveryServerOperation
    WorkQueueEngine
    WorkQueueGetBacklogServerOperation
    WorkQueueGetSubscriptionStatsServerOperation
    WorkQueueHost
    WorkQueueListDeadLettersServerOperation
    WorkQueueListPartitionsServerOperation
    WorkQueueOperatorService
    WorkQueueOperatorSql
    WorkQueuePublishCoordinator
    WorkQueuePublishSql
    WorkQueueReplayDeadLetterServerOperation
    WorkQueueSweeper
    WorkQueueValidateBindingsServerOperation

    Interfaces

    BacklogRow
    BlockedSubscriptionPlan
    ClaimedDeliveryRow
    ConsumeSqlBuilder
    CoordinatorPublishOptions
    DatabaseConformanceHarness
    DatabaseSubscriptionIDs
    DatabaseTransportPublishOptions
    DeadLetterCursor
    DeadLetteredEvent
    DeadLetterRow
    DeliveryInsertRow
    DeliveryPlan
    ExistingMessageRow
    ExpandedSubscriptionRequest
    ExpiredDeadLetterRow
    HostRuntime
    HostRuntimeArgs
    HostSubscriptionRequest
    HostSweeper
    IsolationRow
    LeaseStateRow
    LockResultRow
    MessageColumns
    MessageInsertedRow
    MessageInsertRow
    OperatorSqlBuilder
    PartitionCandidateRow
    PartitionModeChange
    PartitionRow
    PlannedDelivery
    ProcedureParam
    PublishCoordinatorDeps
    PublishOrderLocker
    PublishSqlBuilder
    ReservationRow
    RunnableSubscriptionPlan
    RunOnceOptions
    RunOnceResult
    SqlStatement
    StatsRow
    SubscriptionBacklog
    SubscriptionBacklogReport
    SweepLock
    SweepLockRow
    TransactionOutcome
    TransportDriverDeps
    WorkHandlerExecutionContext
    WorkQueueExecutorSource
    WorkQueueHostConfig
    WorkQueueHostDependencies
    WorkQueueHostEngine
    WorkQueueHostHealth
    WorkQueueIndependentExecutor
    WorkQueueOperatorEngine
    WorkQueueProviderSource
    WorkQueuePublishOptions
    WorkQueueSqlBuilder
    WorkQueueSqlExecutor
    WorkQueueSweeperEngine
    WorkQueueSweeperOptions
    WorkQueueTransactionalExecutor

    Type Aliases

    BacklogPartitionMode
    ClaimPartitionMode
    ConformanceProvider
    EntityPermissionLookup
    HostedSubscriptionPlan
    HostedSubscriptionState
    LedgerOperations
    LedgerReservation
    ManifestEnricher
    OperatorAccess
    RunOnceReason
    SqlBuilderContext
    SqlParam
    WorkHandlerProbe
    WorkHandlerResolver
    WorkQueueProcedureName
    WorkQueueTableName

    Variables

    BACKLOG_COUNT_CAP
    CANDIDATE_OVERSCAN
    DATABASE_CONFORMANCE_TRAITS
    DATABASE_TRANSPORT_CAPABILITIES
    DEDUP_RESERVATION_SECONDS
    DEDUPLICATION_KEY_INDEX
    DEFAULT_SWEEPER_OPTIONS
    DELIVERY_INSERT_CHUNK
    DELIVERY_SUBSCRIPTION_MESSAGE_INDEX
    DRIVER_OWNED_STATE_MESSAGE
    EXPIRE_LEASES_BATCH
    HOST_SHUT_DOWN_REASON
    IN_FLIGHT_PARTITION_INDEX
    MESSAGE_PRIMARY_KEY
    OPERATOR_DEFAULT_PAGE_SIZE
    OPERATOR_MAX_CURSOR_LENGTH
    OPERATOR_MAX_NAME_LENGTH
    OPERATOR_MAX_NOTE_LENGTH
    OPERATOR_MAX_PAGE_SIZE
    OPERATOR_OPERATE_ENTITY
    OPERATOR_READ_ENTITY
    PUBLISH_LOCK_TIMEOUT_MS
    STATS_UNAVAILABLE_MESSAGE
    SWEEP_LOCK_RESOURCE
    WorkQueueProcedures
    WorkQueueTables

    Functions

    Accepted
    AddFieldIssues
    AuthorizeWorkQueueOperator
    BuildDeliveryPlan
    CheckPartitionModeChange
    ClampPageSize
    CreateDatabaseConformanceHarness
    CreateWorkQueueSqlBuilder
    DecodeCursorField
    DefaultInstanceID
    DriverCacheKey
    Duplicate
    EncodeCursor
    ErrorCodes
    ErrorText
    ExecuteRows
    ExecuteWrite
    ExpandSubscriptionRequests
    IsDatabaseTransportPublishOptions
    IsTransientDatabaseError
    IsUniqueViolation
    IsUUID
    IsWorkHandlerRegistered
    IsWorkQueueExecutorSource
    IsWorkQueueTransactionalExecutor
    LoadDatabaseTransportDriverFactory
    LoadWorkQueueOperations
    MessageFromColumns
    NormalizeRowID
    ParseAttributes
    ParsePayload
    ParsePayloadRef
    PlanHostedSubscriptions
    PublishOrderKeys
    PublishOrderLockResource
    QualifiedTable
    ReadSubscriptionIDs
    ReadTopicID
    RefuseDriverOwnedWrite
    Rejected
    ResolveDriverFactory
    ResolveExistingMessage
    ResolveWorkHandler
    RetryTransient
    RunInWorkQueueTransaction
    SecondsToShift
    SerializeProgress
    SetOperatorPermissionLookupForTests
    ToBoolean
    ToDeliveryRows
    ToIsoString
    ToMessageInsertRow
    ToNumber
    TruncateNote
    TryAcquireSweepLock

    Settings

    Member Visibility

    On This Page

    Classes
    BaseTransportDriverFactoryBaseWorkHandlerBoundWorkHandlerDatabaseTransportConsumerDatabaseTransportDriverDatabaseTransportDriverFactoryDatabaseTransportOperatorDeduplicationLedgerListenerSetManifestEnricherRegistryMJWorkLoggerMJWorkQueueDeduplicationEntityServerMJWorkQueueDeliveryEntityServerMJWorkQueueMessageEntityServerMJWorkQueueSubscriptionEntityServerMJWorkQueueTopicEntityServerMJWorkQueueTransportEntityServerOwnedExecutorProcedureCallBuilderPublishListenerSetSharedProviderSourceSqlParamListWorkQueueConsumeSqlWorkQueueDiscardDeliveryServerOperationWorkQueueEngineWorkQueueGetBacklogServerOperationWorkQueueGetSubscriptionStatsServerOperationWorkQueueHostWorkQueueListDeadLettersServerOperationWorkQueueListPartitionsServerOperationWorkQueueOperatorServiceWorkQueueOperatorSqlWorkQueuePublishCoordinatorWorkQueuePublishSqlWorkQueueReplayDeadLetterServerOperationWorkQueueSweeperWorkQueueValidateBindingsServerOperation
    Interfaces
    BacklogRowBlockedSubscriptionPlanClaimedDeliveryRowConsumeSqlBuilderCoordinatorPublishOptionsDatabaseConformanceHarnessDatabaseSubscriptionIDsDatabaseTransportPublishOptionsDeadLetterCursorDeadLetteredEventDeadLetterRowDeliveryInsertRowDeliveryPlanExistingMessageRowExpandedSubscriptionRequestExpiredDeadLetterRowHostRuntimeHostRuntimeArgsHostSubscriptionRequestHostSweeperIsolationRowLeaseStateRowLockResultRowMessageColumnsMessageInsertedRowMessageInsertRowOperatorSqlBuilderPartitionCandidateRowPartitionModeChangePartitionRowPlannedDeliveryProcedureParamPublishCoordinatorDepsPublishOrderLockerPublishSqlBuilderReservationRowRunnableSubscriptionPlanRunOnceOptionsRunOnceResultSqlStatementStatsRowSubscriptionBacklogSubscriptionBacklogReportSweepLockSweepLockRowTransactionOutcomeTransportDriverDepsWorkHandlerExecutionContextWorkQueueExecutorSourceWorkQueueHostConfigWorkQueueHostDependenciesWorkQueueHostEngineWorkQueueHostHealthWorkQueueIndependentExecutorWorkQueueOperatorEngineWorkQueueProviderSourceWorkQueuePublishOptionsWorkQueueSqlBuilderWorkQueueSqlExecutorWorkQueueSweeperEngineWorkQueueSweeperOptionsWorkQueueTransactionalExecutor
    Type Aliases
    Variables
    Functions
    AcceptedAddFieldIssuesAuthorizeWorkQueueOperatorBuildDeliveryPlanCheckPartitionModeChangeClampPageSizeCreateDatabaseConformanceHarnessCreateWorkQueueSqlBuilderDecodeCursorFieldDefaultInstanceIDDriverCacheKeyDuplicateEncodeCursorErrorCodesErrorTextExecuteRowsExecuteWriteExpandSubscriptionRequestsIsDatabaseTransportPublishOptionsIsTransientDatabaseErrorIsUniqueViolationIsUUIDIsWorkHandlerRegisteredIsWorkQueueExecutorSourceIsWorkQueueTransactionalExecutorLoadDatabaseTransportDriverFactoryLoadWorkQueueOperationsMessageFromColumnsNormalizeRowIDParseAttributesParsePayloadParsePayloadRefPlanHostedSubscriptionsPublishOrderKeysPublishOrderLockResourceQualifiedTableReadSubscriptionIDsReadTopicIDRefuseDriverOwnedWriteRejectedResolveDriverFactoryResolveExistingMessageResolveWorkHandlerRetryTransientRunInWorkQueueTransactionSecondsToShiftSerializeProgressSetOperatorPermissionLookupForTestsToBooleanToDeliveryRowsToIsoStringToMessageInsertRowToNumberTruncateNoteTryAcquireSweepLock