ServiceBusDestination<TInput>
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>, 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 |
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
PrepareParameterForCheck()
Declaration
protected override void PrepareParameterForCheck()
Overrides
PrepareWrite()
Declaration
protected override void PrepareWrite()