0

I’m trying to write an integration for Azure Service Bus to receive messages from a topic/subscription. For this I created a Custom Java Action which seemingly connects but does not return any messages. I can run the code in a standalone Java application and it works well.  The dependencies (azure-messaging-servicebus and azure-identity) are bundled with Maven into a fat JAR. I call the Java Action from a Microflow (triggered by a button) and am currently running things locally in Studio Pro 9.10.2.  The Java Action contains the following: var logger = Core.getLogger("ServieBusAction"); logger.debug(String.format("Get creds...")); ClientSecretCredential credential = new ClientSecretCredentialBuilder() .tenantId("<...>") .clientId("<...>") .clientSecret("<...>") .build(); logger.debug(String.format("Get receiver...")); ServiceBusReceiverClient receiver = new ServiceBusClientBuilder() .credential("<...>", credential) .receiver() .maxAutoLockRenewDuration(Duration.ofMinutes(1)) .topicName("<...>") .subscriptionName("<...>") .buildClient(); logger.debug(String.format("Receive messages...")); ServiceBusReceivedMessage message = receiver .receiveMessages(1) .stream() .findAny() .orElse(null); String messageBody = ""; if (message != null) { messageBody = String.format("%s", message.getBody()); logger.debug(String.format("message body: %s", messageBody)); } receiver.close(); return messageBody; I can see the debug logs in the Console, including “Receive messages...”, then it just stalls. Any ideas? 

asked 2022-04-28

3 answers