diff --git a/build.gradle b/build.gradle index b6b6d9a..6b3d00c 100644 --- a/build.gradle +++ b/build.gradle @@ -15,7 +15,7 @@ repositories { } } -ext.fineractVersion = '0.0.267-41719d25' +ext.fineractVersion = '0.0.390-00e2880' dependencies { implementation 'org.springframework.boot:spring-boot-starter-activemq' diff --git a/src/main/java/org/test/consumer/service/MessageConsumerServiceImpl.java b/src/main/java/org/test/consumer/service/MessageConsumerServiceImpl.java index 7034c37..3a7fb79 100644 --- a/src/main/java/org/test/consumer/service/MessageConsumerServiceImpl.java +++ b/src/main/java/org/test/consumer/service/MessageConsumerServiceImpl.java @@ -30,7 +30,7 @@ public List getMessages() { eventMessages = convertToReadableFormat(messages); } catch (ClassNotFoundException | NoSuchMethodException | InvocationTargetException | IllegalAccessException e) { - log.error("Unable to read message", e); + throw new RuntimeException("Unable to read messages", e); } return eventMessages; } @@ -43,7 +43,7 @@ public List getMessagesByType(String eventType) { eventMessages = convertToReadableFormat(messages); } catch (ClassNotFoundException | NoSuchMethodException | InvocationTargetException | IllegalAccessException e) { - log.error("Unable to read message", e); + throw new RuntimeException("Unable to read messages", e); } return eventMessages; }