From 2919aadbb8661060fea26c408363341e4ea44118 Mon Sep 17 00:00:00 2001 From: Dhanendra Sahu Date: Wed, 24 Jun 2026 10:57:03 +0530 Subject: [PATCH 1/5] Fixed the slowstartup issue Signed-off-by: Dhanendra Sahu --- .../processor/message/sender/stage/MessageSenderStage.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java b/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java index e22c6f69fbb..db4ffce5e89 100644 --- a/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java +++ b/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java @@ -11,7 +11,6 @@ import org.json.simple.parser.ParseException; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; -import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.core.env.Environment; @@ -84,8 +83,6 @@ * @author M1048358 Alok * @since 1.0.0 */ -@RefreshScope - @Service @Configuration @ComponentScan(basePackages = { "${mosip.auth.adapter.impl.basepackage}", From 11e248ce181784986c7d538dd76db51db4545e5a Mon Sep 17 00:00:00 2001 From: Dhanendra Sahu Date: Thu, 25 Jun 2026 16:29:50 +0530 Subject: [PATCH 2/5] Fixed the race condition issue Signed-off-by: Dhanendra Sahu --- .../processor/message/sender/stage/MessageSenderStage.java | 5 +++-- .../quality/classifier/stage/QualityClassifierStage.java | 7 ++++--- .../notification/stage/SecurezoneNotificationStage.java | 7 ++++--- 3 files changed, 11 insertions(+), 8 deletions(-) diff --git a/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java b/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java index db4ffce5e89..b4c897e1efb 100644 --- a/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java +++ b/registration-processor/post-processor/registration-processor-message-sender-stage/src/main/java/io/mosip/registration/processor/message/sender/stage/MessageSenderStage.java @@ -184,8 +184,9 @@ public void deployVerticle() { */ @Override public void start() { - router.setRoute(this.postUrl(vertx, MessageBusAddress.MESSAGE_SENDER_BUS, null)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(vertx, MessageBusAddress.MESSAGE_SENDER_BUS, null); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* diff --git a/registration-processor/pre-processor/registration-processor-quality-classifier-stage/src/main/java/io/mosip/registration/processor/quality/classifier/stage/QualityClassifierStage.java b/registration-processor/pre-processor/registration-processor-quality-classifier-stage/src/main/java/io/mosip/registration/processor/quality/classifier/stage/QualityClassifierStage.java index 4a2dba73f42..5ebebdf5f5b 100644 --- a/registration-processor/pre-processor/registration-processor-quality-classifier-stage/src/main/java/io/mosip/registration/processor/quality/classifier/stage/QualityClassifierStage.java +++ b/registration-processor/pre-processor/registration-processor-quality-classifier-stage/src/main/java/io/mosip/registration/processor/quality/classifier/stage/QualityClassifierStage.java @@ -208,9 +208,10 @@ protected String getPropertyPrefix() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.QUALITY_CLASSIFIER_BUS_IN, - MessageBusAddress.QUALITY_CLASSIFIER_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.QUALITY_CLASSIFIER_BUS_IN, + MessageBusAddress.QUALITY_CLASSIFIER_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* diff --git a/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java b/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java index 5672a5b4c34..6bb2aa8eeb7 100644 --- a/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java +++ b/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java @@ -126,10 +126,11 @@ protected String getPropertyPrefix() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.SECUREZONE_NOTIFICATION_IN, - MessageBusAddress.SECUREZONE_NOTIFICATION_OUT)); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.SECUREZONE_NOTIFICATION_IN, + MessageBusAddress.SECUREZONE_NOTIFICATION_OUT); + router.setRoute(vertxRouter); this.routes(router); - this.createServer(router.getRouter(), getPort()); + this.createServer(vertxRouter, getPort()); } /** From 039fee50b066b77dc2205bede41bb05430414b26 Mon Sep 17 00:00:00 2001 From: Dhanendra Sahu Date: Fri, 26 Jun 2026 10:34:37 +0530 Subject: [PATCH 3/5] Fixed slow startup issue Signed-off-by: Dhanendra Sahu --- .../processor/abis/handler/stage/AbisHandlerStage.java | 7 ++++--- .../abis/middleware/stage/AbisMiddleWareStage.java | 7 ++++--- .../processor/biodedupe/stage/BioDedupeStage.java | 5 +++-- .../authentication/stage/BiometricAuthenticationStage.java | 7 ++++--- .../extraction/stage/BiometricExtractionStage.java | 7 ++++--- .../processor/stages/demodedupe/DemoDedupeStage.java | 5 +++-- .../stages/finalization/stage/FinalizationStage.java | 7 ++++--- .../adjudication/stage/ManualAdjudicationStage.java | 5 +++-- .../stages/uingenerator/stage/UinGeneratorStage.java | 7 ++++--- .../processor/verification/stage/VerificationStage.java | 5 +++-- .../packet/receiver/stage/PacketReceiverStage.java | 5 +++-- .../stage/CredentialRequestorStage.java | 7 ++++--- .../processor/stages/app/CMDValidatorStage.java | 7 ++++--- .../introducervalidator/IntroducerValidatorStage.java | 7 ++++--- .../stages/operatorvalidator/OperatorValidatorStage.java | 7 ++++--- .../stages/packetclassifier/PacketClassifierStage.java | 7 ++++--- .../packet/uploader/stage/PacketUploaderStage.java | 7 ++++--- .../stages/packet/validator/PacketValidatorStage.java | 7 ++++--- .../supervisorvalidator/SupervisorValidatorStage.java | 7 ++++--- 19 files changed, 71 insertions(+), 52 deletions(-) diff --git a/registration-processor/core-processor/registration-processor-abis-handler-stage/src/main/java/io/mosip/registration/processor/abis/handler/stage/AbisHandlerStage.java b/registration-processor/core-processor/registration-processor-abis-handler-stage/src/main/java/io/mosip/registration/processor/abis/handler/stage/AbisHandlerStage.java index 4507ed810dc..31590cd7727 100644 --- a/registration-processor/core-processor/registration-processor-abis-handler-stage/src/main/java/io/mosip/registration/processor/abis/handler/stage/AbisHandlerStage.java +++ b/registration-processor/core-processor/registration-processor-abis-handler-stage/src/main/java/io/mosip/registration/processor/abis/handler/stage/AbisHandlerStage.java @@ -220,9 +220,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.ABIS_HANDLER_BUS_IN, - MessageBusAddress.ABIS_HANDLER_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.ABIS_HANDLER_BUS_IN, + MessageBusAddress.ABIS_HANDLER_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/core-processor/registration-processor-abis-middleware-stage/src/main/java/io/mosip/registartion/processor/abis/middleware/stage/AbisMiddleWareStage.java b/registration-processor/core-processor/registration-processor-abis-middleware-stage/src/main/java/io/mosip/registartion/processor/abis/middleware/stage/AbisMiddleWareStage.java index 00363dc7e9f..d576212b703 100644 --- a/registration-processor/core-processor/registration-processor-abis-middleware-stage/src/main/java/io/mosip/registartion/processor/abis/middleware/stage/AbisMiddleWareStage.java +++ b/registration-processor/core-processor/registration-processor-abis-middleware-stage/src/main/java/io/mosip/registartion/processor/abis/middleware/stage/AbisMiddleWareStage.java @@ -220,9 +220,10 @@ public void setListener(Message message) { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.ABIS_MIDDLEWARE_BUS_IN, - MessageBusAddress.ABIS_MIDDLEWARE_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.ABIS_MIDDLEWARE_BUS_IN, + MessageBusAddress.ABIS_MIDDLEWARE_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } diff --git a/registration-processor/core-processor/registration-processor-bio-dedupe-stage/src/main/java/io/mosip/registration/processor/biodedupe/stage/BioDedupeStage.java b/registration-processor/core-processor/registration-processor-bio-dedupe-stage/src/main/java/io/mosip/registration/processor/biodedupe/stage/BioDedupeStage.java index ea1b41f7e15..1c75b3f36c2 100644 --- a/registration-processor/core-processor/registration-processor-bio-dedupe-stage/src/main/java/io/mosip/registration/processor/biodedupe/stage/BioDedupeStage.java +++ b/registration-processor/core-processor/registration-processor-bio-dedupe-stage/src/main/java/io/mosip/registration/processor/biodedupe/stage/BioDedupeStage.java @@ -65,8 +65,9 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.BIO_DEDUPE_BUS_IN, MessageBusAddress.BIO_DEDUPE_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.BIO_DEDUPE_BUS_IN, MessageBusAddress.BIO_DEDUPE_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/core-processor/registration-processor-biometric-authentication-stage/src/main/java/io/mosip/registration/processor/biometric/authentication/stage/BiometricAuthenticationStage.java b/registration-processor/core-processor/registration-processor-biometric-authentication-stage/src/main/java/io/mosip/registration/processor/biometric/authentication/stage/BiometricAuthenticationStage.java index 5c3d6b43bfe..17d763c82eb 100644 --- a/registration-processor/core-processor/registration-processor-biometric-authentication-stage/src/main/java/io/mosip/registration/processor/biometric/authentication/stage/BiometricAuthenticationStage.java +++ b/registration-processor/core-processor/registration-processor-biometric-authentication-stage/src/main/java/io/mosip/registration/processor/biometric/authentication/stage/BiometricAuthenticationStage.java @@ -120,9 +120,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.BIOMETRIC_AUTHENTICATION_BUS_IN, - MessageBusAddress.BIOMETRIC_AUTHENTICATION_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.BIOMETRIC_AUTHENTICATION_BUS_IN, + MessageBusAddress.BIOMETRIC_AUTHENTICATION_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/core-processor/registration-processor-biometric-extraction-stage/src/main/java/io/mosip/registration/processor/stages/biometric/extraction/stage/BiometricExtractionStage.java b/registration-processor/core-processor/registration-processor-biometric-extraction-stage/src/main/java/io/mosip/registration/processor/stages/biometric/extraction/stage/BiometricExtractionStage.java index ea65e0cbf44..e2ac4bce0c0 100644 --- a/registration-processor/core-processor/registration-processor-biometric-extraction-stage/src/main/java/io/mosip/registration/processor/stages/biometric/extraction/stage/BiometricExtractionStage.java +++ b/registration-processor/core-processor/registration-processor-biometric-extraction-stage/src/main/java/io/mosip/registration/processor/stages/biometric/extraction/stage/BiometricExtractionStage.java @@ -138,9 +138,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.BIOMETRIC_EXTRACTION_BUS_IN, - MessageBusAddress.BIOMETRIC_EXTRACTION_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.BIOMETRIC_EXTRACTION_BUS_IN, + MessageBusAddress.BIOMETRIC_EXTRACTION_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* diff --git a/registration-processor/core-processor/registration-processor-demo-dedupe-stage/src/main/java/io/mosip/registration/processor/stages/demodedupe/DemoDedupeStage.java b/registration-processor/core-processor/registration-processor-demo-dedupe-stage/src/main/java/io/mosip/registration/processor/stages/demodedupe/DemoDedupeStage.java index 22bdd5f484a..10eb0b7732a 100644 --- a/registration-processor/core-processor/registration-processor-demo-dedupe-stage/src/main/java/io/mosip/registration/processor/stages/demodedupe/DemoDedupeStage.java +++ b/registration-processor/core-processor/registration-processor-demo-dedupe-stage/src/main/java/io/mosip/registration/processor/stages/demodedupe/DemoDedupeStage.java @@ -61,8 +61,9 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.DEMO_DEDUPE_BUS_IN, MessageBusAddress.DEMO_DEDUPE_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.DEMO_DEDUPE_BUS_IN, MessageBusAddress.DEMO_DEDUPE_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/core-processor/registration-processor-finalization-stage/src/main/java/io/mosip/registration/processor/stages/finalization/stage/FinalizationStage.java b/registration-processor/core-processor/registration-processor-finalization-stage/src/main/java/io/mosip/registration/processor/stages/finalization/stage/FinalizationStage.java index efcdd01d7f8..803fd68e3b2 100644 --- a/registration-processor/core-processor/registration-processor-finalization-stage/src/main/java/io/mosip/registration/processor/stages/finalization/stage/FinalizationStage.java +++ b/registration-processor/core-processor/registration-processor-finalization-stage/src/main/java/io/mosip/registration/processor/stages/finalization/stage/FinalizationStage.java @@ -110,9 +110,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.FINALIZATION_BUS_IN, - MessageBusAddress.FINALIZATION_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.FINALIZATION_BUS_IN, + MessageBusAddress.FINALIZATION_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* diff --git a/registration-processor/core-processor/registration-processor-manual-adjudication-stage/src/main/java/io/mosip/registration/processor/adjudication/stage/ManualAdjudicationStage.java b/registration-processor/core-processor/registration-processor-manual-adjudication-stage/src/main/java/io/mosip/registration/processor/adjudication/stage/ManualAdjudicationStage.java index ec8622d298b..d619716c0b6 100644 --- a/registration-processor/core-processor/registration-processor-manual-adjudication-stage/src/main/java/io/mosip/registration/processor/adjudication/stage/ManualAdjudicationStage.java +++ b/registration-processor/core-processor/registration-processor-manual-adjudication-stage/src/main/java/io/mosip/registration/processor/adjudication/stage/ManualAdjudicationStage.java @@ -175,8 +175,9 @@ public void setListener(Message message) { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.MANUAL_ADJUDICATION_BUS_IN, MessageBusAddress.MANUAL_ADJUDICATION_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.MANUAL_ADJUDICATION_BUS_IN, MessageBusAddress.MANUAL_ADJUDICATION_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/core-processor/registration-processor-uin-generator-stage/src/main/java/io/mosip/registration/processor/stages/uingenerator/stage/UinGeneratorStage.java b/registration-processor/core-processor/registration-processor-uin-generator-stage/src/main/java/io/mosip/registration/processor/stages/uingenerator/stage/UinGeneratorStage.java index d28465ff294..3ade33ac7e2 100644 --- a/registration-processor/core-processor/registration-processor-uin-generator-stage/src/main/java/io/mosip/registration/processor/stages/uingenerator/stage/UinGeneratorStage.java +++ b/registration-processor/core-processor/registration-processor-uin-generator-stage/src/main/java/io/mosip/registration/processor/stages/uingenerator/stage/UinGeneratorStage.java @@ -1100,9 +1100,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.UIN_GENERATION_BUS_IN, - MessageBusAddress.UIN_GENERATION_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.UIN_GENERATION_BUS_IN, + MessageBusAddress.UIN_GENERATION_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } diff --git a/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java b/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java index 6f49bfe7845..846d45a881d 100644 --- a/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java +++ b/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java @@ -176,8 +176,9 @@ public void setListener(Message message) { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.MANUAL_ADJUDICATION_BUS_IN, MessageBusAddress.MANUAL_ADJUDICATION_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.MANUAL_ADJUDICATION_BUS_IN, MessageBusAddress.MANUAL_ADJUDICATION_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java b/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java index 7c0974b5f91..93062654365 100644 --- a/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java +++ b/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java @@ -112,9 +112,10 @@ public void deployVerticle() { */ @Override public void start() { - router.setRoute(this.postUrl(vertx, null, MessageBusAddress.PACKET_RECEIVER_OUT)); + io.vertx.ext.web.Router vertxRouter = this.postUrl(vertx, null, MessageBusAddress.PACKET_RECEIVER_OUT); + router.setRoute(vertxRouter); this.routes(router); - this.createServer(router.getRouter(), getPort()); + this.createServer(vertxRouter, getPort()); } /** diff --git a/registration-processor/post-processor/registration-processor-credential-requestor-stage/src/main/java/io/mosip/registration/processor/credentialrequestor/stage/CredentialRequestorStage.java b/registration-processor/post-processor/registration-processor-credential-requestor-stage/src/main/java/io/mosip/registration/processor/credentialrequestor/stage/CredentialRequestorStage.java index 7bd27746ccf..e18af8a8b4d 100644 --- a/registration-processor/post-processor/registration-processor-credential-requestor-stage/src/main/java/io/mosip/registration/processor/credentialrequestor/stage/CredentialRequestorStage.java +++ b/registration-processor/post-processor/registration-processor-credential-requestor-stage/src/main/java/io/mosip/registration/processor/credentialrequestor/stage/CredentialRequestorStage.java @@ -397,9 +397,10 @@ private void getAdditionalCredentialFields(String regId, String process, */ @Override public void start() { - router.setRoute(this.postUrl(getVertx(), - MessageBusAddress.CREDENTIAL_REQUESTOR_BUS_IN, MessageBusAddress.CREDENTIAL_REQUESTOR_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), + MessageBusAddress.CREDENTIAL_REQUESTOR_BUS_IN, MessageBusAddress.CREDENTIAL_REQUESTOR_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } public String generatePin() { diff --git a/registration-processor/pre-processor/registration-processor-cmd-validator-stage/src/main/java/io/mosip/registration/processor/stages/app/CMDValidatorStage.java b/registration-processor/pre-processor/registration-processor-cmd-validator-stage/src/main/java/io/mosip/registration/processor/stages/app/CMDValidatorStage.java index 0288cc59a5f..423117f8934 100644 --- a/registration-processor/pre-processor/registration-processor-cmd-validator-stage/src/main/java/io/mosip/registration/processor/stages/app/CMDValidatorStage.java +++ b/registration-processor/pre-processor/registration-processor-cmd-validator-stage/src/main/java/io/mosip/registration/processor/stages/app/CMDValidatorStage.java @@ -50,9 +50,10 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(getVertx(), - MessageBusAddress.CMD_VALIDATOR_BUS_IN, MessageBusAddress.CMD_VALIDATOR_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), + MessageBusAddress.CMD_VALIDATOR_BUS_IN, MessageBusAddress.CMD_VALIDATOR_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } diff --git a/registration-processor/pre-processor/registration-processor-introducer-validator-stage/src/main/java/io/mosip/registration/processor/stages/introducervalidator/IntroducerValidatorStage.java b/registration-processor/pre-processor/registration-processor-introducer-validator-stage/src/main/java/io/mosip/registration/processor/stages/introducervalidator/IntroducerValidatorStage.java index 3b2f0733297..4c843e7ef7f 100644 --- a/registration-processor/pre-processor/registration-processor-introducer-validator-stage/src/main/java/io/mosip/registration/processor/stages/introducervalidator/IntroducerValidatorStage.java +++ b/registration-processor/pre-processor/registration-processor-introducer-validator-stage/src/main/java/io/mosip/registration/processor/stages/introducervalidator/IntroducerValidatorStage.java @@ -56,9 +56,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.INTRODUCER_VALIDATOR_BUS_IN, - MessageBusAddress.INTRODUCER_VALIDATOR_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.INTRODUCER_VALIDATOR_BUS_IN, + MessageBusAddress.INTRODUCER_VALIDATOR_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override diff --git a/registration-processor/pre-processor/registration-processor-operator-validator-stage/src/main/java/io/mosip/registration/processor/stages/operatorvalidator/OperatorValidatorStage.java b/registration-processor/pre-processor/registration-processor-operator-validator-stage/src/main/java/io/mosip/registration/processor/stages/operatorvalidator/OperatorValidatorStage.java index 8d11369e599..ea73b3db10f 100644 --- a/registration-processor/pre-processor/registration-processor-operator-validator-stage/src/main/java/io/mosip/registration/processor/stages/operatorvalidator/OperatorValidatorStage.java +++ b/registration-processor/pre-processor/registration-processor-operator-validator-stage/src/main/java/io/mosip/registration/processor/stages/operatorvalidator/OperatorValidatorStage.java @@ -55,9 +55,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.OPERATOR_VALIDATOR_BUS_IN, - MessageBusAddress.OPERATOR_VALIDATOR_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.OPERATOR_VALIDATOR_BUS_IN, + MessageBusAddress.OPERATOR_VALIDATOR_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override 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 62ffc7eacfa..c59aceb4843 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 @@ -69,9 +69,10 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(getVertx(), - MessageBusAddress.PACKET_CLASSIFIER_BUS_IN, MessageBusAddress.PACKET_CLASSIFIER_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), + MessageBusAddress.PACKET_CLASSIFIER_BUS_IN, MessageBusAddress.PACKET_CLASSIFIER_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* diff --git a/registration-processor/pre-processor/registration-processor-packet-uploader-stage/src/main/java/io/mosip/registration/processor/packet/uploader/stage/PacketUploaderStage.java b/registration-processor/pre-processor/registration-processor-packet-uploader-stage/src/main/java/io/mosip/registration/processor/packet/uploader/stage/PacketUploaderStage.java index 4661b67a884..d56f835262a 100644 --- a/registration-processor/pre-processor/registration-processor-packet-uploader-stage/src/main/java/io/mosip/registration/processor/packet/uploader/stage/PacketUploaderStage.java +++ b/registration-processor/pre-processor/registration-processor-packet-uploader-stage/src/main/java/io/mosip/registration/processor/packet/uploader/stage/PacketUploaderStage.java @@ -79,9 +79,10 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.PACKET_UPLOADER_IN, - MessageBusAddress.PACKET_UPLOADER_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.PACKET_UPLOADER_IN, + MessageBusAddress.PACKET_UPLOADER_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* diff --git a/registration-processor/pre-processor/registration-processor-packet-validator-stage/src/main/java/io/mosip/registration/processor/stages/packet/validator/PacketValidatorStage.java b/registration-processor/pre-processor/registration-processor-packet-validator-stage/src/main/java/io/mosip/registration/processor/stages/packet/validator/PacketValidatorStage.java index 73dcdbc903d..39e42073e11 100644 --- a/registration-processor/pre-processor/registration-processor-packet-validator-stage/src/main/java/io/mosip/registration/processor/stages/packet/validator/PacketValidatorStage.java +++ b/registration-processor/pre-processor/registration-processor-packet-validator-stage/src/main/java/io/mosip/registration/processor/stages/packet/validator/PacketValidatorStage.java @@ -69,9 +69,10 @@ public void deployVerticle() { @Override public void start(){ - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.PACKET_VALIDATOR_BUS_IN, - MessageBusAddress.PACKET_VALIDATOR_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.PACKET_VALIDATOR_BUS_IN, + MessageBusAddress.PACKET_VALIDATOR_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } /* * (non-Javadoc) diff --git a/registration-processor/pre-processor/registration-processor-supervisor-validator-stage/src/main/java/io/mosip/registration/processor/stages/supervisorvalidator/SupervisorValidatorStage.java b/registration-processor/pre-processor/registration-processor-supervisor-validator-stage/src/main/java/io/mosip/registration/processor/stages/supervisorvalidator/SupervisorValidatorStage.java index 34cb6df0e39..74fa7ce41d6 100644 --- a/registration-processor/pre-processor/registration-processor-supervisor-validator-stage/src/main/java/io/mosip/registration/processor/stages/supervisorvalidator/SupervisorValidatorStage.java +++ b/registration-processor/pre-processor/registration-processor-supervisor-validator-stage/src/main/java/io/mosip/registration/processor/stages/supervisorvalidator/SupervisorValidatorStage.java @@ -55,9 +55,10 @@ public void deployVerticle() { @Override public void start() { - router.setRoute(this.postUrl(getVertx(), MessageBusAddress.SUPERVISOR_VALIDATOR_BUS_IN, - MessageBusAddress.SUPERVISOR_VALIDATOR_BUS_OUT)); - this.createServer(router.getRouter(), getPort()); + io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.SUPERVISOR_VALIDATOR_BUS_IN, + MessageBusAddress.SUPERVISOR_VALIDATOR_BUS_OUT); + router.setRoute(vertxRouter); + this.createServer(vertxRouter, getPort()); } @Override From 00802a2ec81713db10b4e96dea1e228222a42693 Mon Sep 17 00:00:00 2001 From: Dhanendra Sahu Date: Fri, 26 Jun 2026 17:36:08 +0530 Subject: [PATCH 4/5] Fixed slow startup issue Signed-off-by: Dhanendra Sahu --- .../verification/stage/VerificationStage.java | 2 -- .../packet/receiver/stage/PacketReceiverStage.java | 13 ++++++------- .../stages/config/PacketClassifierConfig.java | 2 -- .../packetclassifier/PacketClassifierStage.java | 2 -- .../stage/SecurezoneNotificationStage.java | 7 ++++--- .../core/abstractverticle/MosipRouter.java | 5 +++++ 6 files changed, 15 insertions(+), 16 deletions(-) diff --git a/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java b/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java index 846d45a881d..f2424766bb9 100644 --- a/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java +++ b/registration-processor/core-processor/registration-processor-verification-stage/src/main/java/io/mosip/registration/processor/verification/stage/VerificationStage.java @@ -9,7 +9,6 @@ import org.apache.activemq.command.ActiveMQTextMessage; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; -import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.core.env.Environment; @@ -48,7 +47,6 @@ * @author Pranav Kumar * @since 0.0.1 */ -@RefreshScope @Service @Configuration @ComponentScan(basePackages = { "${mosip.auth.adapter.impl.basepackage}", diff --git a/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java b/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java index 93062654365..8cb638c1b3a 100644 --- a/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java +++ b/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java @@ -12,7 +12,6 @@ import org.apache.commons.io.FileUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; -import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.core.env.Environment; @@ -42,7 +41,6 @@ * The Class PacketReceiverStage. */ -@RefreshScope @Service @Configuration @ComponentScan(basePackages = { "${mosip.auth.adapter.impl.basepackage}", @@ -114,7 +112,7 @@ public void deployVerticle() { public void start() { io.vertx.ext.web.Router vertxRouter = this.postUrl(vertx, null, MessageBusAddress.PACKET_RECEIVER_OUT); router.setRoute(vertxRouter); - this.routes(router); + this.routes(router, vertxRouter); this.createServer(vertxRouter, getPort()); } @@ -123,12 +121,13 @@ public void start() { * * @param router * the router + * @param vertxRouter + * the vertx router */ - private void routes(MosipRouter router) { - - router.post(getServletPath() + "/registrationpackets"); + private void routes(MosipRouter router, io.vertx.ext.web.Router vertxRouter) { + router.post(vertxRouter, getServletPath() + "/registrationpackets"); router.handler(this::processURL, this::processPacket, this::failure); - }; + } /** * This is for failure handler. diff --git a/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/config/PacketClassifierConfig.java b/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/config/PacketClassifierConfig.java index df392ba9b7e..e445ea5d7f3 100644 --- a/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/config/PacketClassifierConfig.java +++ b/registration-processor/pre-processor/registration-processor-packet-classifier-stage/src/main/java/io/mosip/registration/processor/stages/config/PacketClassifierConfig.java @@ -1,6 +1,5 @@ package io.mosip.registration.processor.stages.config; -import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -14,7 +13,6 @@ * The beans belonging to other libraries has their own config class to declare the required beans */ @Configuration -@RefreshScope public class PacketClassifierConfig { @Bean 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 c59aceb4843..a2d7675cd75 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 @@ -2,7 +2,6 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; -import org.springframework.cloud.context.config.annotation.RefreshScope; import org.springframework.context.annotation.ComponentScan; import org.springframework.context.annotation.Configuration; import org.springframework.stereotype.Service; @@ -19,7 +18,6 @@ * * @author Vishwanath V */ -@RefreshScope @Service @Configuration @ComponentScan(basePackages = { "${mosip.auth.adapter.impl.basepackage}", diff --git a/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java b/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java index 6bb2aa8eeb7..9f93ac20513 100644 --- a/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java +++ b/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java @@ -129,7 +129,7 @@ public void start() { io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.SECUREZONE_NOTIFICATION_IN, MessageBusAddress.SECUREZONE_NOTIFICATION_OUT); router.setRoute(vertxRouter); - this.routes(router); + this.routes(router, vertxRouter); this.createServer(vertxRouter, getPort()); } @@ -137,9 +137,10 @@ public void start() { * contains all the routes in this stage * * @param router + * @param vertxRouter */ - private void routes(MosipRouter router) { - router.post(getServletPath() + "/notification"); + private void routes(MosipRouter router, io.vertx.ext.web.Router vertxRouter) { + router.post(vertxRouter, getServletPath() + "/notification"); router.handler(this::processURL, this::failure); } diff --git a/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java b/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java index eecf57d03e6..5edf318ea28 100644 --- a/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java +++ b/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java @@ -58,6 +58,11 @@ public Route post(String url) { return this.route; } + public Route post(Router specificRouter, String url) { + this.route = specificRouter.post(url); + return this.route; + } + /** * this method is used to handle request and failure handler including * validation of token From 675d6647a338dcf774fb13e3101a3349431bad30 Mon Sep 17 00:00:00 2001 From: Dhanendra Sahu Date: Fri, 26 Jun 2026 18:00:23 +0530 Subject: [PATCH 5/5] reverted the changes Signed-off-by: Dhanendra Sahu --- .../packet/receiver/stage/PacketReceiverStage.java | 8 +++----- .../notification/stage/SecurezoneNotificationStage.java | 7 +++---- .../processor/core/abstractverticle/MosipRouter.java | 5 ----- 3 files changed, 6 insertions(+), 14 deletions(-) diff --git a/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java b/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java index 8cb638c1b3a..97374355bdf 100644 --- a/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java +++ b/registration-processor/init/registration-processor-packet-receiver-stage/src/main/java/io/mosip/registration/processor/packet/receiver/stage/PacketReceiverStage.java @@ -112,7 +112,7 @@ public void deployVerticle() { public void start() { io.vertx.ext.web.Router vertxRouter = this.postUrl(vertx, null, MessageBusAddress.PACKET_RECEIVER_OUT); router.setRoute(vertxRouter); - this.routes(router, vertxRouter); + this.routes(router); this.createServer(vertxRouter, getPort()); } @@ -121,11 +121,9 @@ public void start() { * * @param router * the router - * @param vertxRouter - * the vertx router */ - private void routes(MosipRouter router, io.vertx.ext.web.Router vertxRouter) { - router.post(vertxRouter, getServletPath() + "/registrationpackets"); + private void routes(MosipRouter router) { + router.post(getServletPath() + "/registrationpackets"); router.handler(this::processURL, this::processPacket, this::failure); } diff --git a/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java b/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java index 9f93ac20513..6bb2aa8eeb7 100644 --- a/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java +++ b/registration-processor/pre-processor/registration-processor-securezone-notification-stage/src/main/java/io/mosip/registration/processor/securezone/notification/stage/SecurezoneNotificationStage.java @@ -129,7 +129,7 @@ public void start() { io.vertx.ext.web.Router vertxRouter = this.postUrl(getVertx(), MessageBusAddress.SECUREZONE_NOTIFICATION_IN, MessageBusAddress.SECUREZONE_NOTIFICATION_OUT); router.setRoute(vertxRouter); - this.routes(router, vertxRouter); + this.routes(router); this.createServer(vertxRouter, getPort()); } @@ -137,10 +137,9 @@ public void start() { * contains all the routes in this stage * * @param router - * @param vertxRouter */ - private void routes(MosipRouter router, io.vertx.ext.web.Router vertxRouter) { - router.post(vertxRouter, getServletPath() + "/notification"); + private void routes(MosipRouter router) { + router.post(getServletPath() + "/notification"); router.handler(this::processURL, this::failure); } diff --git a/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java b/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java index 5edf318ea28..eecf57d03e6 100644 --- a/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java +++ b/registration-processor/registration-processor-core/src/main/java/io/mosip/registration/processor/core/abstractverticle/MosipRouter.java @@ -58,11 +58,6 @@ public Route post(String url) { return this.route; } - public Route post(Router specificRouter, String url) { - this.route = specificRouter.post(url); - return this.route; - } - /** * this method is used to handle request and failure handler including * validation of token