cmqxpas.pas

delphi写的IBM mq服务器

 (*********************************************************************)
 (*  MQXCNVC Function -- Convert Characters                           *)
 (*********************************************************************)

  procedure MQXCNVC (
    Hconn         : MQHCONN;   (* Connection handle *)
    Options       : MQLONG;    (* Options that control the action of
                                  MQXCNVC *)
    SourceCCSID   : MQLONG;    (* Coded character set identifier of string
                                  before conversion *)
    SourceLength  : MQLONG;    (* Length of string before conversion *)
    pSourceBuffer : PMQCHAR;   (* String to be converted *)
    TargetCCSID   : MQLONG;    (* Coded character set identifier of string
                                  after conversion *)
    TargetLength  : MQLONG;    (* Length of output buffer *)
    pTargetBuffer : PMQCHAR;   (* String after conversion *)
    var DataLength: MQLONG;    (* Length of output string *)
    var CompCode  : MQLONG;    (* Completion code *)
    var Reason    : MQLONG);   (* Reason code qualifying CompCode *)
  cdecl;
  external 'mqm.dll' name 'MQXCNVC';

procedure SetMQCD_DEFAULT(var struct: TMQCD);
procedure SetMQDXP_DEFAULT(var struct: TMQDXP);
procedure SetMQCD_CLIENT_CONN_DEFAULT(var struct: TMQCD);
procedure SetMQCXP_DEFAULT(var struct: TMQCXP);
procedure SetMQPXP_DEFAULT(var struct: TMQPXP);
procedure SetMQWDR_DEFAULT(var struct: TMQWDR);
procedure SetMQWQR_DEFAULT(var struct: TMQWQR);
procedure SetMQWXP_DEFAULT(var struct: TMQWXP);

implementation

procedure SetMQCD_DEFAULT(var struct: TMQCD);
begin
  FillChar(struct, SizeOf(Struct), 0);
  with struct do begin
    ChannelName := '';
    Version := MQCD_CURRENT_VERSION;
    ChannelType :=  MQCHT_SENDER;
    TransportType := MQXPT_LU62;
    Desc := '';
    QMgrName := '';
    XmitQName := '';
    ShortConnectionName := '';
    MCAName := '';
    ModeName := '';
    TpName := '';
    BatchSize := 50;
    DiscInterval := 6000;
    ShortRetryCount := 10;
    ShortRetryInterval := 60;
    LongRetryCount := 999999999;
    LongRetryInterval := 1200;
    SecurityExit := '';
    MsgExit := '';
    SendExit := '';
    ReceiveExit := '';
    SeqNumberWrap := 999999999;
    MaxMsgLength := 4194304;
    PutAuthority := MQPA_DEFAULT;
    DataConversion := MQCDC_NO_SENDER_CONVERSION;
    SecurityUserData := '';
    MsgUserData := '';
    SendUserData := '';
    ReceiveUserData := '';
    UserIdentifier := '';
    Password := '';
    MCAUserIdentifier := '';
    MCAType := MQMCAT_PROCESS;
    ConnectionName := '';
    RemoteUserIdentifier := '';
    RemotePassword := '';
    MsgRetryExit := '';
    MsgRetryUserData := '';
    MsgRetryCount := 10;
    MsgRetryInterval := 1000;
    HeartbeatInterval := 300;
    BatchInterval := 0;
    NonPersistentMsgSpeed := MQNPMS_FAST;
    StrucLength := MQCD_CURRENT_LENGTH;
    ExitNameLength := MQ_EXIT_NAME_LENGTH;
    ExitDataLength := MQ_EXIT_DATA_LENGTH;
    MsgExitsDefined := 0;
    SendExitsDefined := 0;
    ReceiveExitsDefined := 0;
    MsgExitPtr := nil;
    MsgUserDataPtr := nil;
    SendExitPtr := nil;
    SendUserDataPtr := nil;
    ReceiveExitPtr := nil;
    ReceiveUserDataPtr := nil;
    ClusterPtr := nil;
    ClustersDefined := 0;
    NetworkPriority := 0;
    LongMCAUserIdLength := 0;
    LongRemoteUserIdLength := 0;
    LongMCAUserIdPtr := nil;
    LongRemoteUserIdPtr := nil;
