Using Service Bus from .NET with AMQP 1.0

Downloading the Service Bus SDK

AMQP 1.0 support is available in the Service Bus SDK version 2.1 or later. You can ensure you have the latest version by downloading the Service Bus bits from NuGet.

Configuring .NET applications to use AMQP 1.0

By default, the Service Bus .NET client library communicates with the Service Bus service using a dedicated SOAP-based protocol. To use AMQP 1.0 instead of the default protocol requires explicit configuration on the Service Bus connection string, as described in the next section. Other than this change, application code remains unchanged when using AMQP 1.0.

In the current release, there are a few API features that are not supported when using AMQP. These unsupported features are listed later in the section Unsupported features, restrictions, and behavioral differences. Some of the advanced configuration settings also have a different meaning when using AMQP.

Configuration using App.config

It is good practice for applications to use the App.config configuration file to store settings. For Service Bus applications, you can use App.config to store the Service Bus connection string. An example App.config file is as follows:

<?xml version="1.0" encoding="utf-8" ?>
        <add key="Microsoft.ServiceBus.ConnectionString"
             value="Endpoint=sb://[namespace];SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=[SAS key];TransportType=Amqp" />

The value of the Microsoft.ServiceBus.ConnectionString setting is the Service Bus connection string that is used to configure the connection to Service Bus. The format is as follows:

Endpoint=sb://[namespace];SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=[SAS key];TransportType=Amqp

Where [namespace] and SharedAccessKey are obtained from the Azure portal when you create a Service Bus namespace. For more information, see Create a Service Bus namespace using the Azure portal.

When using AMQP, append the connection string with ;TransportType=Amqp. This notation instructs the client library to make its connection to Service Bus using AMQP 1.0.

Message serialization

When using the default protocol, the default serialization behavior of the .NET client library is to use the DataContractSerializer type to serialize a BrokeredMessage instance for transport between the client library and the Service Bus service. When using the AMQP transport mode, the client library uses the AMQP type system for serialization of the brokered message into an AMQP message. This serialization enables the message to be received and interpreted by a receiving application that is potentially running on a different platform, for example, a Java application that uses the JMS API to access Service Bus.

When you construct a BrokeredMessage instance, you can provide a .NET object as a parameter to the constructor to serve as the body of the message. For objects that can be mapped to AMQP primitive types, the body is serialized into AMQP data types. If the object cannot be directly mapped into an AMQP primitive type; that is, a custom type defined by the application, then the object is serialized using the DataContractSerializer, and the serialized bytes are sent in an AMQP data message.

To facilitate interoperability with non-.NET clients, use only .NET types that can be serialized directly into AMQP types for the body of the message. The following table details those types and the corresponding mapping to the AMQP type system.

.NET Body Object Type Mapped AMQP Type AMQP Body Section Type
bool boolean AMQP Value
byte ubyte AMQP Value
ushort ushort AMQP Value
uint uint AMQP Value
ulong ulong AMQP Value
sbyte byte AMQP Value
short short AMQP Value
int int AMQP Value
long long AMQP Value
float float AMQP Value
double double AMQP Value
decimal decimal128 AMQP Value
char char AMQP Value
DateTime timestamp AMQP Value
Guid uuid AMQP Value
byte[] binary AMQP Value
string string AMQP Value
System.Collections.IList list AMQP Value: items contained in the collection can only be those that are defined in this table.
System.Array array AMQP Value: items contained in the collection can only be those that are defined in this table.
System.Collections.IDictionary map AMQP Value: items contained in the collection can only be those that are defined in this table.Note: only String keys are supported.
Uri Described string(see the following table) AMQP Value
DateTimeOffset Described long(see the following table) AMQP Value
TimeSpan Described long(see the following) AMQP Value
Stream binary AMQP Data (may be multiple). The Data sections contain the raw bytes read from the Stream object.
Other Object binary AMQP Data (may be multiple). Contains the serialized binary of the object that uses the DataContractSerializer or a serializer supplied by the application.
.NET Type Mapped AMQP Described Type Notes
Uri <type name=”uri” class=restricted source=”string”> <descriptor name=”” /></type> Uri.AbsoluteUri
DateTimeOffset <type name=”datetime-offset” class=restricted source=”long”> <descriptor name=”” /></type> DateTimeOffset.UtcTicks
TimeSpan <type name=”timespan” class=restricted source=”long”> <descriptor name=”” /></type> TimeSpan.Ticks

Unsupported features, restrictions, and behavioral differences

The following features of the Service Bus .NET API are not currently supported when using AMQP:

  • Transactions
  • Send via transfer destination

There are also some small differences in the behavior of the Service Bus .NET API when using AMQP, compared to the default protocol:

  • The OperationTimeout property is ignored.
  • MessageReceiver.Receive(TimeSpan.Zero) is implemented as MessageReceiver.Receive(TimeSpan.FromSeconds(10)).
  • Completing messages by lock tokens can only be done by the message receivers that initially received the messages.

Controlling AMQP protocol settings

The .NET APIs expose several settings to control the behavior of the AMQP protocol:

Next steps

Ready to learn more? Visit the following links: