5.3.3. Publishing Messages to the Fanout Exchange

5.3.3. Publishing Messages to the Fanout Exchange

The second program in this example, fanout_producer.cpp, writes messages to the fanout queue.

// Send some messages ...

for (int i=0; i<10; i++) {
  stringstream message_data;
  message_data << "Message " << i;

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

message.setData("That's all, folks!");
session.messageTransfer(arg::content=message, arg::destination="amq.fanout");