|
RSS Feed - WebSphere MQ Support
|
RSS Feed - Message Broker Support
|
 |
|
Empty BAGGREGATE table rows |
« View previous topic :: View next topic » |
Author |
Message
|
kerbling |
Posted: Mon Aug 15, 2005 7:13 am Post subject: Empty BAGGREGATE table rows |
|
|
Novice
Joined: 15 Aug 2005 Posts: 10
|
I am testing the Aggregate Nodes and have 2 flows. The first acting as the Request the second as the Reply. My issue is with the Request flow and specifically the behaviour of the AggregateRequestNode.
I have a trace node just before the Aggregate Request Node and it shows that the LocalEnviornment is being populated.
--LocalEnvironment--
(
(0x01000000):ComIbmAggregateControlNode = (
(0x03000000):aggregateName = 'TESTAGG'
(0x03000000):replyGroupId = '1c97a9a409c440bea89267f6dd96b294'
(0x03000000):timeout = 1124118255
)
(0x01000000):WrittenDestination = (
(0x01000000):MQ = (
(0x01000000):DestinationData = (
(0x03000000):queueName = 'REQUEST.OUT'
(0x03000000):queueManagerName = ''
(0x03000000):replyIdentifier = X'414d5120424245414944303120202020cb55ff4220002817'
(0x03000000):msgId = X'414d5120424245414944303120202020cb55ff4220002817'
(0x03000000):correlId = X'414d5120424245414944303120202020cb55ff4220008605'
)
)
)
)
--Root--
(
(0x01000000):Properties = (
(0x03000000):MessageSet = ''
(0x03000000):MessageType = ''
(0x03000000):MessageFormat = ''
(0x03000000):Encoding = 546
(0x03000000):CodedCharSetId = 437
(0x03000000):Transactional = TRUE
(0x03000000):Persistence = FALSE
(0x03000000):CreationTime = GMTTIMESTAMP '2005-08-15 15:04:05.570'
(0x03000000):ExpirationTime = -1
(0x03000000):Priority = 0
(0x03000000):ReplyIdentifier = X'414d5120424245414944303120202020cb55ff4220008605'
(0x03000000):ReplyProtocol = 'MQ'
(0x03000000):Topic = NULL
)
(0x01000000):MQMD = (
(0x03000000):SourceQueue = 'REQUEST.IN'
(0x03000000):Transactional = TRUE
(0x03000000):Encoding = 546
(0x03000000):CodedCharSetId = 437
(0x03000000):Format = ' '
(0x03000000):Version = 2
(0x03000000):Report = 0
(0x03000000):MsgType = 8
(0x03000000):Expiry = -1
(0x03000000):Feedback = 0
(0x03000000):Priority = 0
(0x03000000):Persistence = 0
(0x03000000):MsgId = X'414d5120424245414944303120202020cb55ff4220008605'
(0x03000000):CorrelId = X'414d5120424245414944303120202020cb55ff4220008605'
(0x03000000):BackoutCount = 0
(0x03000000):ReplyToQ = ' '
(0x03000000):ReplyToQMgr = 'BBEAID01 '
(0x03000000):UserIdentifier = 'USER '
(0x03000000):AccountingToken = X'160105150000000d7a5a339e407e1443170a320504000000000000000000000b'
(0x03000000):ApplIdentityData = ' '
(0x03000000):PutApplType = 11
(0x03000000):PutApplName = 'rt Pacs\RFHUTIL\rfhutilc.exe'
(0x03000000):PutDate = DATE '2005-08-15'
(0x03000000):PutTime = GMTTIME '15:04:05.570'
(0x03000000):ApplOriginData = ' '
(0x03000000):GroupId = X'000000000000000000000000000000000000000000000000'
(0x03000000):MsgSeqNumber = 1
(0x03000000):Offset = 0
(0x03000000):MsgFlags = 0
(0x03000000):OriginalLength = -1
)
)
So it is my understanding that the AggregateRequestNode should enter the LocalEnvironment into the BAGGREGATE table. There is one entry made but it only has the TIMEOUT that matches the value in the timeout field of the LocalEnvironment and UNSOLICITED set to 'N'.
I read that the Aggregate Request Node writes to the BAGGREGATE, please correct me if I am wrong in that. If that is right, can anyone tell me why the data might not be being written. It is my assumption that this record is needed in the database and therefore that is why all my replies go to the UNKNOWN node of the AggregateReplyNode.
Many Thanks. |
|
Back to top |
|
 |
jefflowrey |
Posted: Mon Aug 15, 2005 7:18 am Post subject: |
|
|
Grand Poobah
Joined: 16 Oct 2002 Posts: 19981
|
I guess I don't usually wory about the tables behind the scenes.
Do the flows work? Do you get the data you need? _________________ I am *not* the model of the modern major general. |
|
Back to top |
|
 |
TonyD |
Posted: Mon Aug 15, 2005 3:10 pm Post subject: |
|
|
Knight
Joined: 15 May 2001 Posts: 540 Location: New Zealand
|
It is not clear whether you have a process between your flows or not, ie something that receives the fan-out request, does some processing and then sends a reply, or whether flow #1 writes directly to the input queue of flow #2; the absence of a ReplyToQ and the fact that message type is datagram indicates that the latter may be the case. However you must ensure that the message id of the request message is placed in the correlation id of the reply. The request is being written with MsgId ending '...2817' which is what should be in the CorrelId of the reply (fan-in) message. If however the reply has CorrelId ending '...8605' you will get the 'unknown' result. |
|
Back to top |
|
 |
kerbling |
Posted: Tue Aug 16, 2005 1:38 am Post subject: |
|
|
Novice
Joined: 15 Aug 2005 Posts: 10
|
TonyD ... your assumption was correct. As this was a test I was writing the requests direct to the input queue of the Reply flow. Directly before the AggregateReplyNode I added a Compute node to copy the MsgId to the CorrelId and now it appears to work. So thank you for you assistence, much appreciated. |
|
Back to top |
|
 |
|
|
 |
|
Page 1 of 1 |
|
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
|
|
|
|