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