+
+ private void checkAndPublishPortAddNotification(String subnetIp, Uuid subnetId, Uuid portId)throws InterruptedException{
+ PortAddedToSubnetBuilder builder = new PortAddedToSubnetBuilder();
+
+ LOG.info("publish notification called");
+
+ builder.setSubnetIp(subnetIp);
+ builder.setSubnetId(subnetId);
+ builder.setPortId(portId);
+
+ notificationPublishService.putNotification(builder.build());
+ }
+
+ private void checkAndPublishPortRemoveNotification(String subnetIp, Uuid subnetId, Uuid portId)throws InterruptedException{
+ PortRemovedFromSubnetBuilder builder = new PortRemovedFromSubnetBuilder();
+
+ LOG.info("publish notification called");
+
+ builder.setPortId(portId);
+ builder.setSubnetIp(subnetIp);
+ builder.setSubnetId(subnetId);
+
+ notificationPublishService.putNotification(builder.build());
+ }