We will be sunsetting Advisor during Jan, 2026 and will instead be providing information in Snyk Security DB.

You can begin to take advantage of Snyk Security DB today for a unified, package-centric experience.

How to use the @azure/amqp-common.ConnectionConfig.validate function in @azure/amqp-common

To help you get started, we’ve selected a few @azure/amqp-common examples, based on popular ways it is used in public projects.

Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.

github Azure / azure-sdk-for-js / sdk / servicebus / service-bus / src / serviceBusClient.ts View on Github external
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);
  }
github Azure / azure-sdk-for-js / sdk / servicebus / service-bus / src / serviceBusClient.ts View on Github external
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);
  }
github Azure / azure-sdk-for-js / sdk / servicebus / service-bus / src / serviceBusClient.ts View on Github external
): 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);
  }
github Azure / azure-sdk-for-js / sdk / servicebus / service-bus / src / serviceBusClient.ts View on Github external
): 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);
  }