MQSeries.net :: View topic

mrgate · Posted: Thu Jun 28, 2007 2:10 am Post subject:

Hi all,
I am using message broker version6.0 on windows 2000 platform. I have created a message flow project which includes three flows.

first flow is publisher flow:

mqinput(queue is PUBLISHER.INPUT)--->compute node--->publication node.
in this flow the input is of xml data and code in compute node is:

set OutputRoot.MQMD.ReplyToQ='RTOQ';
set OutputRoot.MQMD.Format=MQFMT_RF_HEADER_2;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Version=2;
set OutputRoot.MQRFH2.(MQRFH2.Field)Format='MQSTR';
SET OutputRoot.MQRFH2.(MQRFH2.Field)NameValueCCSID=1208;
SET OutputRoot.MQRFH2.psc.Command='Publish';
SET OutputRoot.MQRFH2.psc.Topic=InputRoot.XML.Publish.topic;
SET OutputRoot.XML.DATA=InputRoot.XML.Publish.data;

the second flow is subscriber flow:

mqinput(queue is SUBSCRIBER.INPUT)--->compute node--->mqoutput node(queue is SYSTEM.BROKER.CONTROL.QUEUE)

code in subscribers flow compute node is:

SET OutputRoot.MQMD.Format=MQFMT_RF_HEADER_2;
--SET OutputRoot.MQMD.CorrelId=A;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Version=2;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Format='MQSTR';
SET OutputRoot.MQRFH2.(MQRFH2.Field)NameValueCCSID=1208;
SET OutputRoot.MQRFH2.psc.Command='RegSub';
SET OutputRoot.MQRFH2.psc.Topic=InputRoot.XML.topic;
--SET OutputRoot.MQRFH2.psc.RegOpt='CorrelAsId';
SET OutputRoot.MQRFH2.psc.QMgrName='WBRK6_DEFAULT_QUEUE_MANAGER';
SET OutputRoot.MQRFH2.psc.QName='PUBLISHEDINFO';

third flow is subscribers deregister flow :

mqinput(queue is DEREGSUBSCRIBER.INPUT)--->compute node--->mqoutput node(queue is SYSTEM.BROKER.CONTROL.QUEUE)

code in compute node is:

SET OutputRoot.MQMD.Format=MQFMT_RF_HEADER_2;
--SET OutputRoot.MQMD.CorrelId=A;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Version=2;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Format='MQSTR';
SET OutputRoot.MQRFH2.(MQRFH2.Field)NameValueCCSID=1208;
SET OutputRoot.MQRFH2.psc.Command='DeregSub';
SET OutputRoot.MQRFH2.psc.Topic=InputRoot.XML.topic;
SET OutputRoot.MQRFH2.psc.RegOpt='CorrelAsId';
SET OutputRoot.MQRFH2.psc.QMgrName='WBRK6_DEFAULT_QUEUE_MANAGER';
SET OutputRoot.MQRFH2.psc.QName='PUBLISHEDINFO';

In the documentation, I have seen that whenever we are subscribing to a particular topic we should include the correlid of mqmd in the psc service folder so that whenever we are deregistering a subscriber, we should pass the matching correlation id of the subscriber to deregister a subscriber.

now what is the problem is that topic is being subscribed in the broker and the data is not being unscribed from the broker can anyone give me the reason for this.