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 class="Apple-tab-span" style="white-space:pre">                </span>// publisher code</div>
<div><span class="Apple-tab-span" style="white-space:pre">        </span>    ConnectionFactory factory = new ConnectionFactory();</div><div>            factory.HostName = &quot;localhost&quot;;<span class="Apple-tab-span" style="white-space:pre">        </span></div>
<div><span class="Apple-tab-span" style="white-space:pre">                </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 class="Apple-tab-span" style="white-space:pre">                        </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 class="Apple-tab-span" style="white-space:pre">        </span>{</div>
<div><span class="Apple-tab-span" style="white-space:pre">                </span>// subscriber code</div><div><span class="Apple-tab-span" style="white-space:pre">                </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 class="Apple-tab-span" style="white-space:pre">        </span>    string queue1 = channel.QueueDeclare();</div><div><span class="Apple-tab-span" style="white-space:pre">                        </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 class="Apple-tab-span" style="white-space:pre">                </span></div>
<div>                byte[] body = ea.Body;</div><div><span class="Apple-tab-span" style="white-space:pre">                                </span></div><div><span class="Apple-tab-span" style="white-space:pre">                </span>Measurement m2 = new Measurement(20, 23323, 3.3);</div>
<div><span class="Apple-tab-span" style="white-space:pre">                </span>m2 = BinarySerialization.BinaryDeSerialize( body );</div><div><span class="Apple-tab-span" style="white-space:pre">                </span>                </div><div>                Console.WriteLine(&quot; Message received: &quot;);</div>
<div><span class="Apple-tab-span" style="white-space:pre">                                </span>Console.WriteLine(&quot;\nMeasurement ID: {0}&quot;, <a href="http://m2.id">m2.id</a>);</div><div><span class="Apple-tab-span" style="white-space:pre">                                </span>Console.WriteLine(&quot;Measurement Time: {0}&quot;, m2.time);</div>
<div><span class="Apple-tab-span" style="white-space:pre">                                </span>Console.WriteLine(&quot;Measurement Value: {0}&quot;, m2.value);</div><div>            }</div><div>        }</div><div>}<span class="Apple-tab-span" style="white-space:pre">        </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>