@@ -30,7 +30,13 @@ import { Response } from "./responses/response"
3030import { SaslAuthenticateResponse } from "./responses/sasl_authenticate_response"
3131import { SaslHandshakeResponse } from "./responses/sasl_handshake_response"
3232import { TuneResponse } from "./responses/tune_response"
33- import { DEFAULT_FRAME_MAX , DEFAULT_UNLIMITED_FRAME_MAX , REQUIRED_MANAGEMENT_VERSION , removeFrom } from "./util"
33+ import {
34+ DEFAULT_FRAME_MAX ,
35+ DEFAULT_UNLIMITED_FRAME_MAX ,
36+ REQUIRED_MANAGEMENT_VERSION ,
37+ isString ,
38+ removeFrom ,
39+ } from "./util"
3440import { Version , checkServerDeclaredVersions , getClientSupportedVersions } from "./versions"
3541import { WaitingResponse } from "./waiting_response"
3642import { ClientListenersParams , ClientParams , ClosingParams , QueryOffsetParams , StoreOffsetParams } from "./client"
@@ -474,7 +480,7 @@ export class Connection {
474480
475481 private async open ( params : { virtualHost : string } ) {
476482 this . logger . debug ( `Open ...` )
477- if ( this . virtualHostIsNotValid ( params . virtualHost ) ) {
483+ if ( ! this . virtualHostIsValid ( params . virtualHost ) ) {
478484 const errorMessage = `[ERROR]: VirtualHost '${ params . virtualHost } ' is not valid`
479485 this . logger . error ( errorMessage )
480486 return { ok : false , error : new Error ( errorMessage ) }
@@ -487,8 +493,8 @@ export class Connection {
487493 return { ok : true , response : res }
488494 }
489495
490- private virtualHostIsNotValid ( virtualHost : string ) {
491- if ( ! virtualHost ) {
496+ private virtualHostIsValid ( virtualHost : string ) {
497+ if ( isString ( virtualHost ) && virtualHost . length > 0 ) {
492498 return true
493499 }
494500
0 commit comments