Azure
/
azure-event-hubs-node
зеркало из
1
0
Форкнуть 0
Код Задачи Пакеты Проекты Релизы Вики Активность

small updates

This commit is contained in:
Amar Zavery 2018-05-02 15:50:01 -07:00
Родитель f3c4191c50
Коммит c455735913
3 изменённых файлов: 45 добавлений и 14 удалений
Показать статистику Скачать Patch файл Скачать Diff файл Показать все файлы Свернуть все файлы

40
.vscode/launch.json поставляемый
Просмотреть файл

@ -7,7 +7,7 @@
{
"type": "node",
"request": "launch",
"name": "Mocha Tests",
"name": "EPH Tests",
"program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
"args": [
"-u",
@ -17,20 +17,48 @@
"-t",
"999999",
"--colors",
"${workspaceFolder}/tests/eph.spec.ts"
"${workspaceFolder}/processor/tests/eph.spec.ts"
],
"internalConsoleOptions": "openOnSessionStart",
"envFile": "${workspaceFolder}/.env" // You can take a look at the sample.env file for supported environment variables.
"envFile": "${workspaceFolder}/processor/.env" // You can take a look at the sample.env file for supported environment variables.
},
{
"type": "node",
"request": "launch",
"name": "Run Example",
"program": "${workspaceFolder}/examples/simpleSendReceive.ts",
"name": "Client Tests",
"program": "${workspaceFolder}/node_modules/mocha/bin/_mocha",
"args": [
"-u",
"tdd",
"-r",
"ts-node/register",
"-t",
"999999",
"--colors",
"${workspaceFolder}/client/tests/client.spec.ts"
],
"internalConsoleOptions": "openOnSessionStart",
"envFile": "${workspaceFolder}/client/.env" // You can take a look at the sample.env file for supported environment variables.
},
{
"type": "node",
"request": "launch",
"name": "Client Example",
"program": "${workspaceFolder}/client/examples/simpleSendReceive.ts",
"outFiles": [
"${workspaceFolder}/dist/**/*.js"
],
"envFile": "${workspaceFolder}/.env" // You can take a look at the sample.env file for supported environment variables.
"envFile": "${workspaceFolder}/client/.env" // You can take a look at the sample.env file for supported environment variables.
},
{
"type": "node",
"request": "launch",
"name": "EPH Example",
"program": "${workspaceFolder}/processor/examples/eph.ts",
"outFiles": [
"${workspaceFolder}/dist/**/*.js"
],
"envFile": "${workspaceFolder}/processor/.env" // You can take a look at the sample.env file for supported environment variables.
},
{
"type": "node",

7
processor/lib/index.ts
Просмотреть файл

@ -3,10 +3,13 @@
export {
PartitionFilter, EventProcessorHost, OnEphClose, OnEphMessage, OnEphOpen,
ConnectionStringBasedOptions, EventProcessorOptions
ConnectionStringBasedOptions, EventProcessorOptions, StartEPHOptions
} from "./eventProcessorHost";
export { PartitionContext } from "./partitionContext";
export { CheckpointInfo } from "./checkpointInfo";
export { Lease } from "./blobLease";
export { LeaseManager, LeaseWithDuration } from "./blobLeaseManager";
export { delay, EventData, OnError as OnEphError } from "azure-event-hubs";
export {
delay, EventData, OnError as OnEphError, EventPosition, EventHubPartitionRuntimeInformation,
EventHubRuntimeInformation, EventHubsError, DataTransformer
} from "azure-event-hubs";

12
processor/tests/eph.spec.ts
Просмотреть файл

@ -8,11 +8,11 @@ chai.use(chaiAsPromised);
import * as debugModule from "debug";
const should = chai.should();
const debug = debugModule("azure:event-hubs:eph-spec");
import { EventHubClient, EventData, EventPosition, delay } from "../../client/lib";
import { EventHubClient, EventData, EventPosition, delay } from "azure-event-hubs";
import * as dotenv from "dotenv";
import { BlobLeaseManager } from "../lib/blobLeaseManager";
import { PartitionContext, OnEphMessage, EventProcessorHost, OnEphOpen } from "../lib";
import { executePromisesSequentially } from "../../client/lib/util/utils";
import { executePromisesSequentially } from "azure-event-hubs/lib/util/utils";
dotenv.config();
describe("EPH", function () {
@ -82,7 +82,7 @@ describe("EPH", function () {
}
};
const onMessage: OnEphMessage = (context: PartitionContext, data: EventData) => {
debug(">>>>> Rx message from '%s': '%s'", context.partitionId, data.body.toString('utf8'));
debug(">>>>> Rx message from '%s': '%s'", context.partitionId, data);
if (data.properties!.message_id === msgId) {
debug(">>>> Checkpointing the received message...");
context.checkpoint().then(function () {
@ -91,7 +91,7 @@ describe("EPH", function () {
}).then(function (content) {
debug(">>>> Seen expected message. New lease contents: %s", content);
const parsed = JSON.parse(content);
parsed.Offset.should.eql(data.offset);
parsed.offset.should.eql(data.offset);
}).then(() => {
return ehc.close();
}).then(() => {
@ -134,7 +134,7 @@ describe("EPH", function () {
let counter1 = 0;
const onMessage1: OnEphMessage = (context: PartitionContext, data: EventData) => {
counter1++;
debug(">>>>>[host1] Rx message from '%s': '%s'", context.partitionId, data.body.toString('utf8'));
debug(">>>>>[host1] Rx message from '%s': '%s'", context.partitionId, data);
debug("&&&&&&& counter1: %d", counter1);
if (counter1 >= 90) {
debug("#### host1 counter %d, now closing it.", counter1);
@ -156,7 +156,7 @@ describe("EPH", function () {
let counter2 = 0;
const onMessage2: OnEphMessage = (context: PartitionContext, data: EventData) => {
counter2++;
debug(">>>>>[host2] Rx message from '%s': '%s'", context.partitionId, data.body.toString('utf8'));
debug(">>>>>[host2] Rx message from '%s': '%s'", context.partitionId, data);
debug("&&&&&&& counter2: %d", counter2);
if (counter2 >= 3) {
debug("#### host2 counter %d, now closing it.", counter2);