public static Completable jedisPoolAdd ( CacheConfigBean cacheConfigBean ) { return SingleRxXian . call ( CacheService . CACHE_SERVICE , "jedisPoolAdd" , new JSONObject ( ) { { put ( "host" , cacheConfigBean . getHost ( ) ) ; put ( "port" , cacheConfigBean . getPort ( ) ) ; put ( "password" , cacheConfigBean . getPassword ( ) ) ; put ( "dbIndex" , cacheConfigBean . getDbIndex ( ) ) ; } } ) . map ( unitResponse -> { unitResponse . throwExceptionIfNotSuccess ( ) ; return unitResponse . succeeded ( ) ; } ) . toCompletable ( ) ; }
Add a cache datasource into the cache pool .