testsend.cpp

MQ的c程序(发送和接收)及xlc编译命令行/usr/vacpp/bin/xlC -g -o testsend testsend.o -L/usr/vacpp/bin/api/lib -lapi -L

//////////////////////////////////////////////////////////////////// 
//文件名：testsend.cpp
//功  能：MQ API 测试例子程序
//说  明：
//版  本：1.00
//Copyright (c) 2004  YLink
//
//日期       人员    版本  描述
//2004-09-19 joshua  1.00  创建
////////////////////////////////////////////////////////////////////

#include "api.hpp"
#include "stdio.h"
#include "stdlib.h"
#include "string.h"


int main(int argc,char **argv)
{
	if (argc < 2)
	{
		printf("缺少运行参数\n");
		return -1;
	}

	int iRetCode;
	char szRetInfo[API_RETINF_LEN];
	char szMsg[API_MSGINSTR_LEN];
//	int iMsgFlag;

	memset(szRetInfo,0,sizeof(szRetInfo));
	memset(szMsg,0,sizeof(szMsg));
        strncpy(szMsg, argv[2],strlen(argv[2]));	
        //strncpy(szMsg, "aaa",strlen("aaa"));
	char szQName[21];
	memset(szQName	,0		,sizeof(szQName	));
	strncpy(szQName	,argv[1],sizeof(szQName	)-1);
       //strncpy(szQName	,"01_1",sizeof(szQName)-1);
	void* pId=MQ_CONNECT("QM01",iRetCode,szRetInfo);
	if (iRetCode!=0)
	{
		fprintf(stderr,"open queue error:[%s]\n",szRetInfo);
		return 0;
	}
        
        fprintf(stderr,"send file!\n");
        fprintf(stderr,"queue name:[%s]\n",szQName);
        fprintf(stderr,"msg:[%s]\n",szMsg);
	iRetCode=0;
	MQ_SEND(pId, szQName,"aaa", 0, 1, iRetCode, szRetInfo);
	if (iRetCode != 0)
	{
             fprintf(stderr,"send file error:[%d]-[%s]\n",iRetCode, szRetInfo);
	}
	else{
             fprintf(stderr,"send file succeed\n");
	}

	MQ_DISCONNECT(pId);
	fprintf(stderr,"close queue\n");

	return 0;

}