fix signatures for listQueues and listTopics

fix Subscription and Topic CountDetails property
add ServiceBusClient between ServicebusServiceClient and EventEmitter
...to expose host, port and protocol.
This commit is contained in:
naughton
2018-03-15 13:14:44 -07:00
parent 4966cbaaa5
commit b9369a91f4
6 changed files with 31 additions and 23 deletions
+2 -2
View File
@@ -14,14 +14,14 @@ function ResponseCallback(err: Error | null, response: Azure.ServiceBus.Response
const ServiceBus = AzureSB.createServiceBusService('connectionstring');
// Queues
ServiceBus.listQueues('', createResultCallback<Models.Queue[]>());
ServiceBus.listQueues(createResultCallback<Models.Queue[]>());
ServiceBus.createQueue('test', createResultCallback<Models.Queue>());
ServiceBus.createQueueIfNotExists('test', createResultCallback<boolean>());
ServiceBus.getQueue('test', createResultCallback<Models.Queue>());
ServiceBus.deleteQueue('test', ResponseCallback);
// Topics
ServiceBus.listTopics('', createResultCallback<Models.Topic[]>());
ServiceBus.listTopics(createResultCallback<Models.Topic[]>());
ServiceBus.createTopic('test', createResultCallback<Models.Topic>());
ServiceBus.createTopicIfNotExists('test', createResultCallback<boolean>());
ServiceBus.getTopic('test', createResultCallback<Models.Topic>());
+10 -14
View File
@@ -214,15 +214,15 @@ export namespace Azure.ServiceBus {
// [x: string]: string | Dictionary<string | object>;
// }
export const ActiveMessageCount = 'd2p1:ActiveMessageCount';
export const DeadLetterMessageCount = 'd2p1:DeadLetterMessageCount';
export const ScheduledMessageCount = 'd2p1:ScheduledMessageCount';
export const TransferMessageCount = 'd2p1:TransferMessageCount';
export const TransferDeadLetterMessageCount = 'd2p1:TransferDeadLetterMessageCount';
export interface Topic extends ExtendedBase {
AccessedAt: DateString;
CountDetails: {
'd2p1:ActiveMessageCount': string;
'd2p1:DeadLetterMessageCount': string;
'd2p1:ScheduledMessageCount': string;
'd2p1:TransferMessageCount': string;
'd2p1:TransferDeadLetterMessageCount': string;
};
CountDetails: { [key: string]: string };
EnableSubscriptionPartitioning: string;
FilteringMessagesBeforePublishing: string;
IsExpress: string;
@@ -242,13 +242,7 @@ export namespace Azure.ServiceBus {
}
export interface Subscription extends ExtendedBase {
CountDetails: {
'd3p1:ActiveMessageCount': string;
'd3p1:DeadLetterMessageCount': string;
'd3p1:ScheduledMessageCount': string;
'd3p1:TransferMessageCount': string;
'd3p1:TransferDeadLetterMessageCount': string;
};
CountDetails: { [key: string]: string };
DeadLetteringOnFilterEvaluationExceptions: string;
DeadLetteringOnMessageExpiration: string;
LockDuration: string;
@@ -315,6 +309,8 @@ export namespace Azure.ServiceBus {
export type CreateSubscriptionOptions = Partial<ICreateSubscriptionOptions>;
export type ListSubscriptionsOptions = Partial<PaginationOptions>;
export type ListRulesOptions = Partial<PaginationOptions>;
export type ListTopicsOptions = Partial<PaginationOptions>;
export type ListQueuesOptions = Partial<PaginationOptions>;
export type CreateRuleOptions = Partial<ICreateRuleOptions>;
export type CreateNotificationHubOptions = Partial<ICreateNotificationHubOptions>;
export type ListNotificationHubsOptions = Partial<PaginationOptions>;
+6 -2
View File
@@ -11,6 +11,8 @@ import CreateTopicOptions = Azure.ServiceBus.CreateTopicOptions;
import ListNotificationHubsOptions = Azure.ServiceBus.ListNotificationHubsOptions;
import ListRulesOptions = Azure.ServiceBus.ListRulesOptions;
import ListSubscriptionsOptions = Azure.ServiceBus.ListSubscriptionsOptions;
import ListTopicsOptions = Azure.ServiceBus.ListTopicsOptions;
import ListQueuesOptions = Azure.ServiceBus.ListQueuesOptions;
import MessageOrName = Azure.ServiceBus.MessageOrName;
import Queue = Azure.ServiceBus.Results.Models.Queue;
import ReceiveQueueMessageOptions = Azure.ServiceBus.ReceiveQueueMessageOptions;
@@ -88,7 +90,8 @@ declare class ServiceBusService extends ServiceBusServiceBase {
public getQueue(queuePath: string,
callback: TypedResultAndResponseCallback<Queue>): void;
public listQueues(queuePath: string,
public listQueues(callback: TypedResultAndResponseCallback<Queue[]>): void;
public listQueues(options: ListQueuesOptions,
callback: TypedResultAndResponseCallback<Queue[]>): void;
/*
@@ -115,7 +118,8 @@ declare class ServiceBusService extends ServiceBusServiceBase {
public getTopic(topicPath: string,
callback: TypedResultAndResponseCallback<Topic>): void;
public listTopics(topicPath: string,
public listTopics(callback: TypedResultAndResponseCallback<Topic[]>): void;
public listTopics(options: ListTopicsOptions,
callback: TypedResultAndResponseCallback<Topic[]>): void;
/*
+3 -4
View File
@@ -1,14 +1,13 @@
/// <reference types="node" />
import EventEmitter = NodeJS.EventEmitter;
import ServiceClient = require('azure-sb/lib/serviceclient');
declare class ServiceBusServiceClient extends EventEmitter {
declare class ServiceBusServiceClient extends ServiceClient {
constructor(accessKey?: string,
issuer?: string,
sharedAccessKeyName?: string,
sharedAccessKeyValue?: string,
host?: string,
acsHost?: string,
authenticationProvider?: object);
authenticationProvider?: object);
}
export = ServiceBusServiceClient;
+8
View File
@@ -0,0 +1,8 @@
/// <reference types="node" />
import EventEmitter = NodeJS.EventEmitter;
declare class ServiceClient extends EventEmitter {
public host: string;
public port: number;
public protocol: string;
}
export = ServiceClient;
+2 -1
View File
@@ -30,6 +30,7 @@
"lib/models/subscriptionresult.d.ts",
"lib/models/notificationhubresult.d.ts",
"lib/models/resourceresult.d.ts",
"lib/serviceclient.d.ts",
"lib/servicebusserviceclient.d.ts",
"lib/gcmservice.d.ts",
"lib/wnsservice.d.ts",
@@ -38,4 +39,4 @@
"azure-sb-tests.ts",
"index.d.ts"
]
}
}