Method constructor

src/queue/QueueServer.ts:53–142

* Creates an instance of Server. * * @param {BlobConfiguration} configuration * @memberof Server

(configuration?: QueueConfiguration)

   * @memberof Server
   */
  constructor(configuration?: QueueConfiguration) {
    if (configuration === undefined) {
      configuration = new QueueConfiguration();
    }

    const host = configuration.host;
    const port = configuration.port;

    // We can create a HTTP server or a HTTPS server here
    let httpServer;
    const certOption = configuration.hasCert();
    switch (certOption) {
      case CertOptions.PEM:
      case CertOptions.PFX:
        httpServer = https.createServer(configuration.getCert(certOption)!);
        break;
      default:
        httpServer = http.createServer();
    }

    if (configuration.keepAliveTimeout > 0) {
      httpServer.keepAliveTimeout = configuration.keepAliveTimeout * 1000
    }

    // We can change the persistency layer implementation by
    // creating a new XXXDataStore class implementing IBlobDataStore interface
    // and replace the default LokiBlobDataStore
    const metadataStore: IQueueMetadataStore = new LokiQueueMetadataStore(
      configuration.metadataDBPath,
      configuration.isMemoryPersistence
    );

    const extentMetadataStore = new LokiExtentMetadataStore(
      configuration.extentDBPath,
      configuration.isMemoryPersistence
    );

    const extentStore: IExtentStore = configuration.isMemoryPersistence ? new MemoryExtentStore(
      "queue",
      configuration.memoryStore ?? SharedChunkStore,
      extentMetadataStore,
      logger,
      (sc, er, em, ri) => new StorageError(sc, er, em, ri)
    ) : new FSExtentStore(
      extentMetadataStore,
      configuration.persistencePathArray,
      logger
    );

    const accountDataStore: IAccountDataStore = new AccountDataStore(logger);

    // We can also change the HTTP framework here by
    // creating a new XXXListenerFactory implementing IRequestListenerFactory interface
    // and replace the default Express based request listener
    const requestListenerFactory: IRequestListenerFactory = new QueueRequestListenerFactory(
      metadataStore,
      extentStore,
      accountDataStore,