public void dropConnection ( String name , String database ) { RequestExecutor requestExecutor = _store . getRequestExecutor ( ObjectUtils . firstNonNull ( database , _store . getDatabase ( ) ) ) ; DropSubscriptionConnectionCommand command = new DropSubscriptionConnectionCommand ( name ) ; requestExecutor . execute ( command ) ; }
Force server to close current client subscription connection to the server