query { 
  productSelectWhere
  ( searchBy: "  productId > 5 and  productType = 'Medicine' and productDesc containsIgnoreCase 'vitamin'  " , 
    sortBy: " productId Desc " , 
	page: 1, 
	size: 10
	) { 
	productId  
	productType  
	productDesc  
	} 
} 

@QueryMapping  
public List ProductDataMesh() {
  ...
  System.out.println("Data Mesh Source #1 Record Count: "+productList.size()); 

  // ---- Combine Data With ------ Get data from GraphQL API call  
  String get_data_url = "http://127.0.0.1:9080/graphql"; 
  WebClient webClient1 = WebClient.builder().baseUrl(get_data_url) 
  .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE).build(); 

  HttpGraphQlClient graphQlClient = HttpGraphQlClient.builder(webClient1).build(); 
  ...

{
  "data": {
    "InventoryProductFindOne": {
      "invId": 1,
      "invDate": "19/02/23",
      "invQty": 1050,
      "invLocation": "USA Warehouse 01",
      "Product": {
        "productId": 1,
        "productName": "Amoxicillin",
        "productCategory": "Antibiotics",
        "primarySupplier": "Lupin"
      }
    }
  }
}

subscription { 
  notifyproductTblQuery
	  (productId: 10) { 
	productId  
	productType  
	productDesc  
	} 
} 

//Function<I, O> 
public Function<Product, Product> ProductCfFunction() {
...

//Supplier<O>
public Supplier<Flux<List<Product>>> ProductCfSupplierFlux(long productId) { 
...

//Consumer<I>
public Consumer<Product> ProductCfConsumer () { 
...