MQSeries.net :: View topic

sagitwang · Posted: Mon Dec 01, 2008 3:39 am Post subject:

Hi

I am pretty new to MQ, currently have no idea of solving this MQRC_Q_MGR_NOT_AVAILABLE problem.

I have installed the MQ client 6 on my machine and MQ server 6 on another machine in the same cluster.

I have been trying to connect to the server from the client machine using the following code(downloaded from the Internet).

using System;
using System.Collections;

using IBM.WMQ;

namespace MQexample
{
class MQSeriesClass
{
//MQQueueManager queueManager;
MQQueue queue;
MQMessage queueMessage;
MQPutMessageOptions queuePutMessageOptions;
MQGetMessageOptions queueGetMessageOptions;

const String connectionType = MQC.TRANSPORT_MQSERIES_CLIENT;

string connectionName;
string message;

[STAThread]
static void Main(string[] args)
{

MQSeriesClass mqSeries = new MQSeriesClass();

if( mqSeries.putTheMessageIntoQueue() )
mqSeries.GetMessageFromTheQueue();

Console.ReadLine();

}

bool putTheMessageIntoQueue()
{
bool success = true;

try
{
Hashtable connectionProperties = init(MQC.TRANSPORT_MQSERIES_CLIENT);

MQQueueManager qManager = new MQQueueManager("QM_damarel_mward", connectionProperties);
//MQQueueManager qManager = new MQQueueManager("QM_damarel_mward", "TO_QM_damarel_mward", "damarel-mward.damarel.com");
// queueManager = new MQQueueManager(QueueManagerName, channelName, connectionName);

queue = qManager.AccessQueue("default", MQC.MQOO_OUTPUT + MQC.MQOO_FAIL_IF_QUIESCING);
Console.WriteLine("Enter the message to put in MQSeries server:");
message = System.Console.ReadLine();
int msgLen = message.Length;

while (msgLen == 0)
{
if (msgLen == 0)
Console.WriteLine("Please reenter the message:");
message = System.Console.ReadLine();
msgLen = message.Length;
}

queueMessage = new MQMessage();
queueMessage.WriteString(message);
queueMessage.Format = MQC.MQFMT_STRING;
queuePutMessageOptions = new MQPutMessageOptions();

//putting the message into the queue
queue.Put(queueMessage, queuePutMessageOptions);

Console.WriteLine("Success fully entered the message into the queue");
}
catch (MQException mqexp)
{
Console.WriteLine("MQSeries Exception: " + mqexp.Message);
success = false;
}

return success;
}

/// <summary>
/// Initialise the connection properties for the connection type requested
/// </summary>
/// <param name="connectionType">One of the MQC.TRANSPORT_MQSERIES_ values</param>
static Hashtable init(String connectionType)
{
Hashtable connectionProperties = new Hashtable();

// Add the connection type
connectionProperties.Add(MQC.TRANSPORT_PROPERTY, connectionType);

// Set up the rest of the connection properties, based on the
// connection type requested
switch (connectionType)
{
case MQC.TRANSPORT_MQSERIES_BINDINGS:
break;
case MQC.TRANSPORT_MQSERIES_CLIENT:
//case MQC.TRANSPORT_MQSERIES_XACLIENT:
//case MQC.TRANSPORT_MQSERIES_MANAGED:
connectionProperties.Add(MQC.HOST_NAME_PROPERTY, "damarel-mward.damarel.com");
connectionProperties.Add(MQC.CHANNEL_PROPERTY, "TO_QM_damarel_mward");
connectionProperties.Add(MQC.PORT_PROPERTY, 1414);
//connectionProperties.Add(MQC.USER_ID_PROPERTY, "mqtest");
//connectionProperties.Add(MQC.PASSWORD_PROPERTY, "Web5phere");
break;
}

return connectionProperties;
}

public void GetMessageFromTheQueue()
{
Hashtable connectionProperties = init(MQC.TRANSPORT_MQSERIES_CLIENT);

MQQueueManager qManager = new MQQueueManager("QM_damarel_mward", connectionProperties);
// queueManager = new MQQueueManager(QueueManagerName, channelName, connectionName);
queue = qManager.AccessQueue("default", MQC.MQOO_INPUT_AS_Q_DEF + MQC.MQOO_FAIL_IF_QUIESCING);
queueMessage = new MQMessage();
queueMessage.Format = MQC.MQFMT_STRING;
queueGetMessageOptions = new MQGetMessageOptions();

try
{
queue.Get(queueMessage, queueGetMessageOptions);

// Received Message.
System.Console.WriteLine("Received Message: {0}", queueMessage.ReadString(queueMessage.MessageLength));

}
catch (MQException MQExp)
{
// report the error
System.Console.WriteLine("MQQueue::Get ended with " + MQExp.Message);
}
}

}
}

Following information is what I have got from the Server machine

C:\Documents and Settings\mward>runmqsc QM_damarel_mward
5724-H72 (C) Copyright IBM Corp. 1994, 2004. ALL RIGHTS RESERVED.
Starting MQSC for queue manager QM_damarel_mward.

dis channel(*)
4 : dis channel(*)
AMQ8414: Display Channel details.
CHANNEL(RCV_QM_damarel_mward) CHLTYPE(RCVR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.ADMIN.SVRCONN) CHLTYPE(SVRCONN)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.AUTO.RECEIVER) CHLTYPE(RCVR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.AUTO.SVRCONN) CHLTYPE(SVRCONN)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.CLUSRCVR) CHLTYPE(CLUSRCVR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.CLUSSDR) CHLTYPE(CLUSSDR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.RECEIVER) CHLTYPE(RCVR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.REQUESTER) CHLTYPE(RQSTR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.SENDER) CHLTYPE(SDR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.SERVER) CHLTYPE(SVR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.SVRCONN) CHLTYPE(SVRCONN)
AMQ8414: Display Channel details.
CHANNEL(S_damarel_mward) CHLTYPE(SVRCONN)
AMQ8414: Display Channel details.
CHANNEL(TO_QM_damarel_mward) CHLTYPE(CLUSRCVR)
AMQ8414: Display Channel details.
CHANNEL(SYSTEM.DEF.CLNTCONN) CHLTYPE(CLNTCONN)

Can any1 help?

Thanks in advance

Xi