Azure Servicebus Sink
Provided by: "Apache Software Foundation"
Support Level for this Kamelet is: "Stable"
Send Messages to Azure Servicebus.
Configuration Options
The following table summarizes the configuration options available for the azure-servicebus-sink Kamelet:
| Property | Name | Description | Type | Default | Example |
|---|---|---|---|---|---|
Connection String | Required Connection String for Azure Servicebus instance. | string | |||
Topic Or Queue Name | Required Topic Or Queue Name for the Azure Servicebus instance. | string | |||
Credential Type | Determines the credential strategy to adopt. Enum values: * AZURE_IDENTITY * CONNECTION_STRING * TOKEN_CREDENTIAL | string | CONNECTION_STRING | ||
Servicebus Type | The service bus type of connection to execute. Queue is for typical queue option and topic for subscription based model. Enum values: * queue * topic | string | queue |
Dependencies
At runtime, the azure-servicebus-sink Kamelet relies upon the presence of the following dependencies:
-
camel:azure-servicebus
-
camel:kamelet
-
camel:core
Camel JBang usage
Prerequisites
-
You’ve installed JBang.
-
You have executed the following command:
jbang app install camel@apache/camel Supposing you have a file named route.yaml with this content:
- route:
from:
uri: "kamelet:timer-source"
parameters:
period: 10000
message: 'test'
steps:
- to:
uri: "kamelet:azure-servicebus-sink" You can now run it directly through the following command
camel run route.yaml Azure Servicebus Sink Kamelet Description
Authentication methods
In this Kamelet, you can use these Azure authentication methods:
-
Azure Identity mechanism:
AZURE_IDENTITY -
Connection string:
CONNECTION_STRING -
Token credentials:
TOKEN_CREDENTIAL
The order of evaluation for AZURE_IDENTITY is the following:
-
Enviroment
-
Workload Identity
-
Managed Identity
-
Azure Developer CLI
-
IntelliJ
-
Azure CLI
-
Azure Powershell
For more information, see the Azure Identity documentation
For TOKEN_CREDENTIAL type, you’ll need to add com.azure.core.credential.TokenCredential instance in the Camel registry.