MQSeries.net :: View topic

raze · Posted: Tue May 16, 2006 4:05 pm Post subject:

I still have this strange problem. When writing to the remote queue the
message does not reach the other end of the remote queue.

When using the test program amqsput.exe everything works as expected,
but when using my Delphi test program, it only works when writing to a
local queue.

I get no errors what so ever from MQ. I hope somebody have an idea on
how to fix this problem ?

I'm using MQSeries client version 5.1.

----------------------------- Delphi main program
-----------------------------------------------------

unit MQSMain;

interface

uses Windows, Forms, SysUtils, StdCtrls, Buttons, Controls, Classes,
ExtCtrls, dialogs, Spin, syncobjs, registry;

{$I MQS.inc}

function BreakWriteConnectionToMQS: longint;
function MakeWriteConnectionToMQS(qm: PChar): longint;
function SendStringToMQS(s: PChar; qm: PChar; qn: PChar): longint;

var

ObjDesc: MQOD = (StrucId: ('O','D',' ',' ');
Version: MQOD_VERSION_1;
ObjectType: MQOT_Q;
ObjectName: '';
ObjectQMgrName: '';
DynamicQName: 'AMQ.*';
AlternateUserId: '';
RecsPresent: 0;
KnownDestCount: 0;
UnknownDestCount: 0;
InvalidDestCount: 0;
ObjectRecOffset: 0;
ResponseRecOffset: 0;
ObjectRecPtr: nil;
ResponseRecPtr: nil;
AlternateSecurityId: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
ResolvedQName: '';
ResolvedQMgrName: '');

Filler1: MQMD;

MsgDesc: MQMD = (StrucId: ('M','D',' ',' ');
Version: MQMD_VERSION_1;
Report: MQRO_NONE;
MsgType: MQMT_DATAGRAM;
Expiry: MQEI_UNLIMITED;
Feedback: MQFB_NONE;
Encoding: MQENC_NATIVE;
CodedCharSetId: MQCCSI_Q_MGR;
Format: (' ',' ',' ',' ',' ',' ',' ','
');
Priority: MQPRI_PRIORITY_AS_Q_DEF;
Persistence: MQPER_PERSISTENCE_AS_Q_DEF;
MsgId: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
CorrelId: (#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0);
BackoutCount: 0;
ReplyToQ: '';
ReplyToQMgr: '';
UserIdentifier: '';
AccountingToken: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
ApplIdentityData: '';
PutApplType: MQAT_NO_CONTEXT;
PutApplName: '';
PutDate: '';
PutTime: '';
ApplOriginData: '';
GroupId: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
MsgSeqNumber: 1;
Offset: 0;
MsgFlags: MQMF_NONE;
OriginalLength: MQOL_UNDEFINED);

Filler2: MQMD;

PutOptions: MQPMO = (StrucId: ('P','M','O',' ');
Version: MQPMO_VERSION_1;
Options: MQPMO_NONE;
Timeout: -1;
Context: 0;
KnownDestCount: 0;
UnknownDestCount: 0;
InvalidDestCount: 0;
ResolvedQName: '';
ResolvedQMgrName: '';
RecsPresent: 0;
PutMsgRecFields: MQPMRF_NONE;
PutMsgRecOffset: 0;
ResponseRecOffset:0;
PutMsgRecPtr: nil;
ResponseRecPtr: nil);

Filler3: MQMD;

PutMsgDesc: MQMD = (StrucId: ('M','D',' ',' ');
Version: MQMD_VERSION_1;
Report: MQRO_NONE;
MsgType: MQMT_DATAGRAM;
Expiry: MQEI_UNLIMITED;
Feedback: MQFB_NONE;
Encoding: MQENC_NATIVE;
CodedCharSetId: MQCCSI_Q_MGR;
Format: (' ',' ',' ',' ',' ',' ',' ','
');
Priority: 0;
Persistence: MQPER_PERSISTENCE_AS_Q_DEF;
MsgId: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
CorrelId: (#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0);
BackoutCount: 0;
ReplyToQ: '';
ReplyToQMgr: '';
UserIdentifier: '';
AccountingToken: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
ApplIdentityData: '';
PutApplType: MQAT_NO_CONTEXT;
PutApplName: '';
PutDate: '';
PutTime: '';
ApplOriginData: '';
GroupId: (#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0,
#0,#0,#0,#0,#0,#0,#0,#0);
MsgSeqNumber: 1;
Offset: 0;
MsgFlags: MQMF_NONE;
OriginalLength: MQOL_UNDEFINED);

Filler4: MQMD;

WriteConnHandle: longint;
WriteQueueHandle: longint;
WriteConnectionEstablished: boolean = FALSE;
WriteConnectionError: boolean = False;

implementation

function BreakWriteConnectionToMQS: longint;
var
comp_code: longint;
reason: longint;

begin
comp_code := MQCC_OK;
reason := MQRC_NONE;

Filler1 := MQMD_DEFAULT;

if ( WriteConnectionEstablished ) then
begin
MQDISC(WriteConnHandle, comp_code, reason);
if ( comp_code = MQCC_OK ) then
WriteConnectionEstablished := False
end
else
comp_code := MQCC_OK;

Result := comp_code;
end;

function MakeWriteConnectionToMQS(qm: PChar): longint;
var
comp_code: longint;
reason: longint;

begin
comp_code := MQCC_OK;
reason := MQRC_NONE;
if ( not WriteConnectionEstablished ) then
begin
MQCONN(qm, WriteConnHandle, comp_code, reason);
if ( comp_code = MQCC_OK ) then
begin
WriteConnectionEstablished := True;
comp_code := MQCC_OK;
end;
end;

Result := reason
end;

function SendStringToMQS(s: PChar; qm: PChar; qn: PChar): longint;
var
comp_code: longint;
reason: longint;
buffer_length: longint;

begin
comp_code := MQCC_OK;
reason := MQRC_NONE;
if ( WriteConnectionError ) then
begin
WriteConnectionError := False;
end;
if( not WriteConnectionEstablished ) then
begin
comp_code := MakeWriteConnectionToMQS(qm);
if ( comp_code <> MQCC_OK ) then
WriteConnectionError := True;
end;
if ( comp_code = MQCC_OK ) then
begin
StrCopy( ObjDesc.ObjectName, qn);
MQOPEN(WriteConnHandle, ObjDesc, MQOO_OUTPUT +
MQOO_FAIL_IF_QUIESCING, WriteQueueHandle, comp_code, reason);
if ( (comp_code = MQCC_FAILED) or (reason <> MQRC_NONE) ) then
begin
WriteConnectionError := True;
end
else
begin

ShowMessage('Number of open remove queues are: ' +
IntToStr(objDesc.UnknownDestCount) + ' for queue ' +
objDesc.ResolvedQName);

//StrLCopy(PutMsgDesc.Format, MQFMT_STRING,
StrLen(MQFMT_STRING));
buffer_length := strlen( s );

StrLCopy(PutMsgDesc.MsgId, MQMI_NONE_ARRAY,
StrLen(MQMI_NONE_ARRAY));
StrLCopy(PutMsgDesc.CorrelId, MQCI_NONE_ARRAY,
StrLen(MQCI_NONE_ARRAY));

ShowMessage('Ready to put msg: ' + s + ' with length: ' +
IntToStr(buffer_length));

MQPUT(WriteConnHandle, WriteQueueHandle, PutMsgDesc, PutOptions,
buffer_length, s, comp_code, reason);
if ( (comp_code <> MQCC_OK) or (reason <> MQRC_NONE) ) then
begin
WriteConnectionError := True;
end
else