Skip to main content

Create Azure Service Bus

In this section, we will demonstrate how you can create a Service Bus instance in Microsoft Azure using Fractal Cloud.

Service bus with minimum requirements

AzureResourceGroup azureResourceGroup = AzureResourceGroup
.builder()
.withName("rg-service-bus")
.withRegion(EUROPE_WEST)
.build();

AzureServiceBus serviceBus = AzureServiceBus.builder()
.withId("sb-sample")
.withName("sb-sample")
.withRegion(AzureRegion.EUROPE_WEST)
.withAzureResourceGroup(azureResourceGroup)
.withSku(ServiceBusSku.builder()
.withTier(ServiceBusSkuTier.BASIC)
.build())
.build();

Service Bus will all settings available

AzureResourceGroup azureResourceGroup = AzureResourceGroup
.builder()
.withName("rg-service-bus")
.withRegion(EUROPE_WEST)
.build();
AzureServiceBus serviceBus = AzureServiceBus.builder()
.withId("sb-sample")
.withName("sb-sample")
.withRegion(AzureRegion.EUROPE_WEST)
.withAzureResourceGroup(azureResourceGroup)
.withSku(ServiceBusSku.builder()
.withCapacity(1)
.withTier(ServiceBusSkuTier.BASIC)
.build())
.withEncryption(Encryption.builder()
.withKeySource(KeySource.MICROSOFT_KEYVAULT)
.withRequireInfrastructureEncryption(Boolean.TRUE)
.withKeyVaultProperties(List.of(KeyVaultProperties.builder()
.withIdentity("identity")
.withKeyName("keyName")
.withKeyVaultUri("keyVaultUri")
.withKeyVersion("keyVaultVersion")
.build()))
.build())
.withIdentity(AzureIdentityType.SYSTEM_ASSIGNED)
.withDisableLocalAuth(null)
.withZoneRedundant(Boolean.FALSE)
.withQueue(AzureServiceBusQueue.builder()
.withId("queue-1")
.withAutoDeleteOnIdle(Duration.ofMinutes(1L))
.withDeadLetteringOnMessageExpiration(false)
.withDefaultMessageTimeToLive(Duration.ofMinutes(2))
.withDuplicateDetectionHistoryTimeWindow(Duration.ofSeconds(21))
.withEnableExpress(false)
.withEnableBatchedOperations(true)
.withEnablePartitioning(false)
.withForwardTo("forwardTo")
.withForwardDeadLetteredMessagesTo("forwardDeadLetteredMessagesTo")
.withLockDuration(Duration.ofMinutes(5))
.withMaxDeliveryCount(12)
.withMaxSizeInMegabytes(22)
.withMaxMessageSizeInKilobytes(300L)
.withRequiresSession(false)
.withRequiresDuplicateDetection(true)
.build())
.withTopic(AzureServiceBusTopic.builder()
.withId("topic-1")
.withAutoDeleteOnIdle(Duration.ofMinutes(2L))
.withDefaultMessageTimeToLive(Duration.ofMinutes(3))
.withDuplicateDetectionHistoryTimeWindow(Duration.ofSeconds(33))
.withEnableExpress(false)
.withEnableBatchedOperations(true)
.withEnablePartitioning(false)
.withMaxSizeInMegabytes(124)
.withMaxMessageSizeInKilobytes(500L)
.withRequiresDuplicateDetection(true)
.withSupportOrdering(false)
.build())
.build();