@azure/event-hubs
Advanced tools
Comparing version 5.13.0-alpha.20241004.1 to 5.13.0-alpha.20241008.6
// Copyright (c) Microsoft Corporation. | ||
// Licensed under the MIT License. | ||
import { message, types, } from "rhea-promise"; | ||
import { Constants, ErrorNameConditionMapper, RetryOperationType, defaultCancellableLock, delay, retry, translate, } from "@azure/core-amqp"; | ||
import { ErrorNameConditionMapper, RetryOperationType, defaultCancellableLock, delay, retry, translate, } from "@azure/core-amqp"; | ||
import { populateIdempotentMessageAnnotations, toRheaMessage, } from "./eventData.js"; | ||
@@ -9,3 +9,3 @@ import { isEventDataBatch } from "./eventDataBatch.js"; | ||
import { getRetryAttemptTimeoutInMs } from "./util/retries.js"; | ||
import { idempotentProducerAmqpPropertyNames, PENDING_PUBLISH_SEQ_NUM_SYMBOL, } from "./util/constants.js"; | ||
import { idempotentProducerAmqpPropertyNames, PENDING_PUBLISH_SEQ_NUM_SYMBOL, geoReplication, } from "./util/constants.js"; | ||
import { isDefined } from "@azure/core-util"; | ||
@@ -230,3 +230,3 @@ import { translateError } from "./util/error.js"; | ||
}; | ||
srOptions.desired_capabilities = [Constants.geoReplication]; | ||
srOptions.desired_capabilities = [geoReplication]; | ||
if (this._isIdempotentProducer) { | ||
@@ -233,0 +233,0 @@ srOptions.desired_capabilities.push(idempotentProducerAmqpPropertyNames.capability); |
@@ -19,2 +19,4 @@ /** | ||
export declare const receiverIdPropertyName = "com.microsoft:receiver-name"; | ||
/** @internal */ | ||
export declare const geoReplication = "com.microsoft:georeplication"; | ||
/** | ||
@@ -21,0 +23,0 @@ * @internal |
@@ -21,2 +21,4 @@ // Copyright (c) Microsoft Corporation. | ||
export const receiverIdPropertyName = "com.microsoft:receiver-name"; | ||
/** @internal */ | ||
export const geoReplication = "com.microsoft:georeplication"; | ||
/** | ||
@@ -23,0 +25,0 @@ * @internal |
@@ -234,3 +234,3 @@ "use strict"; | ||
}; | ||
srOptions.desired_capabilities = [core_amqp_1.Constants.geoReplication]; | ||
srOptions.desired_capabilities = [constants_js_1.geoReplication]; | ||
if (this._isIdempotentProducer) { | ||
@@ -237,0 +237,0 @@ srOptions.desired_capabilities.push(constants_js_1.idempotentProducerAmqpPropertyNames.capability); |
@@ -19,2 +19,4 @@ /** | ||
export declare const receiverIdPropertyName = "com.microsoft:receiver-name"; | ||
/** @internal */ | ||
export declare const geoReplication = "com.microsoft:georeplication"; | ||
/** | ||
@@ -21,0 +23,0 @@ * @internal |
@@ -5,3 +5,3 @@ "use strict"; | ||
Object.defineProperty(exports, "__esModule", { value: true }); | ||
exports.PENDING_PUBLISH_SEQ_NUM_SYMBOL = exports.receiverIdPropertyName = exports.idempotentProducerAmqpPropertyNames = exports.packageJsonInfo = void 0; | ||
exports.PENDING_PUBLISH_SEQ_NUM_SYMBOL = exports.geoReplication = exports.receiverIdPropertyName = exports.idempotentProducerAmqpPropertyNames = exports.packageJsonInfo = void 0; | ||
/** | ||
@@ -25,2 +25,4 @@ * @internal | ||
exports.receiverIdPropertyName = "com.microsoft:receiver-name"; | ||
/** @internal */ | ||
exports.geoReplication = "com.microsoft:georeplication"; | ||
/** | ||
@@ -27,0 +29,0 @@ * @internal |
// Copyright (c) Microsoft Corporation. | ||
// Licensed under the MIT License. | ||
import { message, types, } from "rhea-promise"; | ||
import { Constants, ErrorNameConditionMapper, RetryOperationType, defaultCancellableLock, delay, retry, translate, } from "@azure/core-amqp"; | ||
import { ErrorNameConditionMapper, RetryOperationType, defaultCancellableLock, delay, retry, translate, } from "@azure/core-amqp"; | ||
import { populateIdempotentMessageAnnotations, toRheaMessage, } from "./eventData.js"; | ||
@@ -9,3 +9,3 @@ import { isEventDataBatch } from "./eventDataBatch.js"; | ||
import { getRetryAttemptTimeoutInMs } from "./util/retries.js"; | ||
import { idempotentProducerAmqpPropertyNames, PENDING_PUBLISH_SEQ_NUM_SYMBOL, } from "./util/constants.js"; | ||
import { idempotentProducerAmqpPropertyNames, PENDING_PUBLISH_SEQ_NUM_SYMBOL, geoReplication, } from "./util/constants.js"; | ||
import { isDefined } from "@azure/core-util"; | ||
@@ -230,3 +230,3 @@ import { translateError } from "./util/error.js"; | ||
}; | ||
srOptions.desired_capabilities = [Constants.geoReplication]; | ||
srOptions.desired_capabilities = [geoReplication]; | ||
if (this._isIdempotentProducer) { | ||
@@ -233,0 +233,0 @@ srOptions.desired_capabilities.push(idempotentProducerAmqpPropertyNames.capability); |
@@ -19,2 +19,4 @@ /** | ||
export declare const receiverIdPropertyName = "com.microsoft:receiver-name"; | ||
/** @internal */ | ||
export declare const geoReplication = "com.microsoft:georeplication"; | ||
/** | ||
@@ -21,0 +23,0 @@ * @internal |
@@ -21,2 +21,4 @@ // Copyright (c) Microsoft Corporation. | ||
export const receiverIdPropertyName = "com.microsoft:receiver-name"; | ||
/** @internal */ | ||
export const geoReplication = "com.microsoft:georeplication"; | ||
/** | ||
@@ -23,0 +25,0 @@ * @internal |
{ | ||
"name": "@azure/event-hubs", | ||
"sdk-type": "client", | ||
"version": "5.13.0-alpha.20241004.1", | ||
"version": "5.13.0-alpha.20241008.6", | ||
"description": "Azure Event Hubs SDK for JS.", | ||
@@ -6,0 +6,0 @@ "author": "Microsoft Corporation", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
3203759
30334