//    MCASecurityId := MQSID_NONE;
//    RemoteSecurityId := MQSID_NONE;
  end;
end;

procedure SetMQCD_CLIENT_CONN_DEFAULT(var struct: TMQCD);
begin
  FillChar(struct, SizeOf(Struct), 0);
  with struct do begin
    ChannelName := '';
    Version := MQCD_VERSION_6;
    ChannelType := MQCHT_CLNTCONN;
    TransportType := MQXPT_TCP;
    Desc := '';
    QMgrName := '';
    XmitQName := '';
    ShortConnectionName := '';
    MCAName := '';
    ModeName := '';
    TpName := '';
    BatchSize := 50;
    DiscInterval := 6000;
    ShortRetryCount := 10;
    ShortRetryInterval := 60;
    LongRetryCount := 999999999;
    LongRetryInterval := 1200;
    SecurityExit := '';
    MsgExit := '';
    SendExit := '';
    ReceiveExit := '';
    SeqNumberWrap := 999999999;
    MaxMsgLength := 4194304;
    PutAuthority := MQPA_DEFAULT;
    DataConversion := MQCDC_NO_SENDER_CONVERSION;
    SecurityUserData := '';
    MsgUserData := '';
    SendUserData := '';
    ReceiveUserData := '';
    UserIdentifier := '';
    Password := '';
    MCAUserIdentifier := '';
    MCAType := MQMCAT_PROCESS;
    ConnectionName := '';
    RemoteUserIdentifier := '';
    RemotePassword := '';
    MsgRetryExit := '';
    MsgRetryUserData := '';
    MsgRetryCount := 10;
    MsgRetryInterval := 1000;
    HeartbeatInterval := 1;
    BatchInterval := 0;
    NonPersistentMsgSpeed := MQNPMS_FAST;
    StrucLength := MQCD_LENGTH_6;
    ExitNameLength := MQ_EXIT_NAME_LENGTH;
    ExitDataLength := MQ_EXIT_DATA_LENGTH;
    MsgExitsDefined := 0;
    SendExitsDefined := 0;
    ReceiveExitsDefined := 0;
    MsgExitPtr := nil;
    MsgUserDataPtr := nil;
    SendExitPtr := nil;
    SendUserDataPtr := nil;
    ReceiveExitPtr := nil;
    ReceiveUserDataPtr := nil;
    ClusterPtr := nil;
    ClustersDefined := 0;
    NetworkPriority := 0;
    LongMCAUserIdLength := 0;
    LongRemoteUserIdLength := 0;
    LongMCAUserIdPtr := nil;
    LongRemoteUserIdPtr := nil;
//    MCASecurityId := MQSID_NONE_ARRAY;
//    RemoteSecurityId := MQSID_NONE_ARRAY;
  end;
end;

procedure SetMQCXP_DEFAULT(var struct: TMQCXP);
begin
  FillChar(struct, SizeOf(struct), 0);
  with struct do begin
    StrucId := MQCXP_STRUC_ID;
    Version := MQCXP_CURRENT_VERSION;
    ExitId := 0;
    ExitReason := 0;
    ExitResponse := MQXCC_OK;
    ExitResponse2 := MQXR2_PUT_WITH_DEF_ACTION;
    Feedback := 0;
    MaxSegmentLength := 0;
//    ExitUserArea := MQXUA_NONE_ARRAY;
    ExitData := '';
    MsgRetryCount := 0;
    MsgRetryInterval := 0;
    MsgRetryReason := 0;
    HeaderLength := 0;
    PartnerName := '';
    FAPLevel := 0;
    CapabilityFlags := MQCF_NONE;
    ExitNumber := 1;
    ExitSpace := 0;
  end;
