MQSeries.net :: View topic - MQJE011: Socket connection attempt refused

Kelvin · Posted: Sat Aug 26, 2006 3:07 am Post subject:

Dear all,

I try to copy the MSender.java from web to run in my machine but failed.
Below is my code

But when i comment MQEnvironment.hostname = "10.130.48.59", this program can run.

I must to connect MQ server with other machine. How do i fix it? Please advise?

Thanks

Kelvin Ho

kelvin.ho@cigna.com or kelvinho2000@yahoo.com

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

public class MSender {

private static MQQueueManager qMgr;

public MSender() {
super();
}

public static void main(String args[]) {
try {
if (args.length < 1) {
System.out.println("Missing queue name: "
+ "MSender <queue name> <qmgr name (optional)>");
} else {
System.out.println("MSender started...");

// create a new instance of the sample program
MSender mSender = new MSender();

MQEnvironment.hostname = "10.130.48.59";
MQEnvironment.port = 1414;
MQEnvironment.CCSID = 1208;
if (args.length > 1) {
qMgr = new MQQueueManager(args[1]);
} else {
System.out.println
qMgr = new MQQueueManager("");

}

int openOptions = MQC.MQOO_OUTPUT;
System.out.println("MSender started 4...");

MQQueue q =
qMgr.accessQueue(args[0], openOptions, null, null, null);

// call method to send messages
mSender.mPut(qMgr, q);

// clean up connection
q.close();
qMgr.disconnect();
System.out.println("MSender ended...");
}

} catch (MQException ex) {
System.out.println(
"WMQ exception occurred : Completion code "
+ ex.completionCode
+ " Reason code "
+ ex.reasonCode );
ex.printStackTrace();
}
}

/*************************************/
/* This method takes two parameters: */
/* qMgr - a WMQ QueueManager object */
/* q - a WMQ Queue object */
/*************************************/
public void mPut(MQQueueManager qMgr, MQQueue q) {
try {

// Define a MQ message buffer
MQMessage mBuf = new MQMessage();

// create message options
MQPutMessageOptions pmo = new MQPutMessageOptions();
// accept defaults
pmo.options = MQC.MQPMO_NONE; // use defaults

System.out.println("Enter text to send, blank line to exit");

InputStreamReader isr = new InputStreamReader(System.in);
BufferedReader br = new BufferedReader(isr);

String runShow;
do {
runShow = br.readLine();
if (runShow.length() > 0) {
mBuf.clearMessage(); // reset the buffer
mBuf.correlationId = MQC.MQCI_NONE; // set correlationId
mBuf.messageId = MQC.MQMI_NONE; // set messageId
mBuf.writeString(runShow); // set actual message
System.out.println("--> writing message to queue");
q.put(mBuf, pmo); // put the message out on the queue
}
} while (runShow.length() > 0);

} catch (MQException ex) {
System.out.println(
"MQ exception occurred : Completion code "
+ ex.completionCode
+ " Reason code "
+ ex.reasonCode);
} catch (java.io.IOException ex) {
System.out.println(
"An error occurred reading from message buffer: " + ex);
}
}
}