cmqpas.pas

delphi写的IBM mq服务器

  MQCMDL_LEVEL_120 = 120;
  MQCMDL_LEVEL_200 = 200;
  MQCMDL_LEVEL_201 = 201;
  MQCMDL_LEVEL_210 = 210;
  MQCMDL_LEVEL_220 = 220;
  MQCMDL_LEVEL_221 = 221;
  MQCMDL_LEVEL_320 = 320;
  MQCMDL_LEVEL_420 = 420;
  MQCMDL_LEVEL_500 = 500;
  MQCMDL_LEVEL_510 = 510;
  MQCMDL_LEVEL_520 = 520;

  (* Platform *)
  MQPL_MVS        = 1;
  MQPL_OS390      = 1;
  MQPL_OS2        = 2;
  MQPL_AIX        = 3;
  MQPL_UNIX       = 3;
  MQPL_OS400      = 4;
  MQPL_WINDOWS    = 5;
  MQPL_WINDOWS_NT = 11;
  MQPL_VMS        = 12;
  MQPL_NSK        = 13;

  (* Syncpoint Availability *)
  MQSP_AVAILABLE     = 1;
  MQSP_NOT_AVAILABLE = 0;

  (* Channel Auto Definition *)
  MQCHAD_DISABLED = 0;
  MQCHAD_ENABLED  = 1;

  (* Intra-Group Queuing *)
  MQIGQ_DISABLED = 0;
  MQIGQ_ENABLED  = 1;

  (* Intra-Group Queuing Put Authority *)
  MQIGQPA_DEFAULT          = 1;
  MQIGQPA_CONTEXT          = 2;
  MQIGQPA_ONLY_IGQ         = 3;
  MQIGQPA_ALTERNATE_OR_IGQ = 4;

  (* Distribution Lists *)
  (* See values for "Distribution Lists" under Queue Attributes *)


type

  (*********************************************************************)
  (*  Simple Data Types                                                *)
  (*********************************************************************)

  (* Function Entry-Point and Pointer Attributes *)
