JDK16 -> JDK 11 for Azure Spring Cloud

Updated README
Resource loading issue
Improved logging
WS vs WSS protocol

Author: NLxAROSA

README.md

@@ -23,10 +23,30 @@ Via RedisCDC these changes will appear in demo application #1.
 2. Make sure you are logged into the Azure CLI
 3. Add the Azure Spring Cloud extension to the Azure CLI `az extension add --name spring-cloud` If you already have the extension, make sure it's up to date using `az extension update --name spring-cloud`
 2. Create an Azure Spring Cloud instance using `az spring-cloud create -n acrebank -g rdsLroACRE -l northeurope` (this may take a few minutes)
-3. Create an App in the newly created Azure Spring Cloud instance using `az spring-cloud app create -n acrebankapp -s acrebank -g rdsLroACRE --assign-endpoint true`
+3. Create an App in the newly created Azure Spring Cloud instance using `az spring-cloud app create -n acrebankapp -s acrebank -g rdsLroACRE --assign-endpoint true --runtime-version Java_11`
 4. Modify the application.properties so it points to your newly created ACRE instance
-5. Rebuild the app using `./mvnw package`
-6. Deploy the app to Azure Spring Cloud using `az spring-cloud app deploy -n acrebankapp -s acrebank -g rdsLroAcre --jar-path target/redisbank-0.0.1-SNAPSHOT.jar`
 
-Demo shows 
+```
+spring.redis.host=your ACRE hostname
+spring.redis.port=your ACRE port (default: 10000)
+spring.redis.password= your ACRE access key
+```
 
+5. Modify the application.properties so the websocket config will point to the Azure Spring Cloud app instance endpoint createed in step 3.
+
+```
+stomp.host=your ASC app endpoint URL (Default: <appname>-<service-name>.azuremicroservices.io)
+stomp.port=443
+stomp.protocol=wss
+```
+
+6. Rebuild the app using `./mvnw package`
+7. Deploy the app to Azure Spring Cloud using `az spring-cloud app deploy -n acrebankapp -s acrebank -g rdsLroAcre --jar-path target/redisbank-0.0.1-SNAPSHOT.jar`
+
+## Troubleshooting tips on Azure Spring Cloud
+
+To get the application logs:
+
+`az spring-cloud app logs -n acrebankapp -g rdsLroAcre -s acrebank`
+
+Note: project is compiled with JDK11 as that's currently the max LTS version that's supported by Azure Spring Cloud. Project will run fine when running locally or on other platforms up to JDK16.

pom.xml

@@ -13,7 +13,7 @@
 	<name>redisbank</name>
 	<description>Demo project for Spring Boot</description>
 	<properties>
-		<java.version>16</java.version>
+		<java.version>11</java.version>
 	</properties>
 	<dependencies>
 		<dependency>

src/main/java/com/redislabs/demos/redisbank/SerializationUtil.java

@@ -1,6 +1,7 @@
 package com.redislabs.demos.redisbank;
 
 import java.io.File;
+import java.io.InputStream;
 import java.text.SimpleDateFormat;
 import java.util.Collections;
 import java.util.List;
