5.6.3. Publishing to an XML Exchange

5.6.3. Publishing to an XML Exchange

Publishing to an XML Exchange is very similar to publishing to a direct exchange — you publish to the exchange using a routing key, which the binding associates with an XQuery:


	message.getDeliveryProperties().setRoutingKey("query_name"); 
	message.getHeaders().setString("control","continue");

	// Now send some messages ...

	for (int i=0; i<10; i++) {
	  stringstream message_data;
	  message_data << "<message><id>" << i << "</id></message>";

	  std::cout << "Message data: " << message_data.str() << std::endl;

	  message.setData(message_data.str());
          session.messageTransfer(arg::content=message,  arg::destination="xml");
	}
	
	// And send a final message to indicate termination.

	message.getHeaders().setString("control","end");
	message.setData("<end>That's all, folks!</end>");
        session.messageTransfer(arg::content=message,  arg::destination="xml");