//  MQENTRY   __cdecl
  MQPOINTER = Pointer;

  (* Byte Datatypes *)
  MQBYTE = byte;
  PMQBYTE = ^MQBYTE;
  MQBYTE8 = array [0..7] of MQBYTE;
  PMQBYTE8 = ^MQBYTE8;
  MQBYTE16 = array [0..15] of MQBYTE;
  PMQBYTE16 = ^MQBYTE16;
  MQBYTE24 = array [0..23] of MQBYTE;
  PMQBYTE24 = ^MQBYTE24;
  MQBYTE32 = array [0..31] of MQBYTE;
  PMQBYTE32 = ^MQBYTE32;
  MQBYTE40 = array [0..39] of MQBYTE;
  PMQBYTE40 = ^MQBYTE40;
  MQBYTE128 = array [0..127] of MQBYTE;
  PMQBYTE128 = ^MQBYTE128;

  (* Character Datatypes *)
  MQCHAR = char;
  PMQCHAR = ^MQCHAR;
  MQCHAR4 = array[0..3] of MQCHAR;
  PMQCHAR4 = ^MQCHAR4;
  MQCHAR8 = array[0..7] of MQCHAR;
  PMQCHAR8 = ^MQCHAR8;
  MQCHAR12 = array[0..11] of MQCHAR;
  PMQCHAR12 = ^MQCHAR12;
  MQCHAR20 = array[0..19] of MQCHAR;
  PMQCHAR20 = ^MQCHAR20;
  MQCHAR28 = array[0..27] of MQCHAR;
  PMQCHAR28 = ^MQCHAR28;
  MQCHAR32 = array[0..31] of MQCHAR;
  PMQCHAR32 = ^MQCHAR32;
  MQCHAR48 = array[0..47] of MQCHAR;
  PMQCHAR48 = ^MQCHAR48;
  MQCHAR64 = array[0..63] of MQCHAR;
  PMQCHAR64 = ^MQCHAR64;
  MQCHAR128 = array[0..127] of MQCHAR;
  PMQCHAR128 = ^MQCHAR128;
  MQCHAR256 = array[0..255] of MQCHAR;
  PMQCHAR256 = ^MQCHAR256;

  (* Other Datatypes *)
  MQLONG = Longint;
  PMQLONG = ^MQLONG;
  MQHCONN = MQLONG;
  PMQHCONN = ^MQHCONN;
  MQHOBJ = MQLONG ;
  PMQHOBJ = ^MQHOBJ;
  MQPTR = ^Pointer;
  PMQPTR = ^MQPTR;
  PMQVOID = ^Pointer;
  PPMQVOID = ^Pointer ;


  (*********************************************************************)
  (*  MQBO Structure -- Begin Options                                  *)
  (*********************************************************************)


  TMQBO = record
    StrucId: MQCHAR4;  (* Structure identifier *)
    Version: MQLONG;   (* Structure version number *)
    Options: MQLONG;   (* Options that control the action of MQBEGIN *)
  end;
  PMQBO = ^TMQBO;

  (*********************************************************************)
  (*  MQCIH Structure -- CICS Information Header                       *)
  (*********************************************************************)


  TMQCIH = record
    StrucId : MQCHAR4;             (* Structure identifier *)
    Version : MQLONG;              (* Structure version number *)
    StrucLength : MQLONG;          (* Length of MQCIH structure *)
    Encoding : MQLONG;             (* Reserved *)
    CodedCharSetId : MQLONG;       (* Reserved *)
    Format : MQCHAR8;              (* MQ format name of data that follows
                                      MQCIH *)
    Flags : MQLONG;                (* Flags *)
    ReturnCode : MQLONG;           (* Return code from bridge *)
    CompCode : MQLONG;             (* MQ completion code or CICS
                                      EIBRESP *)
    Reason : MQLONG;               (* MQ reason or feedback code, or CICS
                                      EIBRESP2 *)
    UOWControl : MQLONG;           (* Unit-of-work control *)
    GetWaitInterval : MQLONG;      (* Wait interval for MQGET call issued
                                      by bridge task *)
    LinkType : MQLONG;             (* Link type *)
    OutputDataLength : MQLONG;     (* Output COMMAREA data length *)
    FacilityKeepTime : MQLONG;     (* Bridge facility release time *)
    ADSDescriptor : MQLONG;        (* Send/receive ADS descriptor *)
    ConversationalTask : MQLONG;   (* Whether task can be conversational *)
    TaskEndStatus : MQLONG;        (* Status at end of task *)
    Facility : MQBYTE8;            (* Bridge facility token *)
    Function_ : MQCHAR4;           (* MQ call name or CICS EIBFN
                                      function *)
    AbendCode : MQCHAR4;           (* Abend code *)
    Authenticator : MQCHAR8;       (* Password or passticket *)
    Reserved1 : MQCHAR8;           (* Reserved *)
    ReplyToFormat : MQCHAR8;       (* MQ format name of reply message *)
    RemoteSysId : MQCHAR4;         (* Reserved *)
    RemoteTransId : MQCHAR4;       (* Reserved *)
    TransactionId : MQCHAR4;       (* Transaction to attach *)
    FacilityLike : MQCHAR4;        (* Terminal emulated attributes *)
    AttentionId : MQCHAR4;         (* AID key *)
    StartCode : MQCHAR4;           (* Transaction start code *)
    CancelCode : MQCHAR4;          (* Abend transaction code *)
    NextTransactionId : MQCHAR4;   (* Next transaction to attach *)
    Reserved2 : MQCHAR8;           (* Reserved *)
    Reserved3 : MQCHAR8;           (* Reserved *)
    CursorPosition : MQLONG;       (* Cursor position *)
    ErrorOffset : MQLONG;          (* Offset of error in message *)
    InputItem : MQLONG;            (* Reserved *)
    Reserved4 : MQLONG;            (* Reserved *)
  end;
  PMQCIH = ^TMQCIH;


  (*********************************************************************)
  (*  MQCNO Structure -- Connect Options                               *)
  (*********************************************************************)

  TMQCNO = record
    StrucId : MQCHAR4;           (* Structure identifier *)
    Version : MQLONG;            (* Structure version number *)
    Options : MQLONG;            (* Options that control the action of
                                    MQCONNX *)
    ClientConnOffset : MQLONG;   (* Offset of MQCD structure for
                                    client connection *)
    ClientConnPtr : MQPTR;       (* Address of MQCD structure for
                                    client connection *)
  end;
  PMQCNO = ^TMQCNO;


  (*********************************************************************)
  (*  MQDH Structure -- Distribution Header                            *)
  (*********************************************************************)

  TMQDH = record
    StrucId : MQCHAR4;          (* Structure identifier *)
    Version : MQLONG;           (* Structure version number *)
    StrucLength : MQLONG;       (* Length of MQDH structure plus following
                                   records *)
    Encoding : MQLONG;          (* Numeric encoding of data that follows
                                   array of MQPMR records *)
    CodedCharSetId : MQLONG;    (* Character set identifier of data that
                                   follows array of MQPMR records *)
    Format : MQCHAR8;           (* Format name of data that follows
                                   array of MQPMR records *)
    Flags : MQLONG;             (* General flags *)
    PutMsgRecFields : MQLONG;   (* Flags indicating which MQPMR
                                   fields are present *)
    RecsPresent : MQLONG;       (* Number of object records present *)
    ObjectRecOffset : MQLONG;   (* Offset of first object record from
                                   start of MQDH *)
    PutMsgRecOffset : MQLONG;   (* Offset of first put message record
                                   from start of MQDH *)
  end;
  PMQDH = ^TMQDH;


  (*********************************************************************)
  (*  MQDLH Structure -- Dead Letter Header                            *)
  (*********************************************************************)

  TMQDLH = record
    StrucId : MQCHAR4;          (* Structure identifier *)
    Version : MQLONG;           (* Structure version number *)
    Reason  : MQLONG;           (* Reason message arrived on dead-letter
                                   (undelivered-message) queue *)
    DestQName : MQCHAR48;       (* Name of original destination queue *)
    DestQMgrName : MQCHAR48;    (* Name of original destination queue
                                   manager *)
    Encoding : MQLONG;          (* Numeric encoding of data that follows
                                   MQDLH *)
    CodedCharSetId : MQLONG;    (* Character set identifier of data that
                                   follows MQDLH *)
    Format : MQCHAR8;           (* Format name of data that follows
                                   MQDLH *)
    PutApplType : MQLONG;       (* Type of application that put message on
                                   dead-letter (undelivered-message)
                                   queue *)
    PutApplName : MQCHAR28;     (* Name of application that put message on
                                   dead-letter (undelivered-message)
                                   queue *)
    PutDate : MQCHAR8;          (* Date when message was put on
                                   dead-letter (undelivered-message)
                                   queue *)
    PutTime : MQCHAR8;          (* Time when message was put on the
                                   dead-letter (undelivered-message)
                                   queue *)
  end;
  PMQDLH = ^TMQDLH;


  (*********************************************************************)
  (*  MQGMO Structure -- Get Message Options                           *)
  (*********************************************************************)

  TMQGMO = record
    StrucId : MQCHAR4;          (* Structure identifier *)
    Version : MQLONG;           (* Structure version number *)
    Options : MQLONG;           (* Options that control the action of
                                   MQGET *)
    WaitInterval : MQLONG;      (* Wait interval *)
    Signal1 : MQLONG;           (* Signal *)
    Signal2 : MQLONG;           (* Signal identifier *)
    ResolvedQName : MQCHAR48;   (* Resolved name of destination queue *)
    MatchOptions : MQLONG;      (* Options controlling selection criteria
                                   used for MQGET *)
    GroupStatus : MQCHAR;       (* Flag indicating whether message
                                   retrieved is in a group *)
    SegmentStatus : MQCHAR;     (* Flag indicating whether message
                                   retrieved is a segment of a logical
                                   message *)
    Segmentation : MQCHAR;      (* Flag indicating whether further
                                   segmentation is allowed for the message
                                   retrieved *)
    Reserved1 : MQCHAR;         (* Reserved *)
    MsgToken : MQBYTE16;        (* Message token *)
    ReturnedLength : MQLONG;    (* Length of message data returned
                                  (bytes) *)
  end;
  PMQGMO = ^TMQGMO;

  (*********************************************************************)
  (*  MQIIH Structure -- IMS Information Header                        *)
  (*********************************************************************)

  TMQIIH = record
    StrucId : MQCHAR4;          (* Structure identifier *)
    Version : MQLONG;           (* Structure version number *)
    StrucLength : MQLONG;       (* Length of MQIIH structure *)
    Encoding : MQLONG;          (* Reserved *)
    CodedCharSetId : MQLONG;    (* Reserved *)
    Format : MQCHAR8;           (* MQ format name of data that follows
                                   MQIIH *)
    Flags : MQLONG;             (* Flags *)
    LTermOverride : MQCHAR8;    (* Logical terminal override *)
    MFSMapName : MQCHAR8;       (* Message format services map name *)
    ReplyToFormat : MQCHAR8;    (* MQ format name of reply message *)
    Authenticator : MQCHAR8;    (* RACF password or passticket *)
    TranInstanceId : MQBYTE16;  (* Transaction instance identifier *)
    TranState : MQCHAR;         (* Transaction state *)
    CommitMode : MQCHAR;        (* Commit mode *)
    SecurityScope : MQCHAR;     (* Security scope *)
    Reserved : MQCHAR;          (* Reserved *)
  end;
  PMQIIH = ^TMQIIH;


  (*********************************************************************)
  (*  MQMD Structure -- Message Descriptor                             *)
  (*********************************************************************)

  TMQMD = record
    StrucId : MQCHAR4;           (* Structure identifier *)
    Version : MQLONG;            (* Structure version number *)
    Report : MQLONG;             (* Options for report messages *)
    MsgType : MQLONG;            (* Message type *)
    Expiry : MQLONG;             (* Message lifetime *)
    Feedback : MQLONG;           (* Feedback or reason code *)
    Encoding : MQLONG;           (* Numeric encoding of message data *)
    CodedCharSetId : MQLONG;     (* Character set identifier of message
                                     data *)
    Format : MQCHAR8;            (* Format name of message data *)
    Priority : MQLONG;           (* Message priority *)
    Persistence : MQLONG;        (* Message persistence *)
    MsgId : MQBYTE24;            (* Message identifier *)
    CorrelId : MQBYTE24;         (* Correlation identifier *)
    BackoutCount : MQLONG;       (* Backout counter *)
    ReplyToQ : MQCHAR48;         (* Name of reply queue *)
    ReplyToQMgr : MQCHAR48;      (* Name of reply queue manager *)
    UserIdentifier : MQCHAR12;   (* User identifier *)
    AccountingToken : MQBYTE32;  (* Accounting token *)
    ApplIdentityData : MQCHAR32; (* Application data relating to
                                    identity *)
    PutApplType : MQLONG;        (* Type of application that put the
                                    message *)
    PutApplName : MQCHAR28;      (* Name of application that put the
                                    message *)
    PutDate : MQCHAR8;           (* Date when message was put *)
    PutTime : MQCHAR8;           (* Time when message was put *)
    ApplOriginData : MQCHAR4;    (* Application data relating to
                                    origin *)
    GroupId : MQBYTE24;          (* Group identifier *)
    MsgSeqNumber : MQLONG;       (* Sequence number of logical message
                                   within group *)
    Offset : MQLONG;             (* Offset of data in physical message
                                    from start of logical message *)
    MsgFlags : MQLONG;           (* Message flags *)
    OriginalLength: MQLONG;      (* Length of original message *)
  end;
  PMQMD = ^TMQMD;


  (*********************************************************************