MQSeries.net :: View topic - Problem Trying to Create Consumer using XMS.NET API

tmeinershagen · Posted: Mon Nov 12, 2007 6:25 pm Post subject:

I have properly set up MQ in our System i environment for the use of JMS. Our Java clients can adequately publish and subscribe to a given topic. However, when I use the XMS.NET client library, I am only able to publish - not consume or subscribe to those topics.

I am getting an exception when trying to connect by calling the following (the exception is encountered after hanging for the specified connection timeout period):

this._consumer = this._session.CreateDurableSubscriber(this._topic, this._properties[ConnectionProperty.TOPIC_SUBSCRIPTION_NAME], this._properties[ConnectionProperty.WMQ_MESSAGE_SELECTOR], false);

The error is as follows:

CWSMQ0006E: An exception was received during the call to the method WmqSubscriptionEngine.GetBrokerReponse: CompCode: 2, Reason: 2033. During execution of the specified method an exception was thrown by another component. See the linked exception for more information. ---> IBM.XMS.XMSException: CWSMQ0006E: An exception was received during the call to the method WmqSubscriptionEngine.GetBrokerReponse: CompCode: 2, Reason: 2033. During execution of the specified method an exception was thrown by another component. See the linked exception for more information..

The 2033 error code means that no message is available. I have set up the following properties when setting up the connection properties:

this._factoryFactory = XMSFactoryFactory.GetInstance(XMSC.CT_WMQ);
this._connectionFactory = this._factoryFactory.CreateConnectionFactory();

this._connectionFactory.SetStringProperty(XMSC.WMQ_HOST_NAME, this._properties[ConnectionProperty.WMQ_HOST_NAME]);
this._connectionFactory.SetStringProperty(XMSC.WMQ_QUEUE_MANAGER, this._properties[ConnectionProperty.WMQ_QUEUE_MANAGER]);
this._connectionFactory.SetIntProperty(XMSC.WMQ_PORT, System.Convert.ToInt32(this._properties[ConnectionProperty.WMQ_PORT]));
this._connectionFactory.SetStringProperty(XMSC.WMQ_CHANNEL, this._properties[ConnectionProperty.WMQ_CHANNEL]);
this._connectionFactory.SetIntProperty(XMSC.WMQ_CONNECTION_MODE, XMSC.WMQ_CM_CLIENT_UNMANAGED);
this._connectionFactory.SetIntProperty(XMSC.WMQ_BROKER_VERSION, XMSC.WMQ_BROKER_V1);
this._connectionFactory.SetStringProperty(XMSC.CLIENT_ID, this._properties[ConnectionProperty.CLIENT_ID]);
this._connectionFactory.SetIntProperty(XMSC.WMQ_MESSAGE_SELECTION, XMSC.WMQ_MSEL_CLIENT);

this._connection = _connectionFactory.CreateConnection(this._properties[ConnectionProperty.USERID], this._properties[ConnectionProperty.PASSWORD]);
this._session = _connection.CreateSession(false, AcknowledgeMode.ClientAcknowledge);
this._connection.Start();

I am not able to use the JNDI that Java uses to make my connection, because we are not able at this point to install the web service on our System i environment.

Does anyone have any answers as to why my connection works only during publishing but not during subscription?

Thanks for your help...