/* * * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information * regarding copyright ownership. The ASF licenses this file * to you under the Apache License, Version 2.0 (the * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, * software distributed under the License is distributed on an * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY * KIND, either express or implied. See the License for the * specific language governing permissions and limitations * under the License. * */ using System; using System.Collections.Generic; using System.Linq; using System.Text; using org.apache.qpid.messaging; namespace org.apache.qpid.messaging.examples { class MapSender { static void Main(string[] args) { string url = "amqp:tcp:localhost:5672"; if (args.Length > 0) url = args[0]; // // Create and open an AMQP connection to the broker URL // Connection connection = new Connection(url); connection.open(); // // Create a session and a sender to the direct exchange using the // routing key "map_example". // Session session = connection.createSession(); Sender sender = session.createSender("amq.direct/map_example"); // // Create structured content for the message. This example builds a // map of items including a nested map and a list of values. // Dictionary content = new Dictionary(); Dictionary subMap = new Dictionary(); List colors = new List(); content["id"] = 987654321; content["name"] = "Widget"; content["percent"] = 0.99; subMap["name"] = "Smith"; subMap["number"] = 354; content["nested"] = subMap; colors.Add("red"); colors.Add("green"); colors.Add("white"); content["colors"] = colors; // // Construct a message with the map content and send it synchronously // via the sender. // Message message = new Message(content); sender.send(message, true); // // Close the connection. // connection.close(); } } }