Class ServiceBusDestination<TInput>
A data flow destination for Azure service bus.
Inherited Members
Namespace: ETLBox.Azure.ServiceBus
Assembly: ETLBox.Azure.ServiceBus.dll
Syntax
public class ServiceBusDestination<TInput> : DataFlowBatchDestination<TInput>, IDataFlowLogging, IDataFlowBatchDestination<TInput>, IDataFlowDestination<TInput>, IDataFlowBatchDestination, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
| Name | Description |
|---|---|
| TInput | Type of incoming data |
Constructors
ServiceBusDestination()
Declaration
public ServiceBusDestination()
Properties
Client
The client that owns the connection and can be used to create senders and receivers.
Automatically created if you provide a ConnectionString, unless you provide your own instance here.
Declaration
public ServiceBusClient Client { get; set; }
Property Value
| Type | Description |
|---|---|
| ServiceBusClient |
ClientOptions
The client options used when instantiating a new client.
Declaration
public ServiceBusClientOptions ClientOptions { get; set; }
Property Value
| Type | Description |
|---|---|
| ServiceBusClientOptions |
ConnectionString
If you provide a namespace connection string, this component will create new ServiceBusClient and ServiceBusSender objects to communicate with the Azure Service Bus. If you need to reuse existing Client/Sender objects, you can provide your own via the Client and Sender properties.
Declaration
public string ConnectionString { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
MessageCreation
By default, your object is serialized into json and send as a ServiceBusMessage without additional parameters. Define your own serialization function here.
Declaration
public Func<TInput, ServiceBusMessage> MessageCreation { get; set; }
Property Value
| Type | Description |
|---|---|
| Func<TInput, ServiceBusMessage> |
QueueOrTopicName
Name of the destination queue or topic
Declaration
public string QueueOrTopicName { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
Sender
The sender used to publish messages to the queue. Automatically created from the Client.
Declaration
public ServiceBusSender Sender { get; }
Property Value
| Type | Description |
|---|---|
| ServiceBusSender |
SenderOptions
The sender options used when instantiating a new sender.
Declaration
public ServiceBusSenderOptions SenderOptions { get; set; }
Property Value
| Type | Description |
|---|---|
| ServiceBusSenderOptions |
TaskName
A name to identify the task or component. Every component or task comes with a default name that can be overwritten.
Declaration
public override string TaskName { get; set; }
Property Value
| Type | Description |
|---|---|
| string |
Overrides
Methods
BulkInsertData(TInput[])
Declaration
protected override void BulkInsertData(TInput[] data)
Parameters
| Type | Name | Description |
|---|---|---|
| TInput[] | data |
Overrides
CheckParameter()
Declaration
protected override void CheckParameter()
Overrides
FinishWrite()
Declaration
protected override void FinishWrite()
Overrides
PrepareParameter()
Declaration
protected override void PrepareParameter()
Overrides
PrepareWrite()
Declaration
protected override void PrepareWrite()