MQSeries.net :: View topic - Pub/Sub : Subscription Problem

MQSeries.net

Tech Exchange

Education

Certifications

Library

Info Center

SupportPacs

FAQÂ Â

Usergroups

RSS Feed - WebSphere MQ Support

RSS Feed - Message Broker Support

MQSeries.net Forum Index » WebSphere Message Broker (ACE) Support » Pub/Sub : Subscription Problem

Pub/Sub : Subscription Problem

« View previous topic :: View next topic »

Author

Message

Raghu

Posted: Thu Apr 15, 2004 8:07 am Post subject: Pub/Sub : Subscription Problem

Newbie

Joined: 15 Apr 2004
Posts: 3
Location: Moline, IL.

Hi,

I'm working on Pub/Sub with Message Broker 5.0 . I created 2 flows, one for publishing and the other for Subscriptions.
I'm having problems with the Subscription flow, I dont see any subscriptions on the topic in Subscriptions list. Here is what I did and the trace files.
Please take a look at these and help me finding whatz wrong.

Thanks - Raghu.

Notes :
Subscription Flow : I created a message flow to take an input XML message and read the request, q name and subscribe/unsubscribe by writing
the message to 'SYSTEM.BROKER.CONTROL.QUEUE' with MQRFH2 values.

When I run this flow, I dont see any errors in 'Event viewer' and the message is not written to any failed Q's. I dont see the Subscription in Subscription list.
(I didnt try to publish and see). I think the subscription itself is not done.

Here is my Compute Node's ESQL.

Quote:

CREATE COMPUTE MODULE Subscribe1_Compute
CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN
--CALL CopyEntireMessage();
SET OutputRoot.MQMD.Format='MQRFH2';
SET OutputRoot.MQMD.CodedCharSetId=1208;
SET OutputRoot.MQMD.Encoding=546;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Format=InputRoot.MQMD.Format;
SET OutputRoot.MQRFH2.(MQRFH2.Field).Encoding=InputRoot.MQMD.Encoding;
SET OutputRoot.MQRFH2.(MQRFH2.Field).CodedCharSetId=InputRoot.MQMD.CodedCharSetId;
SET OutputRoot.MQRFH2.psc.Command='RegSub';
--CASE
--WHEN InputRoot.XML.SubList.Subscriber.Request='Register' WHEN 'RegSub'
--ELSE 'DeRegSub'
--END CASE;

SET OutputRoot.MQRFH2.psc.Topic='A/B/C';
SET OutputRoot.MQRFH2.psc.QMgrName='W900000033347_QM';
SET OutputRoot.MQRFH2.psc.Qname='SUBSCRIBER1';
--SET OutputRoot.MQRFH2.psc.Qname=InputRoot.XML.SubList.Subscriber.Qname;

RETURN TRUE;
END;

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

END MODULE;

Here is the trace before my Compute node.

Quote:

