MQSeries.net :: View topic - MQRC_NOT_AUTHORIZED error for PUB/SUB in MB 7 with MQ 7

nhcaccenture · Posted: Tue Jun 26, 2012 1:52 am Post subject:

I am trying to create a topic by sending PCF message from messsage broker to WMQ. I have done below to accomplish this. I am testing the message flow with test message <tst>test</tst>. Flow completes with out any exceptions but I do not see any topic in MQ Explorer. And I am getting MQRC_NOT_AUTHORIZED error in SYSTEM.DEAD.LETTER.QUEUE. Any help would be greatly appreaciated. I can create the topic using MQExplorere. Why can't I create using Message Broker flow. I have also tried changing the MCA user to SYSTEM.BKR.CONFIG channel. That did not work either.

I have created a flow with MQINPUT--> Compute-->MQOutput-->MQREPLY.
I have set queue name as â€˜SYSTEM.ADMIN.COMMAND.QUEUEâ€™ for node MQ Output node.
Below is the code for compute node.

CREATE COMPUTE MODULE CreateTopicFlow_Compute
CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN
CALL CopyEntireMessage();

-- PCF header is following the MQMD header.
SET OutputRoot.MQMD.MsgType = MQMT_REQUEST;
SET OutputRoot.MQMD.Format = MQFMT_ADMIN;
SET OutputRoot.MQMD.ReplyToQ = 'REP_Q';
SET OutputRoot.MQMD.MsgSeqNumber = 1;
SET OutputRoot.MQMD.Encoding = 546;

--CREATE FIELD OutputRoot.MQPCF;
CREATE NEXTSIBLING OF OutputRoot.MQMD DOMAIN 'MQADMIN' NAME 'MQPCF';
DECLARE refRequest REFERENCE TO OutputRoot.MQPCF;
SET refRequest.Type = MQCFT_COMMAND;
SET refRequest.StrucLength = MQCFH_STRUC_LENGTH;
SET refRequest.Version = MQCFH_CURRENT_VERSION;
SET refRequest.Command = 172; --MQCMD_CREATE_TOPIC
SET refRequest.MsgSeqNumber = 1;
SET refRequest.Control = MQCFC_LAST;

--First parameter: Topic Name.
SET refRequest.Parameter[1] = 2092; --MQCA_TOPIC_NAME
SET refRequest.Parameter[1].* = 'PCFTestTopic1';

-- Second parameter: Topic name length.
SET refRequest.Parameter[2] = 48; --MQ_TOPIC_NAME_LENGTH
SET refRequest.Parameter[2].* = '100';

-- Third parameter: Topic String.
SET refRequest.Parameter[3] = 2094; --MQCA_TOPIC_STRING
SET refRequest.Parameter[3].* = 'PCFTestTopic1String';

SET OutputRoot.BLOB.BLOB = asbitstream(OutputRoot.MQPCF);
SET OutputRoot.MQPCF = null;
RETURN TRUE;
END;

CREATE PROCEDURE CopyMessageHeaders() BEGIN
DECLARE I INTEGER 1;
DECLARE J INTEGER;
SET J = CARDINALITY(InputRoot.*[]);
WHILE I < J DO
SET OutputRoot.*[I] = InputRoot.*[I];
SET I = I + 1;
END WHILE;
END;

CREATE PROCEDURE CopyEntireMessage() BEGIN
SET OutputRoot = InputRoot;
END;
END MODULE;