pub_sub.c

#include <stdio.h>
#include <stdlib.h>
#include <rpc/rpc.h>

#include "pub_sub.h"

int main()
{
    CLIENT *cl;
    char topic[TOPLEN];
    char message[MESLEN];

    short* result;
    int len;

    if(argc < 3){
        fprintf(stderr,"Usage: math_client host topic message\n");
    }

    bzero(topic, TOPLEN);
    bzero(message, MESLEN);

    //copy topic
    len = strlen(argv[2]);
    if(len >= TOPLEN) {
        fprintf(stderr, "topic as to many characters\n");
    }
    memcpy(topic, argv[2], len);

    //copy message
    len = strlen(argv[3]);
    if(len >= MESLEN) {
        fprintf(stderr, "message as to many characters\n");
    }
    memcpy(message, argv[3], len);
    
    //connect
    cl clnt_create(argv[1], PUBSUBPROG, PUBSUBVERS, "tcp");
    if(cl == NULL) {
        clnt_pcreateerror(argv[1]);
        exit(1);
    }

    //subscribe
    result = subscribe();
    if(result == NULL){
        clnt_perror(cl, argv[1]);
        exit(1);
    }

    //publish
    result = publish(message);
    if(result == NULL){
        clnt_perror(cl, argv[1]);
        exit(1);
    }

    //unsubscribe
    result = unsubscribe();
    if(result == NULL){
        clnt_perror(cl, argv[1]);
        exit(1);
    }
    
    return 0;
}