MQSeries.net :: View topic

TRANSPORTATOR · Posted: Tue Jun 27, 2006 2:06 am Post subject:

Please they can help me,

each you see that I execute the MQSample code leaves an error to me â€œhas not been the sourceâ€ qMgr = new MQQueueManager (qManager). that it can be this error, I have haberiguado the bookstores but it even follows in the same

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

public class MQSamp {

// Define el nombre del Gestor de Cola
private String qManager = "JAVAMQM";
// Define el Gestor de Cola
private MQQueueManager qMgr;

/** ********************** */
/** Cuerpo del Programa * */
/** ********************** */

// Cuando se llama la clase, esta inicializaciÃ³n se hace primero.

public static void main(String args[])
{
new MQSamp();
} // End of init

public MQSamp()
{
try {
/** CONEXION * */
// Crea una conexion con el Gestor de Cola
qMgr = new MQQueueManager(qManager);

/** ABRIR * */
// Configura las opciones en la cola que se va abrir
// ** Todas las opciones de MQSeries tiene un prefijo MQC de
// java
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_OUTPUT ;

// Especificar la cola que se va abrir con sus opciones
MQQueue system_defaul_local_queue = qMgr.accessQueue("SYSTEM_DEFAULT_LOCAL_QUEUE", openOptions);

// Definir un mensaje que se va insertar en la cola, en formato
// UTF
MQMessage hola = new MQMessage();
hola.writeUTF(" Hola Sres.");
System.out.println("prueba 1");

// Especificar las opciones del mensaje
MQPutMessageOptions pmo = new MQPutMessageOptions();

// Transferir el mensaje a la cola
system_defaul_local_queue.put(hola,pmo);

// Obtener el nuevo mensaje
// Definir primero un almacenamiento intermedio de mensaje
// MQSeries para recibir el mensaje
MQMessage retrievedMessage = new MQMessage();
retrievedMessage.messageId = hola.messageId;

// Establecer las opciones de optecion del mensaje
MQGetMessageOptions gmo = new MQGetMessageOptions();

// Extraer el mensaje de la cola
system_defaul_local_queue.get(retrievedMessage,gmo);

// Probar que tenemos el mensaje visualizado UTF
String msgText = retrievedMessage.readUTF();
System.out.print(" El mensaje es : " + msgText);

// Cerrar la cola
system_defaul_local_queue.close();

// Desconectar el Gestor de Cola
qMgr.disconnect();
}
// Si se a producido un error mas arriba, idenfificar el error
catch (MQException ex)
{
System.out.print(" Se a producido un error MQSeries : Codigo de terminacion " +
ex.completionCode + "Codigo Razon " + ex.reasonCode);
}
catch (IOException ex)
{
System.out.print(" Se a producido un error al grabar el mensaje:" + ex );
}
}
} // FIN DEL PROGRAMA