急急急 MQRMH 索引消息傳輸文件 websphere8 java

cu_cef

與這位樓主一模一樣的問題, 也不知道他怎么解決的, 哪位大神知道解決方案
bbs.csdn.net/topics/190046875

之前是在舊版本的websphere用C程序?qū)崿F(xiàn)的索引消息傳輸文件, 現(xiàn)在要在8.0版本 用java實現(xiàn).

C版本大致如下:

1. 
   
2.    MQOD     od = {MQOD_DEFAULT};    /* Object Descriptor             */
   
3.    MQMD     md = {MQMD_DEFAULT};    /* Message Descriptor            */
   
4.    MQPMO    pmo = {MQPMO_DEFAULT};  /* put message options           */
   
5.    MQGMO    gmo = {MQGMO_DEFAULT};  /* get message options           */
   
6.    MQRMHX   refx = {{MQRMH_DEFAULT}}; /* reference message           */
   
7. 
   
8.    MQHCONN  Hcon;                   /* connection handle             */
   
9.    MQHOBJ   Hobj = MQHO_UNUSABLE_HOBJ;
   
10.                                     /* object handle                 */
    
11.    MQLONG   CompCode ;     /* completion code               */
    
12.    MQLONG   ConnCode ; /* MQCONN completion code        */
    
13.    MQLONG   Reason;                 /* reason code                   */
    
14.    MQLONG   CReason;                /* reason code for MQCONN        */
    
15.    MQLONG   co  = MQCO_NONE;        /* MQCLOSE options               */
    
16.    MQLONG   DataLength;             /* Length of report message      */
    
17.    MQLONG   WaitInterval = 15 ;
    
18.                                     /* Wait interval                 */
    
19.    MQLONG   QMgrCCSID;              /* QMgr CodedCharSetId           */
    
20.    PMQRMH   pMQRMH;   /* -> MQRMH structure            */
    
21.    PMQXQH   pMQXQH;                 /* -> MQXQH structure            */
    
22. 
    
23.    char     QMName[MQ_Q_MGR_NAME_LENGTH+1] = "qmgrname" ;
    
24.                                     /* local queue manager name      */
    
25.    char     DestQName[MQ_Q_NAME_LENGTH+1] = "queuename" ;
    
26.                                     /* destination queue name        */
    
27.    char     SourceFileName[MAX_FILENAME_LENGTH+1] = "filename" ;
    
28.                                     /* source file name              */
    
29.    char     TargetFileName[MAX_FILENAME_LENGTH+1] = "filename" ;
    
30.                                     /* target file name              */
    
31.    char     ObjectType[sizeof(refx.ref.ObjectType)];
    
32.                                     /* Object type                   */
    
33.    char     Buffer[sizeof(MQXQH)+MAX_MQRMH_LENGTH];       
    
34. 
    
35.    strcpy(QMName, sMQManager);
    
36.    strcpy(DestQName, sMQSendQueue);
    
37.    strcpy(SourceFileName, sFileName);
    
38. 
    
39.    sprintf(SourceFileName,"%s\\%s",getenv("MQ_FILEPATH"),sFileName);//源文件名
    
40.    strcpy(TargetFileName, sFileName);
    
41.    sprintf(errorstr,"QMName=[%s],DestQName=[%s],SourceFileName=[%s]\n\n",QMName,DestQName,SourceFileName);
    
42. 
    
43.    MQCONN( QMName                 /* queue manager                  */
    
44.            ,&Hcon                  /* connection handle              */
    
45.            ,&ConnCode              /* completion code                */
    
46.            ,&CReason );             /* reason code                    */
    
47. 
    
48.      CompCode = ConnCode;
    
49. 
    
50.          memset(ObjectType,' ',sizeof(ObjectType));
    
51.          memcpy(ObjectType, "FLATFILE", sizeof("FLATFILE") - 1  );         
    
52. 
    
53.          refx.ref.StrucLength         = sizeof(refx);
    
54.      refx.ref.Encoding            = MQENC_NATIVE;
    
55.      refx.ref.CodedCharSetId      = QMgrCCSID;
    
56.      memcpy(refx.ref.Format,MQFMT_STRING
    
57.            ,(size_t)MQ_FORMAT_LENGTH);
    
58.      refx.ref.Flags               = MQRMHF_LAST;
    
59.      memcpy(refx.ref.ObjectType,ObjectType,
    
60.             sizeof(refx.ref.ObjectType));
    
61. 
    
62.      memset(refx.SrcName
    
63.            ,' '
    
64.            ,sizeof(refx.SrcName)+sizeof(refx.DestName));
    
65. 
    
66.      memcpy(refx.SrcName
    
67.            ,SourceFileName
    
68.            ,strlen(SourceFileName)
    
69.            );
    
70.      memcpy(refx.DestName
    
71.            ,TargetFileName
    
72.            ,strlen(TargetFileName)
    
73.            );
    
74. 
    
75.      refx.ref.SrcNameLength = strlen(SourceFileName);
    
76.      refx.ref.SrcNameOffset = offsetof(MQRMHX,SrcName);
    
77. 
    
78.      refx.ref.DestNameLength = strlen(TargetFileName);
    
79.      refx.ref.DestNameOffset = offsetof(MQRMHX,DestName);
    
80. 
    
81.          memcpy(md.ReplyToQ         
    
82.            ,"QUEUE_REPORT"
    
83.            , strlen( "QUEUE_REPORT" )
    
84.             );
    
85.      strncpy(od.ObjectName
    
86.             ,DestQName
    
87.             ,sizeof(od.ObjectName)
    
88.              );
    
89. 
    
90.          md.Report = MQRO_COA_WITH_FULL_DATA + MQRO_EXCEPTION_WITH_FULL_DATA;       
    
91.      pmo.Options = MQPMO_FAIL_IF_QUIESCING;
    
92.      memcpy(md.Format,MQFMT_REF_MSG_HEADER
    
93.            ,(size_t)MQ_FORMAT_LENGTH);
    
94. 
    
95.      MQPUT1(Hcon,                    /* connection handle            */
    
96.             &od,                     /* object descriptor for queue  */
    
97.             &md,                     /* message descriptor           */
    
98.             &pmo,                    /* options                      */
    
99.             sizeof(refx),            /* buffer length                */
    
100.             &refx,                   /* buffer                       */
     
101.             &CompCode,               /* MQPUT1 completion code       */
     
102.             &Reason);                /* reason code                  */
     

復(fù)制代碼