Index: branches/APG_ES_Product/Java/nsight-product-availability/src/main/java/com/genpt/nsight/v4/controller/InventoryVerificationController.java =================================================================== diff -u -r251601 -r256469 --- branches/APG_ES_Product/Java/nsight-product-availability/src/main/java/com/genpt/nsight/v4/controller/InventoryVerificationController.java (.../InventoryVerificationController.java) (revision 251601) +++ branches/APG_ES_Product/Java/nsight-product-availability/src/main/java/com/genpt/nsight/v4/controller/InventoryVerificationController.java (.../InventoryVerificationController.java) (revision 256469) @@ -20,6 +20,7 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.annotation.Value; import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; @@ -47,6 +48,9 @@ @Autowired private AsyncPubsubPublisher asyncPubsubPublisher; + @Value("${inventory.publishVerification}") + private boolean publishVerification; + @Autowired public void setProductAvailabilityVerificationV4(ProductAvailabilityVerificationV4 productAvailabilityVerificationV4) { this.productAvailabilityVerificationV4 = productAvailabilityVerificationV4; @@ -102,7 +106,8 @@ com.genpt.nsight.v2.model.ProductAvailabilityResponse finalProductAvailabilityResponse = productAvailabilityResponse; // spawn a thread try { - asyncPubsubPublisher.triggerPublish(finalProductAvailabilityResponse); + if(publishVerification) + asyncPubsubPublisher.triggerPublish(finalProductAvailabilityResponse); } catch (Exception e) { throw new RuntimeException(e); }