@@ -25,9 +26,9 @@ public static <T> List<T> loadObjectList(Class<T> type, String fileName) {
         try {
             CsvSchema bootstrapSchema = CsvSchema.emptySchema().withHeader();
             CsvMapper mapper = new CsvMapper();
-            File file = new ClassPathResource(fileName).getFile();
+            InputStream is = new ClassPathResource(fileName).getInputStream();
             MappingIterator<T> readValues = 
-              mapper.readerFor(type).with(bootstrapSchema).readValues(file);
+              mapper.readerFor(type).with(bootstrapSchema).readValues(is);
             return readValues.readAll();
         } catch (Exception e) {
             LOGGER.error("Error occurred while loading object list from file " + fileName, e);

src/main/java/com/redislabs/demos/redisbank/transactions/BankTransactionForwarder.java

@@ -53,6 +53,7 @@ public void afterPropertiesSet() throws Exception {
 
     @Override
     public void onMessage(MapRecord<String, String, String> message) {
+        LOGGER.info("Message received from stream: {}", message);
         // Update search index whenever a new transaction arrives via the stream
         String messageString = message.getValue().get("transaction");
         try {
@@ -64,7 +65,7 @@ public void onMessage(MapRecord<String, String, String> message) {
 
         // Stream message to websocket connection topic
         smso.convertAndSend(config.getStomp().getTransactionsTopic(), message.getValue());
-        LOGGER.info("Streamed: {}", messageString);
+        LOGGER.info("Websocket message: {}", messageString);
 
     }
 

src/main/java/com/redislabs/demos/redisbank/transactions/BankTransactionGenerator.java

@@ -55,7 +55,7 @@ public BankTransactionGenerator(StringRedisTemplate redis, StatefulRediSearchCon
         this.redis = redis;
         this.connection = connection;
         this.tsc = rcf.getCommands(TimeSeriesCommands.class);
-        transactionSources = SerializationUtil.loadObjectList(TransactionSource.class, "transaction_sources.csv");
+        transactionSources = SerializationUtil.loadObjectList(TransactionSource.class, "/transaction_sources.csv");
         random = SecureRandom.getInstance("SHA1PRNG");
         random.setSeed("lars".getBytes("UTF-8")); // Prime the RNG so it always generates the same pseudorandom set
 
@@ -78,22 +78,25 @@ private void createSearchIndices() {
                 throw new RuntimeException(e);
             }
         }
-        LOGGER.info("Creating {} index", ACCOUNT_INDEX);
         commands.create(ACCOUNT_INDEX, Field.text("toAccountName").build());
+        LOGGER.info("Created {} index", ACCOUNT_INDEX);
 
-        LOGGER.info("Creating {} index", SEARCH_INDEX);
         commands.create(SEARCH_INDEX, Field.text("description").matcher(PhoneticMatcher.English).build(),
                 Field.text("fromAccountName").matcher(PhoneticMatcher.English).build(),
                 Field.text("transactionType").matcher(PhoneticMatcher.English).build());
+        LOGGER.info("Created {} index", SEARCH_INDEX);
     }
 
     private void deleteSortedSet() {
         redis.delete(SORTED_SET_KEY);
+        LOGGER.info("Deleted {} sorted set", SORTED_SET_KEY);
+
     }
 
     private void createTimeSeries() {
         redis.delete(BALANCE_TS);
         tsc.create(BALANCE_TS, 0);
+        LOGGER.info("Created {} time seris", BALANCE_TS);
     }
 
     private void createInitialStream() {
@@ -118,6 +121,7 @@ private void streamBankTransaction(BankTransaction bankTransaction) {
             transactionString = SerializationUtil.serializeObject(bankTransaction);
             update.put(TRANSACTION_KEY, transactionString);
             redis.opsForStream().add(TRANSACTIONS_STREAM, update);
+            LOGGER.info("Streamed {}", transactionString);
         } catch (JsonProcessingException e) {
             LOGGER.error("Error serialising object to JSON", e.getMessage());
         }

src/main/resources/application.properties

@@ -1,13 +1,17 @@
 stomp.host=localhost
 stomp.protocol=ws
 stomp.port=8080
-stomp.endpoint=/websocket
-stomp.destinationPrefix=/topic
-stomp.transactionsTopic=/topic/transactions
-
 spring.redis.host=localhost
 spring.redis.port=6379
 
-#spring.redis.host=lars5.northeurope.redisenterprise.cache.azure.net
+#stomp.host=<app>-<service>.azuremicroservices.io
+#stomp.protocol=wss
+#stomp.port=443
+#spring.redis.host=<name>.<region>.redisenterprise.cache.azure.net
 #spring.redis.port=10000
-#spring.redis.password=RzM8a9+p2VHu6ZWVwKWyHbHZBUc1jueNWLg8uQZPe9w=
+#spring.redis.password=
+
+stomp.endpoint=/websocket
+stomp.destinationPrefix=/topic
+stomp.transactionsTopic=/topic/transactions
+management.endpoints.web.exposure.include=env

src/main/resources/static/assets/js/transactions.js

@@ -100,7 +100,7 @@ var transactionsOverview = new Vue({
       axios.get(stompConfigUrl)
         .then(function (response) {
           var stompconfig = response.data
-          var url = 'ws://' + stompconfig.host + ':' + stompconfig.port + stompconfig.endpoint
+          var url = stompconfig.protocol + '://' + stompconfig.host + ':' + stompconfig.port + stompconfig.endpoint
           this.stompClient = Stomp.client(url)
 
           this.stompClient.connect(