MQSeries.net :: View topic

shantha · Posted: Mon Feb 09, 2004 7:06 am Post subject:

HI,
I have 2 WAS severs and 2 MQ servers.
The queue mangers are in cluster.
And it works in round robin fashion.As of now I have a coded my application in java.I have a virtual IP address,which connects to 2 different ip address of the mq servers.I have 2 differnt QM.For load balancing and failovers,i should be able to connect to the other QM also.When I execute this program,it works fine in alternate conditions.It works connecting to one QM,but fails while connecting to the other QM.PLease suggest me,if there should be any code change.I am in need of help
Thanks in advance

import com.ibm.mq.*;
import java.io.FileReader;
import java.io.*;
import java.util.*;

public class testsend{

public testsend()

{
String hostname = "172.17.6.23"; //virtual Ip address
String channel = "SYSTEM.DEF.SVRCONN";
String qManager = null;
MQQueueManager qMgr = null;
String outString = null;
String FileName = "ReturnXML.xml";

System.out.println("hello");
MQEnvironment.hostname = hostname;
MQEnvironment.channel = channel;
MQEnvironment.CCSID = 874;
try
{
try
{
qManager = "IMV1DEAIQM";
qMgr = new MQQueueManager(qManager);
}
catch(MQException ex)
{
qManager = "IMV2DEAIQM";
qMgr = new MQQueueManager(qManager);
System.out.println ("hello1 ");
}
int openOptions = MQC.MQOO_OUTPUT;
MQQueue q = qMgr.accessQueue("SAP.MATS.ALE_STATUS",openOptions , null, null, null);
MQMessage msg = new MQMessage();
msg.format = MQC.MQFMT_STRING;
int i = 1;
String s = null;
BufferedReader br=new BufferedReader(new InputStreamReader(new FileInputStream(FileName)));
outString=br.readLine();
while (( s = br.readLine()) != null)
{
if(i==1)
outString = s.trim();
else
outString += s.trim();
i++;
}
br.close();
msg.correlationId = generateMessageId().getBytes();
System.out.println("correlation id =" + new String(msg.correlationId));
msg.writeString(outString);
MQPutMessageOptions pmo = new MQPutMessageOptions();
q.put(msg,pmo);
System.out.println("Message Sent!");
q.close();
qMgr.disconnect();
}//try
catch(MQException ex)
{if (ex.reasonCode != 2058) {
System.out.println("An MQSeries error occurred : Completion code " +
ex.completionCode + " Reason code " + ex.reasonCode);
}
}
catch (java.io.IOException ex)
{
System.out.println("An error occurred while writing to the message buffer: " + ex);
}
}//putMessage()

// Method that returns unique Message ID

public String generateMessageId(){
String MesId = null;
try
{
GregorianCalendar gc = new GregorianCalendar();
MesId = (new Integer(gc.get(Calendar.DATE))).toString();
MesId = MesId + (new Integer(gc.get(Calendar.MONTH))).toString();
MesId = MesId + (new Integer(gc.get(Calendar.YEAR))).toString().substring(2);
MesId = MesId + (new Integer(gc.get(Calendar.HOUR))).toString();
MesId = MesId + (new Integer(gc.get(Calendar.MINUTE))).toString();
MesId = MesId + (new Integer(gc.get(Calendar.SECOND))).toString();
}
catch(Exception e){}
return "18100311122";
}
public static void main(String args[])
{
new testsend();
}
}