Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
static createFromTokenProvider(
host: string,
tokenProvider: TokenProvider,
options?: ServiceBusClientOptions
): ServiceBusClient {
host = String(host);
if (!tokenProvider) {
throw new TypeError('Missing parameter "tokenProvider"');
}
if (!host.endsWith("/")) host += "/";
const connectionString =
`Endpoint=sb://${host};SharedAccessKeyName=defaultKeyName;` +
`SharedAccessKey=defaultKeyValue`;
const config = ConnectionConfig.create(connectionString);
config.webSocket = options && options.webSocket;
config.webSocketEndpointPath = "$servicebus/websocket";
config.webSocketConstructorOptions = options && options.webSocketConstructorOptions;
ConnectionConfig.validate(config);
return new ServiceBusClient(config, tokenProvider, options);
}static createFromConnectionString(
connectionString: string,
options?: ServiceBusClientOptions
): ServiceBusClient {
const config = ConnectionConfig.create(connectionString);
config.webSocket = options && options.webSocket;
config.webSocketEndpointPath = "$servicebus/websocket";
config.webSocketConstructorOptions = options && options.webSocketConstructorOptions;
ConnectionConfig.validate(config);
const tokenProvider = new SasTokenProvider(
config.endpoint,
config.sharedAccessKeyName,
config.sharedAccessKey
);
return new ServiceBusClient(config, tokenProvider, options);
}static createFromTokenProvider(
host: string,
tokenProvider: TokenProvider,
options?: ServiceBusClientOptions
): ServiceBusClient {
host = String(host);
if (!tokenProvider) {
throw new TypeError('Missing parameter "tokenProvider"');
}
if (!host.endsWith("/")) host += "/";
const connectionString =
`Endpoint=sb://${host};SharedAccessKeyName=defaultKeyName;` +
`SharedAccessKey=defaultKeyValue`;
const config = ConnectionConfig.create(connectionString);
config.webSocket = options && options.webSocket;
config.webSocketEndpointPath = "$servicebus/websocket";
config.webSocketConstructorOptions = options && options.webSocketConstructorOptions;
ConnectionConfig.validate(config);
return new ServiceBusClient(config, tokenProvider, options);
}static createFromConnectionString(
connectionString: string,
options?: ServiceBusClientOptions
): ServiceBusClient {
const config = ConnectionConfig.create(connectionString);
config.webSocket = options && options.webSocket;
config.webSocketEndpointPath = "$servicebus/websocket";
config.webSocketConstructorOptions = options && options.webSocketConstructorOptions;
ConnectionConfig.validate(config);
const tokenProvider = new SasTokenProvider(
config.endpoint,
config.sharedAccessKeyName,
config.sharedAccessKey
);
return new ServiceBusClient(config, tokenProvider, options);
}