end;

procedure SetMQDXP_DEFAULT(var struct: TMQDXP);
begin
  FillChar(struct, SizeOf(struct), 0);
  with struct do begin
    StrucId := MQDXP_STRUC_ID_ARRAY;
    Version := MQDXP_CURRENT_VERSION;
    ExitOptions := 0;
    AppOptions := 0;
    Encoding := 0;
    CodedCharSetId := 0;
    DataLength := 0;
    CompCode := MQCC_OK;
    Reason := MQRC_NONE;
    ExitResponse := MQXDR_CONVERSION_FAILED;
    Hconn := 0;
  end;
end;

procedure SetMQPXP_DEFAULT(var struct: TMQPXP);
begin
  FillChar(struct, SizeOf(struct), 0);
  with struct do begin
    StrucId := MQPXP_STRUC_ID;
    Version := MQPXP_CURRENT_VERSION;
    ExitId := MQXT_PUBSUB_ROUTING_EXIT;
    ExitReason := 0;
    ExitResponse := MQXCC_OK;
    ExitResponse2 := 0;
    Feedback := MQFB_NONE;
    ExitNumber := 1;
//    ExitUserArea := MQXUA_NONE_ARRAY;
    ExitData := '';
    HeaderLength := 0;
    MsgInLength := 0;
    MsgOutLength := 0;
    DestinationType := MQDT_APPL;
    MsgDescPtr := nil;
    MsgInPtr := nil;
    MsgOutPtr := nil;
    StreamName := '';
    QMgrName := '';
    DestinationQName := '';
    DestinationQMgrName := '';
  end;
end;

procedure SetMQWDR_DEFAULT(var struct: TMQWDR);
begin
  FillChar(struct, SizeOf(struct), 0);
  with struct do begin
    StrucId := MQWDR_STRUC_ID;
    Version := MQWDR_CURRENT_VERSION;
    StrucLength := MQWDR_CURRENT_LENGTH;
    QMgrFlags := 0;
    QMgrIdentifier := '';
    QMgrName := '';
    ClusterRecOffset := 0;
    ChannelState := 0;
    ChannelDefOffset := 0;
  end;
end;

procedure SetMQWQR_DEFAULT(var struct: TMQWQR);
begin
  FillChar(struct, SizeOf(struct), 0);
  with struct do begin
    StrucId := MQWQR_STRUC_ID;
    Version := MQWQR_CURRENT_VERSION;
    StrucLength := MQWQR_CURRENT_LENGTH;
    QFlags := 0;
    QName := '';
    QMgrIdentifier := '';
    ClusterRecOffset := 0;
    QType := 0;
    QDesc := '';
    DefBind := 0;
    DefPersistence := 0;
    DefPriority := 0;
    InhibitPut := 0;
  end;
end;

procedure SetMQWXP_DEFAULT(var struct: TMQWXP);
begin
  FillChar(struct, SizeOf(struct), 0);
  with struct do begin
    StrucId := MQWXP_STRUC_ID;
    Version := MQWXP_CURRENT_VERSION;
    ExitId := 0;
    ExitReason := 0;
    ExitResponse := MQXCC_OK;
    ExitResponse2 := 0;
    Feedback := 0;
    Reserved := 0;
//    ExitUserArea := MQXUA_NONE_ARRAY;
    ExitData := '';
    MsgDescPtr := nil;
    MsgBufferPtr := nil;
    MsgBufferLength := 0;
    MsgLength := 0;
    QName := '';
    QMgrName := '';
    DestinationCount := 0;
    DestinationChosen := 0;
    DestinationArrayPtr := nil;
    QArrayPtr := nil;
    CacheContext := nil;
    CacheType := MQCLCT_DYNAMIC;
  end;
end;



end.