Programming

#include <mqueue.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <sys/stat.h>
#include <string.h>
#include <signal.h>

#define MSG_SIZE 16
#define MQ_NAME "/msgqueue"
int main(void)
{
      
      mqd_t    mqPXId;          
        char *msg = "test";
         
        
        if ((mqPXId = mq_open (MQ_NAME, O_RDWR | O_CREAT, S_IWUSR | S_IRUSR, NULL)) ==-1) 
            { 
            printf ("sendTask: mq_open failed: %s\n", strerror(errno)); 
            return 0; 
            }

           
        if (mq_send (mqPXId, msg, MSG_SIZE, NULL) == -1) 
            { 
            printf ("sendTask: mq_send failed\n"); 
            return 0; 
            } 
        else 
        {
            printf ("sendTask: mq_send succeeded, msg sent: %s\n",msg); 
         }
            return 0;
}

#include <stdio.h>
#include <mqueue.h>
#include <pthread.h>
#include <string.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <errno.h>
#define MSG_SIZE 16
#define MQ_NAME "/msgqueue"

int main(void)
{
    mqd_t    mqPXId;         /* msg queue descriptor */ 
        char     *msg;  /* msg buffer */ 
       // unsigned int      prio;           /* priority of message */

     
        /* open message queue using default attributes */ 
        if ((mqPXId = mq_open (MQ_NAME, O_RDWR , S_IWUSR | S_IRUSR, NULL))  
            ==  -1) 
            { 
            printf ("receiveTask: mq_open failed\n"); 
            return 0; 
            }

     
        /* try reading from queue */ 
        if (mq_receive (mqPXId,(char *)&msg,MSG_SIZE, NULL) == -1) 
            { 
            printf ("receiveTask: mq_receive failed: %s\n",strerror(errno)); 
            return 0; 
            } 
        else 
            { 
            printf ("receiveTask: Msg of priority received:\n\t\t%s\n", 
                    msg); 
            } 
return 0;
        }

ssize_t bytes_received;
char buffer[ MSG_SIZE ];

bytes_received = mq_receive( mxPXId, buffer, sizeof( buffer ), NULL );
...