@ Override public Publisher < List < String > > getServiceIds ( ) { ServiceFilter serviceFilter = new ServiceFilter ( ) . withName ( "NAMESPACE_ID" ) . withValues ( getRoute53ClientDiscoveryConfiguration ( ) . getNamespaceId ( ) ) ; ListServicesRequest listServicesRequest = new ListServicesRequest ( ) . withFilters ( serviceFilter ) ; Future < ListServicesResult > response = getDiscoveryClient ( ) . listServicesAsync ( listServicesRequest ) ; Flowable < ListServicesResult > flowableList = Flowable . fromFuture ( response ) ; return flowableList . flatMap ( this :: convertServiceIds ) ; }
Gets a list of service IDs from AWS for a given namespace .