Envoyer un message sur Azure ServiceBus de l'expéditeur .NET Core à un gestionnaire .NET 4.6

Question

Je souhaite envoyer un message via Azure Service Bus à partir d'une application de console .NET Core et le recevoir dans une application de console .NET 4.6. Dans .NET Core, j'utilise le nouveau client de bus de service d'Azure pour l'expéditeur qui n'est pas encore destiné à la production (selon leur readme).

https://github.com/Azure/azure-service-bus-dotnet

je peux envoyer de base .NET et recevoir avec Core .NET assez facilement en utilisant les échantillons. Toutefois, lorsque l'application .NET 4.6 souscrit au sujet et reçoit le même message l'application .NET 4.6 génère cette exception:

Microsoft.Azure.WebJobs.Host.FunctionInvocationException: 
Exception while executing function: Functions.ProcessEvent 
System.InvalidOperationException: Exception binding parameter 'message' 
The BrokeredMessage with ContentType 'string' failed to 
deserialize to a string with the message: 
'Expecting element 'string' from namespace 
'http://schemas.microsoft.com/2003/10/Serialization/'.. 
Encountered 'Element' with name 'base64Binary', namespace 
http://schemas.microsoft.com/2003/10/Serialization/'. ' ---> 
System.Runtime.Serialization.SerializationException: Expecting element 
'string' from namespace 
http://schemas.microsoft.com/2003/10/Serialization/'.. Encountered 'Element' 
with name 'base64Binary', namespace 
'http://schemas.microsoft.com/2003/10/Serialization/'. 


System.Runtime.Serialization.DataContractSerializer.InternalReadObject 
(XmlReaderDelegator xmlReader, Boolean verifyObjectName, 
DataContractResolver dataContractResolver) at 
System.Runtime.Serialization.XmlObjectSerializer. 
ReadObjectHandleExceptions(XmlReaderDelegator reader, 
Boolean verifyObjectName, DataContractResolver dataContractResolver) 

Mon code .NET émetteur de base est:

using Microsoft.Azure.ServiceBus; 

var topicClient = new TopicClient(ServiceBusConnectionString, "topic1"); 
var msg = new Message(Encoding.UTF8.GetBytes("Hello world")); 
topicClient.SendAsync(msg).Wait(); 

Mon .NET 4.6 code récepteur est:

using Microsoft.Azure.WebJobs; 

    static void Main() 
    { 
     var config = new JobHostConfiguration(); 
     config.UseTimers(); 
     config.UseServiceBus(); 
     var host = new JobHost(config); 
     host.RunAndBlock(); 
    } 

    public void ProcessEvent([ServiceBusTrigger("topic1", "the-same-endpoint-as-connection-string")] string message, TextWriter logger) 
    { 
     Console.Writeline(message); 
    } 

Remarque Je ne peux pas changer le récepteur comme il est un ancien système.

Answer 1

Je suppose que le problème est parce que le noyau .NET publie le message sérialisé comme JSON au sujet, mais le code 4.6 NET tente de désérialiser le message de l'abonnement avec le DataContract Serializer (XML?), Dans la mesure Comme je sais, c'est la méthode de désérialisation par défaut pour la bibliothèque complète de framework .Net.

Si tel est le cas et vous ne pouvez pas modifier le code de réception, vous devez serialize le message avec DataContractSerializer sur .Net base:

var ser = new System.Runtime.Serialization.DataContractSerializer(typeof(string)); 
var ms = new MemoryStream(); 
ser.WriteObject(ms, "hello world"); 
var msg = new Message(ms.ToArray()); 

Vous aurez besoin du paquet NuGet System.Runtime.Serialization.Xml

Answer 2

Sons comme un interoperability issue

Le correctif a été fusionné dans dev branche, mais n'a pas encore sorti. Prévu pour 0.0.7-preview milestone`. Vous pouvez le suivre sous le repo GitHub.