Message passed through with the following Info before Compute Node:
(
(0x01000000):Properties = (
(0x03000000):MessageSet = ''
(0x03000000):MessageType = ''
(0x03000000):MessageFormat = ''
(0x03000000):Encoding = 546
(0x03000000):CodedCharSetId = 437
(0x03000000):Transactional = TRUE
(0x03000000):Persistence = FALSE
(0x03000000):CreationTime = GMTTIMESTAMP '2004-04-15 15:46:00.460'
(0x03000000):ExpirationTime = -1
(0x03000000):Priority = 0
(0x03000000):ReplyIdentifier = X'000000000000000000000000000000000000000000000000'
(0x03000000):ReplyProtocol = 'MQ'
(0x03000000):Topic = NULL
)
(0x01000000):MQMD = (
(0x03000000):SourceQueue = 'SUBSCRIBE_IN'
(0x03000000):Transactional = TRUE
(0x03000000):Encoding = 546
(0x03000000):CodedCharSetId = 437
(0x03000000):Format = 'MQSTR '
(0x03000000):Version = 2
(0x03000000):Report = 0
(0x03000000):MsgType = 8
(0x03000000):Expiry = -1
(0x03000000):Feedback = 0
(0x03000000):Priority = 0
(0x03000000):Persistence = 0
(0x03000000):MsgId = X'414d512057393030303030303333333497727e4020000249'
(0x03000000):CorrelId = X'000000000000000000000000000000000000000000000000'
(0x03000000):BackoutCount = 0
(0x03000000):ReplyToQ = ' '
(0x03000000):ReplyToQMgr = 'W900000033347_QM '
(0x03000000):UserIdentifier = 'ou54211 '
(0x03000000):AccountingToken = X'160105150000009dbeda52fbda8b7f828ba6282c1b030000000000000000000b'
(0x03000000):ApplIdentityData = ' '
(0x03000000):PutApplType = 11
(0x03000000):PutApplName = 'C:\WINDOWS\system32\mmc.exe '
(0x03000000):PutDate = DATE '2004-04-15'
(0x03000000):PutTime = GMTTIME '15:46:00.460'
(0x03000000):ApplOriginData = ' '
(0x03000000):GroupId = X'000000000000000000000000000000000000000000000000'
(0x03000000):MsgSeqNumber = 1
(0x03000000):Offset = 0
(0x03000000):MsgFlags = 0
(0x03000000):OriginalLength = -1
)
(0x01000000):BLOB = (
(0x03000000):UnknownParserName = 'MQSTR'
(0x03000000):BLOB = X'3c5375624c6973743e3c537562736372696265723e3c526571756573743e52656769737465723c2f526571756573743e3c514e616d653e53554253435249424552313c2f514e616d653e3c2f537562736372696265723e3c2f5375624c6973743e'
)
)

Time is : 10:46

Here is the trace after the Compute node.

Quote:

***** Trace After Compute Node *************

(
(0x01000000):Properties = (
(0x03000000):MessageSet = NULL
(0x03000000):MessageType = NULL
(0x03000000):MessageFormat = NULL
(0x03000000):Encoding = 546
(0x03000000):CodedCharSetId = 437
(0x03000000):Transactional = UNKNOWN
(0x03000000):Persistence = UNKNOWN
(0x03000000):CreationTime = NULL
(0x03000000):ExpirationTime = NULL
(0x03000000):Priority = NULL
(0x03000000):ReplyIdentifier = NULL
(0x03000000):ReplyProtocol = 'MQ'
(0x03000000):Topic = 'A/B/C'
)
(0x01000000):MQMD = (
(0x03000000):Format = 'MQHRF2'
(0x03000000):CodedCharSetId = 1208
(0x03000000):Encoding = 546
)
(0x01000000):MQRFH2 = (
(0x03000000):Format = ''
(0x03000000):Encoding = 546
(0x03000000):CodedCharSetId = 437
(0x01000000):psc = (
(0x01000000):Command = (
(0x02000000): = 'RegSub'
)
(0x01000000):Topic = (
(0x02000000): = 'A/B/C'
)
(0x01000000):QMgrName = (
(0x02000000): = 'W900000033347_QM'
)
(0x01000000):Qname = (
(0x02000000): = 'SUBSCRIBER1'
)
)
)
)

Raghu

Posted: Fri Apr 16, 2004 4:40 am Post subject:

Newbie

Joined: 15 Apr 2004
Posts: 3
Location: Moline, IL.

Never Mind.. I got it to work.

I used RFHUtil tool to see how a Publish Message looks like and I compared it with the message that is generated by my Publish flow..I did the same with Subscribe flow also. And Obviously I was missing some fields.

I added the fields back to my ESQL and made it to work.

Thanks for al the'Views'

Enjoy.

Display posts from previous:

Page 1 of 1

MQSeries.net Forum Index » WebSphere Message Broker (ACE) Support » Pub/Sub : Subscription Problem

Jump to:

You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum

Protected by Anti-Spam ACP