ASG
IBM
Zystems
Cressida
Icon
Netflexity
 
  MQSeries.net
Search  Search       Tech Exchange      Education      Certifications      Library      Info Center      SupportPacs      LinkedIn  Search  Search                                                                   FAQ  FAQ   Usergroups  Usergroups
 
Register  ::  Log in Log in to check your private messages
 
RSS Feed - WebSphere MQ Support RSS Feed - Message Broker Support

MQSeries.net Forum Index » WebSphere Message Broker (ACE) Support » Collective set up

Post new topic  Reply to topic
 Collective set up « View previous topic :: View next topic » 
Author Message
AkankshA
PostPosted: Thu Apr 12, 2007 9:35 pm    Post subject: Collective set up Reply with quote

Grand Master

Joined: 12 Jan 2006
Posts: 1494
Location: Singapore

I have set up a collective on my windows machine with 2 brokers

When i registered a subscription with 1st broker in toolkit its reflecting me a proxy subscription with second broker also as expected

however when I try to publish a message on the same topic to another broker i get the following error in evet viewer and the message gets lost

( CBRK1.default ) Exception condition detected on input node 'MqInterbrokerFlow.TransactionalInputNode'.

The input node 'MqInterbrokerFlow.TransactionalInputNode' detected an error whilst processing a message. The message flow has been rolled-back and, if the message was being processed in a unit of work, it will remain on the input queue to be processed again. Following messages will indicate the cause of this exception.

Check the error messages which follow to determine why the exception was generated, and take action as described by those messages.

Message (of type 'SYSTEM.BROKER.INTERBROKER.QUEUE') on incorrect queue 'Message on incorrect queue'.

An application put a message of type 'SYSTEM.BROKER.INTERBROKER.QUEUE' on queue 'Message on incorrect queue'. This queue is not intended for messages of that type and the message was not processed.

Ensure that your applications are putting messages on the correct queue. Publish and Delete Publication messages should only be put on application queues. Control messages should only be put on SYSTEM.BROKER.CONTROL.QUEUE. Correct the application, then retry the operation.
_________________
Cheers
Back to top
View user's profile Send private message Visit poster's website
sanjoo
PostPosted: Wed Mar 19, 2008 1:05 am    Post subject: Reply with quote

Acolyte

Joined: 26 Oct 2005
Posts: 65

hi Akanksha...
how did you solved that?

I am also trying to do the same thing.. to publish a message to remote broker in a collective. Proxy subscriptions are working fine but while publishing to a remote topic, I get following exception -

ExceptionList:

(
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S000_P\src\DataFlowEngine\JavaNodeLibrary\ImbPubSubEngineNode.cpp'
(0x03000000):Line = 499
(0x03000000):Function = 'ImbPubSubEngineNode::evaluate'
(0x03000000):Type = 'ComIbmPSServiceNode'
(0x03000000):Name = 'MyPublisher#FCMComposite_1_5.ComIbmPublication#FCMComposite_1_1'
(0x03000000):Label = 'MyPublisher.Publication.ComIbmPSService'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):UnknownException = (
(0x03000000):File = 'F:\build\S000_P\src\DataFlowEngine\JavaNodeLibrary\ImbPubSubEngineNode.cpp'
(0x03000000):Line = 775
(0x03000000):Function = 'ImbPubSubEngineNode::publish'
(0x03000000):Type = 'ComIbmPSServiceNode'
(0x03000000):Name = 'MyPublisher#FCMComposite_1_5.ComIbmPublication#FCMComposite_1_1'
(0x03000000):Label = 'MyPublisher.Publication.ComIbmPSService'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'caught exception'
)
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S000_P\src\DataFlowEngine\JavaNodeLibrary\ImbPubSubDestinationList.cpp'
(0x03000000):Line = 506
(0x03000000):Function = 'ImbPubSubDestinationList::addDestination'
(0x03000000):Type = ''
(0x03000000):Name = ''
(0x03000000):Label = ''
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2111
(0x03000000):Text = 'Did not understand the required format: '
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '201458432'
)
)
)
)
)


and since I have also PAN+NAN option, I am also getting 3008 on ReplyToQ.

