MQSeries.net :: View topic - publish-subscribe routing exit

nilendu · Posted: Thu Sep 14, 2006 3:15 pm Post subject:

Hi All,

I am just 1 months old to the MQ series technology. So please apologies
my ignorance.
My reference material is 'MQ series Publish Subscribe Users Guide.pdf'

BACKGROUD:

I am trying to deploy a publish/subscribe routing exit dll. The sample
code is amqspsra.c
It's available with the WB 6.0 installer at
F:\Program Files\IBM\WebSphere MQ\Tools\c\Samples\pubsub\.

I have simply created a VC project and copied the code into it.

I have successfully compiled the dll and updated the 'routerexitpath'
parameter for WBRK6_DEFAULT_QUEUE_MANAGER
(i am using the default configuration for this) as follows:

C:\Program Files\Microsoft Visual
Studio\MyProjects\messageexit\Debug\messageexit(RoutingExit)

where messageexit.dll is the name of my dll and RoutingExit() is the
function name that I have exported.

MY PROBLEM:

When I start the broker in pub/sub mode using the command 'strmqbrk -m
WBRK6_DEFAULT_QUEUE_MANAGER',
The Router exit gets called immediately after the broker starts.

As per my understanding, the broker should call the exit function only
when a publisher application publishes
something to the broker.

The strange thing is that the parameter pExitParm->ExitReason passed to
the exit function is MQXR_MSG. It means
a publish requests was actually sent to the broker. But I had not sent
any publish requests yet.
How did the exit get called?

The second thing I noticed is that the pExitParm->StreamName parameter
is set to SYSTEM.BROKER.ADMIN.STREAM.

If I am not wrong the default queue used to publish a message by the
broker is SYSTEM.BROKER.DEFAULT.STREAM

My routing code is as simple as follows:

void MQENTRY RoutingExit(PMQPXP pExitParm)
{
int QFound=FALSE;
int QMgrFound=FALSE;
char streamName[MQ_Q_NAME_LENGTH];
char QNameIn[MQ_Q_NAME_LENGTH];
char QNameOut[MQ_Q_NAME_LENGTH];
char QMgrNameIn[MQ_Q_MGR_NAME_LENGTH];
char QMgrNameOut[MQ_Q_MGR_NAME_LENGTH];
char DestQueue[MQ_Q_MGR_NAME_LENGTH];
char QMgrName[MQ_Q_MGR_NAME_LENGTH];
char QMgrName2[MQ_Q_MGR_NAME_LENGTH];
//char CharData[MQ_Q_MGR_NAME_LENGTH];

/***************************************************************************/
/* Switch on the reason the exit was called
*/

/***************************************************************************/
switch (pExitParm->ExitReason)
{
case MQXR_INIT:

break;

case MQXR_TERM:

break;

case MQXR_MSG:

fp =fopen("C:\\MESSAGEEXIT.TXT","w");

memset(streamName, ' ', MQ_Q_NAME_LENGTH);
memset(QNameIn, ' ', MQ_Q_NAME_LENGTH);
memset(QNameOut, ' ', MQ_Q_NAME_LENGTH);
memset(QMgrNameIn, ' ', MQ_Q_MGR_NAME_LENGTH);
memset(QMgrNameOut, ' ', MQ_Q_MGR_NAME_LENGTH);

if (pExitParm->DestinationType == MQDT_APPL)
{

fprintf(fp,"pExitParm->StreamName
%s",pExitParm->StreamName);
fprintf(fp,"pExitParm->ExitReason %s",pExitParm->ExitReason);

if (memcmp(pExitParm->QMgrName, QMgrName,
MQ_Q_MGR_NAME_LENGTH) == 0)
{

}

}
else if (pExitParm->DestinationType == MQDT_BROKER)
{

}

fflush(fp);
fclose(fp);

break;

}

This has led to another issue for me. After I start the broker which
inturn runs the router exit immediately, I am not able to
register any subscriber under this broker. I get an error message with
error number 3081:

MQRCCF_NOT_AUTHORIZED

I am out of clues

Please help!

regards,
Nilendu