//////////////////////////////////////////////////////////////////////////////

//

// (C) Copyright Ion Gaztanaga 2006-2012. Distributed under the Boost

// Software License, Version 1.0. (See accompanying file

// LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

//

// See http://www.boost.org/libs/interprocess for documentation.

//

//////////////////////////////////////////////////////////////////////////////

//[doc_message_queueA

#include <boost/interprocess/ipc/message_queue.hpp>

#include <iostream>

#include <vector>

using namespace boost::interprocess;

int main ()

{

BOOST_INTERPROCESS_TRY{

//Erase previous message queue

message_queue::remove("message_queue");

//Create a message_queue.

message_queue mq

(create_only //only create

,"message_queue" //name

,100 //max message number

,sizeof(int) //max message size

);

//Send 100 numbers

for(int i = 0; i < 100; ++i){

mq.send(&i, sizeof(i), 0);

}

}

BOOST_INTERPROCESS_CATCH(interprocess_exception &ex){

std::cout << ex.what() << std::endl;

return 1;

} BOOST_INTERPROCESS_CATCH_END

return 0;

}

//]