Thanks
_________________
Sanjoo

Keep smiling
Back to top
View user's profile Send private message
fjb_saper
PostPosted: Wed Mar 19, 2008 1:42 pm    Post subject: Reply with quote

Grand High Poobah

Joined: 18 Nov 2003
Posts: 20756
Location: LI,NY

What level of MQ and brokers are you guys at?

This only worked ok for me @WMB 6003 & MQ 6.0.2.0 and above...
_________________
MQ & Broker admin
Back to top
View user's profile Send private message Send e-mail
sanjoo
PostPosted: Wed Mar 19, 2008 9:14 pm    Post subject: Reply with quote

Acolyte

Joined: 26 Oct 2005
Posts: 65

I am @ WMB 6.0 and MQ 6.0.2.2
_________________
Sanjoo

Keep smiling
Back to top
View user's profile Send private message
fjb_saper
PostPosted: Thu Mar 20, 2008 2:59 pm    Post subject: Reply with quote

Grand High Poobah

Joined: 18 Nov 2003
Posts: 20756
Location: LI,NY

sanjoo wrote:
I am @ WMB 6.0 and MQ 6.0.2.2
Upgrade to 6.0.0.5
_________________
MQ & Broker admin
Back to top
View user's profile Send private message Send e-mail
sanjoo
PostPosted: Fri Mar 21, 2008 8:53 am    Post subject: Reply with quote

Acolyte

Joined: 26 Oct 2005
Posts: 65

I did upgrade to 6.0.0.6, but still facing same issue.
_________________
Sanjoo

Keep smiling
Back to top
View user's profile Send private message
fjb_saper
PostPosted: Fri Mar 21, 2008 12:37 pm    Post subject: Reply with quote

Grand High Poobah

Joined: 18 Nov 2003
Posts: 20756
Location: LI,NY

back to basics:
Quote:
Text = 'Did not understand the required format: '

So what format is on the MQMD and what format is on the RFH2?
_________________
MQ & Broker admin
Back to top
View user's profile Send private message Send e-mail
ghoshly
PostPosted: Fri Oct 23, 2009 4:45 am    Post subject: Message publication in a collective. Reply with quote

Partisan

Joined: 10 Jan 2008
Posts: 333

Hi,

I am also facing the similar issue..

I have stuck the code currently I am using.

SET OutputRoot.MQMD.Format = MQFMT_RF_HEADER_2;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Version = 2;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Format = MQFMT_STRING;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Encoding = InputRoot.MQMD.Encoding;
SET OutputRoot.MQRFH2.(MQRFH2.Field)CodedCharSetId = InputRoot.MQMD.CodedCharSetId;
SET OutputRoot.MQRFH2.(MQRFH2.Field)Flags = 0;
SET OutputRoot.MQRFH2.(MQRFH2.Field)NameValueCCSID = 1208;
SET OutputRoot.MQRFH2.(MQRFH2.Field)mcd.Msd = 'xmlnsc';

SET OutputRoot.MQRFH2.psc.Topic = 'Root/Topic/Market/#';
Back to top
View user's profile Send private message
ghoshly
PostPosted: Fri Oct 23, 2009 4:46 am    Post subject: MQ and MB version Reply with quote

Partisan

Joined: 10 Jan 2008
Posts: 333

I am though using MQ V7 and MB 6.1
Back to top
View user's profile Send private message
ghoshly
PostPosted: Mon Oct 26, 2009 3:20 am    Post subject: Same code works for broker not in collective Reply with quote

Partisan

Joined: 10 Jan 2008
Posts: 333

Hi.... I have deployed the same code in a broker which is not part of the collective and the code is working fine there and the subscribers are receiving as messages as normal...!!!

Please show some light in this path.
Back to top
View user's profile Send private message
Display posts from previous:   
Post new topic  Reply to topic Page 1 of 1

MQSeries.net Forum Index » WebSphere Message Broker (ACE) Support » Collective set up
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
 
 


Theme by Dustin Baccetti
Powered by phpBB © 2001, 2002 phpBB Group

Copyright © MQSeries.net. All rights reserved.