From a2251876e2eca93ca27ec6f6adb9c712c1a3116d Mon Sep 17 00:00:00 2001 From: Monobikash Das <43202165+MonobikashDas@users.noreply.github.com> Date: Fri, 18 Jun 2021 11:52:25 +0530 Subject: [PATCH] MOR-96 : fixed hazelcast nullpointer (#1017) Co-authored-by: Monobikash Das --- .../manual/verification/stage/ManualVerificationStage.java | 2 +- .../processor/reprocessor/stage/ReprocessorStage.java | 2 +- .../stages/packetclassifier/PacketClassifierStage.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/registration-processor/core-processor/registration-processor-manual-verification-stage/src/main/java/io/mosip/registration/processor/manual/verification/stage/ManualVerificationStage.java b/registration-processor/core-processor/registration-processor-manual-verification-stage/src/main/java/io/mosip/registration/processor/manual/verification/stage/ManualVerificationStage.java index 7cb43f3a3d7..dbd923ad973 100644 --- a/registration-processor/core-processor/registration-processor-manual-verification-stage/src/main/java/io/mosip/registration/processor/manual/verification/stage/ManualVerificationStage.java +++ b/registration-processor/core-processor/registration-processor-manual-verification-stage/src/main/java/io/mosip/registration/processor/manual/verification/stage/ManualVerificationStage.java @@ -178,7 +178,7 @@ public void setListener(Message message) { @Override public void start() { - router.setRoute(this.postUrl(mosipEventBus.getEventbus(), MessageBusAddress.MANUAL_VERIFICATION_BUS_IN, MessageBusAddress.MANUAL_VERIFICATION_BUS_OUT)); + router.setRoute(this.postUrl(getVertx(), MessageBusAddress.MANUAL_VERIFICATION_BUS_IN, MessageBusAddress.MANUAL_VERIFICATION_BUS_OUT)); this.createServer(router.getRouter(), Integer.parseInt(port)); } diff --git a/registration-processor/core-processor/registration-processor-reprocessor-stage/src/main/java/io/mosip/registration/processor/reprocessor/stage/ReprocessorStage.java b/registration-processor/core-processor/registration-processor-reprocessor-stage/src/main/java/io/mosip/registration/processor/reprocessor/stage/ReprocessorStage.java index cac07b18362..6906053b32d 100644 --- a/registration-processor/core-processor/registration-processor-reprocessor-stage/src/main/java/io/mosip/registration/processor/reprocessor/stage/ReprocessorStage.java +++ b/registration-processor/core-processor/registration-processor-reprocessor-stage/src/main/java/io/mosip/registration/processor/reprocessor/stage/ReprocessorStage.java @@ -106,7 +106,7 @@ public class ReprocessorStage extends MosipVerticleAPIManager { */ public void deployVerticle() { mosipEventBus = this.getEventBus(this, clusterManagerUrl); - deployScheduler(mosipEventBus.getEventbus()); + deployScheduler(getVertx()); } diff --git a/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/packetclassifier/PacketClassifierStage.java b/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/packetclassifier/PacketClassifierStage.java index a228c89af78..911c9eaeb60 100644 --- a/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/packetclassifier/PacketClassifierStage.java +++ b/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/packetclassifier/PacketClassifierStage.java @@ -62,7 +62,7 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(mosipEventBus.getEventbus(), + router.setRoute(this.postUrl(getVertx(), MessageBusAddress.PACKET_CLASSIFIER_BUS_IN, MessageBusAddress.PACKET_CLASSIFIER_BUS_OUT)); this.createServer(router.getRouter(), Integer.parseInt(port)); }