@@ -353,52 +353,3 @@ event, then returned messages will be silently dropped.
353
353
The [code BasicReturn] event will fire, for example, if the client
354
354
publishes a message with the "mandatory" flag set to an exchange of
355
355
"direct" type which is not bound to a queue.
356
-
357
- ** QPid-compatible JMS BytesMessage, StreamMessage, and MapMessage codecs
358
-
359
- The [code RabbitMQ.Client.Content] namespace contains classes and
360
- interfaces that implement QPid-compatible JMS BytesMessage,
361
- StreamMessage and MapMessage encoders and decoders.
362
-
363
- For example, to construct (and send) a MapMessage:
364
-
365
- @code java
366
- IModel channel = ...;
367
-
368
- IMapMessageBuilder b = new MapMessageBuilder(channel);
369
- b.Headers["header1"] = "
[email protected] ";
370
- b.Body["field1"] = 123.45;
371
- b.Body["field2"] = new byte[] { 1, 2, 3 };
372
-
373
- channel.BasicPublish(exchange, routingKey,
374
- (IBasicProperties) b.GetContentHeader(),
375
- b.GetContentBody());
376
-
377
- A StreamMessage is similar (and BytesMessages are so similar to
378
- StreamMessages that I shan't demonstrate them here):
379
-
380
- @code java
381
- IStreamMessageBuilder b = new StreamMessageBuilder(channel);
382
- b.Headers["header1"] = "
[email protected] ";
383
- b.WriteDouble(123.45);
384
- b.WriteBytes(new byte[] { 1, 2, 3 });
385
-
386
- Given a received message in the form of an [code IBasicProperties]
387
- header and a [code byte[]] body, reading the message as a MapMessage
388
- is done with [code IMapMessageReader]:
389
-
390
- @code java
391
- IBasicProperties props = ...;
392
- byte[] receivedBody = ...;
393
- IMapMessageReader r = new MapMessageReader(props, receivedBody);
394
- Console.Out.WriteLine("Header1: {0}", r.Headers["header1"]);
395
- Console.Out.WriteLine("Field1: {0}", r.Body["field1"]);
396
- Console.Out.WriteLine("Field2: {0}", r.Body["field2"]);
397
-
398
- StreamMessages (and BytesMessages) are similar:
399
-
400
- @code java
401
- IStreamMessageReader r = new StreamMessageReader(props, receivedBody);
402
- Console.Out.WriteLine("Header1: {0}", r.Headers["header1"]);
403
- Console.Out.WriteLine("First value: {0}", r.ReadDouble());
404
- Console.Out.WriteLine("Second value: {0}", r.ReadBytes());
0 commit comments