// read text file and put each line in MQSeries;
#include <stdlib.h>
#include <iostream.h>
#include <fstream.h>
#include <string.h>
#include <ctype.h>
#include <cmqc.h>

void hint(char * argv0) {
  cerr << "usage: \n" 
	  << argv0 << " -q queue "
                  "[-m manager]"
                  "[-tm manager]"
				  "[-f file]"
				  "[--ccsid=CCSID]"
				  "[--ingroup]"
				  << flush;
}
int main(int argc, char *argv[])
{
char szQueue[ 50 ] = {  0  };
char szFile[ 50 ] = {  0  }; 
char szManager[ 50 ] = {  0  };
char szTManager[ 50 ] = {  0  };
int  CCSID =  0 ;
int ingroup =  0 ;
for(int xx= 1 ; xx<argc; ++xx) {
   if ( !strcmp( argv[xx], "-q") )  {
	   ++xx;
	   if( !(xx<argc)) {
	      hint(argv[ 0 ]);
		  return  1 ;
	   }
	   strcpy(szQueue, argv[xx]);
	   continue;
   }
   if ( !strcmp( argv[xx], "-f") )  {
	   ++xx;
	   if( !(xx<argc)) {
	      hint(argv[ 0 ]);
		  return  1 ;
	   }
	   strcpy(szFile, argv[xx]);
	   continue;
   }
   if ( !strcmp( argv[xx], "-m") )  {
	   ++xx;
	   if( !(xx<argc)) {
	      hint(argv[ 0 ]);
		  return  1 ;
	   }
	   strcpy(szManager, argv[xx]);
	   continue;
   }
   if ( !strcmp( argv[xx], "-tm") )  {
	   ++xx;
	   if( !(xx<argc)) {
	      hint(argv[ 0 ]);
		  return  1 ;
	   }
	   strcpy(szTManager, argv[xx]);
	   continue;
   }
   if( !strncmp(argv[xx],"--ccsid=",  8  )) {
	   for(int zz =  8 ;argv[xx][zz];++zz) {
			if (isdigit(argv[xx][zz])) {
			} else {
				hint(argv[ 0 ]);
				return  1 ;			
			}
	   }
      CCSID = atoi(argv[xx]+ 8 );
      continue;
   }
    if( !strcmp(argv[xx],"--ingroup" )) {
     ++ingroup;
    continue;
   }

				hint(argv[ 0 ]);
				return  1 ;			

}
if(!szQueue[ 0 ]) {
    hint(argv[ 0 ]);
	return  1 ;
}
MQHCONN  Hcon; 
{
	MQLONG CC;
	MQLONG RC;
	MQCONN(szManager,&Hcon,&CC,&RC);
    if(CC==MQCC_FAILED) {
       cerr << "cannot connect to manager '" << szManager << "'\n" << flush;
	   cerr << "reason code: " << RC << endl << flush;
       return  1 ;
	}
}
MQHOBJ   Hobj;
{
   MQLONG O_options = MQOO_OUTPUT + MQOO_FAIL_IF_QUIESCING;
   MQLONG CC;
   MQLONG RC;
   MQOD   Od = {MQOD_DEFAULT};
   strncpy(Od.ObjectQMgrName, szTManager , (size_t)MQ_Q_NAME_LENGTH );
   strncpy(Od.ObjectName, szQueue, (size_t)MQ_Q_NAME_LENGTH);
   MQOPEN(Hcon, &Od, O_options, &Hobj, &CC, &RC); 
   if(CC==MQCC_FAILED) {
      cerr << "cannot open queue: " << szQueue << endl << flush;
	  cerr << "reason code: " << RC << endl << flush;
	  return  1 ;
   }
}

if(szFile[ 0 ]) {

  ifstream *xx = new ifstream(szFile , ios::nocreate   );
  if ( 1 )  {
//  if (xx->is_open())  {
	  cin = *xx;
  } else {
      cerr << "Cannot open file " << szFile << endl;
	  return  1 ;
  }
}

MQMD     md1 = {MQMD_DEFAULT};
MQPMO   pmo1 = {MQPMO_DEFAULT};

if(ingroup) {

	memcpy(md1.MsgId, MQMI_NONE, sizeof(md1.MsgId) );
	memcpy(md1.CorrelId, MQCI_NONE, sizeof(md1.CorrelId) );
	memcpy(md1.Format, MQFMT_STRING, (size_t)MQ_FORMAT_LENGTH);
	if (CCSID)	{
		md1.CodedCharSetId = CCSID;
	}
	md1.Version = MQMD_VERSION_2;
	md1.MsgFlags =  8 ; 
    pmo1.Version = MQPMO_VERSION_2;
    pmo1.Options += MQPMO_LOGICAL_ORDER;
}

char szLine[ 65536 ];
while(!cin.eof()) {
	szLine[ 0 ] = '\0';
    cin.getline(szLine,  65536 , '\n');
	if(!szLine[ 0 ]) continue;
	int xx = strlen(szLine);
	MQLONG CC;
	MQLONG RC;
	if(!ingroup) {
		MQMD     md = {MQMD_DEFAULT};
		MQPMO   pmo = {MQPMO_DEFAULT};
		MQLONG CC;
		MQLONG RC;
		memcpy(md.MsgId, MQMI_NONE, sizeof(md.MsgId) );
		memcpy(md.CorrelId, MQCI_NONE, sizeof(md.CorrelId) );
		memcpy(md.Format, MQFMT_STRING, (size_t)MQ_FORMAT_LENGTH);
		if (CCSID)	{
			md.CodedCharSetId = CCSID;
		}
		MQPUT(Hcon, Hobj,  &md, &pmo, xx, szLine, &CC, &RC);
	} else {
        if(cin.eof())  	md1.MsgFlags =  16 ; 
		MQPUT(Hcon, Hobj,  &md1, &pmo1, xx, szLine, &CC, &RC);
	}
	if(CC==MQCC_FAILED) {
	  cerr << "MQPUT failed with reason code: " << RC << endl << flush;
	  break;
	}
}
{
		MQLONG CC;
		MQLONG RC;
MQCLOSE(Hcon, &Hobj,  0 , &CC, &RC);

if(CC==MQCC_FAILED) {
   cerr << "MQCLOSE failed with reason code: " << RC << endl << flush;
}
MQDISC(&Hcon, &CC, &RC); 
if(CC==MQCC_FAILED) {
   cerr << "MQDISC failed with reason code: " << RC << endl << flush;
}

}
return  0 ;
}