diff --git a/narayana-spring-boot-core/src/main/java/me/snowdrop/boot/narayana/core/properties/NarayanaPropertiesInitializer.java b/narayana-spring-boot-core/src/main/java/me/snowdrop/boot/narayana/core/properties/NarayanaPropertiesInitializer.java index 6afed68b..2dc55289 100644 --- a/narayana-spring-boot-core/src/main/java/me/snowdrop/boot/narayana/core/properties/NarayanaPropertiesInitializer.java +++ b/narayana-spring-boot-core/src/main/java/me/snowdrop/boot/narayana/core/properties/NarayanaPropertiesInitializer.java @@ -16,9 +16,6 @@ package me.snowdrop.boot.narayana.core.properties; -import java.nio.charset.StandardCharsets; -import java.security.MessageDigest; -import java.security.NoSuchAlgorithmException; import java.util.List; import com.arjuna.ats.arjuna.common.CoordinatorEnvironmentBean; @@ -37,8 +34,6 @@ */ public class NarayanaPropertiesInitializer implements InitializingBean { - private static final String HASH_ALGORITHM_FOR_SHORTENING = "SHA-224"; - private final NarayanaProperties properties; public NarayanaPropertiesInitializer(NarayanaProperties narayanaProperties) { @@ -64,24 +59,13 @@ public void afterPropertiesSet() { } private void setNodeIdentifier(String nodeIdentifier) { - String verifiedNodeIdentifier = nodeIdentifier; try { - if (nodeIdentifier != null && nodeIdentifier.getBytes(StandardCharsets.UTF_8).length > 28) { - verifiedNodeIdentifier = shortenNodeIdentifier(nodeIdentifier); - } - - getPopulator(CoreEnvironmentBean.class).setNodeIdentifier(verifiedNodeIdentifier); - } catch (CoreEnvironmentBeanException | NoSuchAlgorithmException e) { + getPopulator(CoreEnvironmentBean.class).setNodeIdentifier(nodeIdentifier); + } catch (CoreEnvironmentBeanException e) { throw new IllegalArgumentException(e); } } - private String shortenNodeIdentifier(String nodeIdentifier) throws NoSuchAlgorithmException { - final byte[] nodeIdentifierAsBytes = nodeIdentifier.getBytes(); - MessageDigest messageDigest224 = MessageDigest.getInstance(HASH_ALGORITHM_FOR_SHORTENING); - return new String(messageDigest224.digest(nodeIdentifierAsBytes), StandardCharsets.UTF_8); - } - private void setXARecoveryNodes(List xaRecoveryNodes) { if (xaRecoveryNodes.isEmpty()) { xaRecoveryNodes = List.of(getPopulator(CoreEnvironmentBean.class).getNodeIdentifier());