<font face="trebuchet ms,sans-serif">Doesn&#39;t m2 in your code below contain the deserialized message?<br></font><br><div class="gmail_quote">On Tue, Jul 5, 2011 at 23:15, Demiss Zike <span dir="ltr">&lt;<a href="mailto:habtdemis@gmail.com">habtdemis@gmail.com</a>&gt;</span> wrote:<br>

<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">Hello,<div><br></div><div>I&#39;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)?  </div>


<div><br></div><div>I&#39;ve included codes on both ends:</div><div><br></div><div><div>public void publish(byte[] _serializedMsg)</div><div>{</div><div><span style="white-space:pre-wrap">                </span>// publisher code</div>


<div><span style="white-space:pre-wrap">        </span>    ConnectionFactory factory = new ConnectionFactory();</div><div>            factory.HostName = &quot;localhost&quot;;<span style="white-space:pre-wrap">        </span></div>
<div><span style="white-space:pre-wrap">                </span></div><div>            using (IConnection connection = factory.CreateConnection())</div><div>            using (IModel channel = connection.CreateModel()) {</div>
<div>            channel.ExchangeDeclare(&quot;logs&quot;, &quot;fanout&quot;);</div><div><span style="white-space:pre-wrap">                        </span></div><div>            channel.BasicPublish(&quot;logs&quot;, queue, null, _serializedMsg);</div>


<div>            Console.WriteLine(&quot; Message sent &quot;);</div><div>        }</div><div>}</div></div><div><br></div><div><br></div><div><br></div><div><div>public void subscribe(string queue)</div><div><span style="white-space:pre-wrap">        </span>{</div>


<div><span style="white-space:pre-wrap">                </span>// subscriber code</div><div><span style="white-space:pre-wrap">                </span>ConnectionFactory factory = new ConnectionFactory();</div><div>
            factory.HostName = &quot;localhost&quot;;</div><div>            using (IConnection connection = factory.CreateConnection())</div><div>            using (IModel channel = connection.CreateModel()) {</div><div>

            channel.ExchangeDeclare(&quot;logs&quot;, &quot;fanout&quot;);</div>
<div><br></div><div><span style="white-space:pre-wrap">        </span>    string queue1 = channel.QueueDeclare();</div><div><span style="white-space:pre-wrap">                        </span></div><div>            channel.QueueBind(queue1, &quot;logs&quot;, &quot;&quot;);</div>


<div>            QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);</div><div>            channel.BasicConsume(queue1, true, consumer);</div><div><br></div><div>            Console.WriteLine(&quot; Waiting for messages. To exit press CTRL+C&quot;);</div>


<div>            while(true) {</div><div>                BasicDeliverEventArgs ea =</div><div>                    (BasicDeliverEventArgs)consumer.Queue.Dequeue();</div><div><span style="white-space:pre-wrap">                </span></div>


<div>                byte[] body = ea.Body;</div><div><span style="white-space:pre-wrap">                                </span></div><div><span style="white-space:pre-wrap">                </span>Measurement m2 = new Measurement(20, 23323, 3.3);</div>
<div><span style="white-space:pre-wrap">                </span>m2 = BinarySerialization.BinaryDeSerialize( body );</div><div><span style="white-space:pre-wrap">                </span>                </div><div>                Console.WriteLine(&quot; Message received: &quot;);</div>


<div><span style="white-space:pre-wrap">                                </span>Console.WriteLine(&quot;\nMeasurement ID: {0}&quot;, <a href="http://m2.id" target="_blank">m2.id</a>);</div><div><span style="white-space:pre-wrap">                                </span>Console.WriteLine(&quot;Measurement Time: {0}&quot;, m2.time);</div>


<div><span style="white-space:pre-wrap">                                </span>Console.WriteLine(&quot;Measurement Value: {0}&quot;, m2.value);</div><div>            }</div><div>        }</div><div>}<span style="white-space:pre-wrap">        </span></div>


</div><div><br></div><div><br></div><div>Thanks!</div><div>Demi</div><div><br></div><div><br></div><div><br></div><div><br></div>
<br>_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br></blockquote></div><br>