[rabbitmq-discuss] Messaging and Serialization in RabbitMQ?

Tue Jul 5 22:18:09 BST 2011

Doesn't m2 in your code below contain the deserialized message?

On Tue, Jul 5, 2011 at 23:15, Demiss Zike <habtdemis at gmail.com> wrote:

> Hello,
>
> I'm using c#. I have a serializable class called Measurement and want to
> send an object of it. I serialized an object of Measurement and captured the
> serialized object as byte[] and published it. My question is how can I
> capture the published message (so that I can deserialize and use it)?
>
> I've included codes on both ends:
>
> public void publish(byte[] _serializedMsg)
> {
> // publisher code
>      ConnectionFactory factory = new ConnectionFactory();
>             factory.HostName = "localhost";
>              using (IConnection connection = factory.CreateConnection())
>             using (IModel channel = connection.CreateModel()) {
>             channel.ExchangeDeclare("logs", "fanout");
>             channel.BasicPublish("logs", queue, null, _serializedMsg);
>             Console.WriteLine(" Message sent ");
>         }
> }
>
>
>
> public void subscribe(string queue)
> {
>  // subscriber code
> ConnectionFactory factory = new ConnectionFactory();
>             factory.HostName = "localhost";
>             using (IConnection connection = factory.CreateConnection())
>             using (IModel channel = connection.CreateModel()) {
>             channel.ExchangeDeclare("logs", "fanout");
>
>     string queue1 = channel.QueueDeclare();
>             channel.QueueBind(queue1, "logs", "");
>             QueueingBasicConsumer consumer = new
> QueueingBasicConsumer(channel);
>             channel.BasicConsume(queue1, true, consumer);
>
>             Console.WriteLine(" Waiting for messages. To exit press
> CTRL+C");
>             while(true) {
>                 BasicDeliverEventArgs ea =
>                     (BasicDeliverEventArgs)consumer.Queue.Dequeue();
>                  byte[] body = ea.Body;
>  Measurement m2 = new Measurement(20, 23323, 3.3);
>  m2 = BinarySerialization.BinaryDeSerialize( body );
>
>                 Console.WriteLine(" Message received: ");
>  Console.WriteLine("\nMeasurement ID: {0}", m2.id);
> Console.WriteLine("Measurement Time: {0}", m2.time);
>  Console.WriteLine("Measurement Value: {0}", m2.value);
>             }
>         }
> }
>
>
> Thanks!
> Demi
>
>
>
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110705/88034333/attachment.htm>