Check the design, if we close the leg then getting exception

java.lang.NullPointerException: Cannot invoke "String.equals(Object)" because the return value of "com.optscalp.internal.order.model.LegCloseOrder.getMonitoringId()" is null
at com.optscalp.internal.api.BasePort.lambda$onClose$3(BasePort.java:245)
at java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:196)
at java.base/java.util.concurrent.ConcurrentHashMap$ValueSpliterator.tryAdvance(ConcurrentHashMap.java:3625)
at java.base/java.util.stream.ReferencePipeline.forEachWithCancel(ReferencePipeline.java:147)
at java.base/java.util.stream.AbstractPipeline.copyIntoWithCancel(AbstractPipeline.java:588)
at java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:574)
at java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:560)
at java.base/java.util.stream.FindOps$FindOp.evaluateSequential(FindOps.java:150)
at java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:265)
at java.base/java.util.stream.ReferencePipeline.findFirst(ReferencePipeline.java:687)
at com.optscalp.internal.api.BasePort.onClose(BasePort.java:245)
at com.optscalp.internal.api.BasePort.onCloseLeg(BasePort.java:213)
at com.optscalp.internal.order.api.LegServiceImpl.updateLegStatusForCloseOrderUpdate(LegServiceImpl.java:305)
at com.optscalp.internal.feed.OrderFeedSubscriberImpl.onOrderUpdate(OrderFeedSubscriberImpl.java:47)
at com.optscalp.internal.feed.OrderFeedPublisherImpl.publish(OrderFeedPublisherImpl.java:29)
at com.optscalp.internal.util.FQueueOrderUpdateConsumer.consume(FQueueOrderUpdateConsumer.java:25)
at io.fulmicotone.fqueue.FQueue.lambda$consumeBatching$3(FQueue.java:231)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:572)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:317)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
at java.base/java.lang.Thread.run(Thread.java:1575)