MQSeries.net :: View topic - JMS-MQ Response cannot be read

shindeashish · Posted: Fri Oct 07, 2005 1:38 am Post subject:

Problem: We have C based MQ client which accepts user inputs and sends a request message on a req. queue. It then waits on a response queue for the response. The server side component is a MDB which recieves this message (onMessage), processes it, and sends the response on the response queue. Upto this point it works as expected. However the client keeps on waiting for the response even though the message is on the response queue (the CURRDEPTH parameter when seen from runmqsc increases after MDB sends back a response).
The client waits a certain amount of time on response queue and expires giving a reason code of 2033 (No message found).
Since we are using C based client for binary transfer of data we are setting the property for format as "AP_BMH_0".
Please let me know what might be the issue/ configuration I might have missed out
The MDB side code is as follows
public void onMessage( Message requestMessage )
{

System.out.println( "Enter onMessage() of MessageBean" );

try
{
getData(requestMessage);
}
catch ( Exception exception )
{
exception.printStackTrace();
}
}

private void getData(Message msg)
{
try
{
if (msg instanceof Message) {
/***************************************************/
/* Need to get the destination that the reply will */
/* go to. This destination then needs to be used */
/* to create a QueueSender to send the actual */
/* reply. Just for curiosity, print out the name */
/* of the destination. */
/***************************************************/

Destination des = msg.getJMSReplyTo();
responseQueueName = ((MQQueue)des).getQueueName();

responseQueue = ((MQQueue)des);
System.out.println("responseQueueName "+responseQueueName);
byte[] b = new byte[500];
bmsg = (BytesMessage)msg;
int m = bmsg.readBytes(b);
String test = new String (b);
System.out.println("The message is : \n" + test);

System.out.println( "Method = "+ bmsg);

sendMessage("00C1");

}

}
catch( MessageEOFException mje ) {
/*******************************************/
/* Catch and display exception information */
/*******************************************/
System.out.println("MessageEOFException: " + mje.getErrorCode());
System.out.println("Linked exception: " + mje.getLinkedException());

}
catch( JMSException je ) {
/*******************************************/
/* Catch and display exception information */
/*******************************************/
System.out.println("JMSException: " + je);
Exception le = je.getLinkedException();
if (le != null) System.out.println("Linked exception: " + le);

} catch( Exception e ) {
/*******************************************/
/* Catch and display exception information */
/*******************************************/
System.out.println("Exception: " + e);
}
}

public void sendMessage( ArrayList messageList,
ArrayList correlationIDList )
throws Exception
{
final String METHOD_NAME = " sendMessage( ArrayList, ArrayList ) ";

String message = null;
String correlationID = null;

QueueSession session = null;
QueueSender queueSender = null;

MQQueue requestQueue = null;

BytesMessage bytesMessage = null;

int messageListSize = 0;
int correlationIDListSize = 0;

System.out.println( "Inside sendMessage" );

try
{
// If connection object is null, invoke init()
if ( connection == null )
{
init();
System.out.println("Connection object created");
}

System.out.println( "Parameters retrived from ejb-jar.xml: " );

session = connection.createQueueSession( SESSION_TRANSACTED,
Session.AUTO_ACKNOWLEDGE );
System.out.println("Session created: " );

//responseQueue = session.createQueue(responseQueueName);
if(responseQueue != null)
{
System.out.println("Response queue object created" );
}
else
{
System.out.println("Response queue object is null" );
}
responseQueue.setTargetClient( JMSC.MQJMS_CLIENT_NONJMS_MQ );
responseQueue.setCCSID( 819 );
responseQueue.setPersistence( DeliveryMode.NON_PERSISTENT );
responseQueue.setPriority( bmsg.getJMSPriority() );
//Queue responseQueue = session.createQueue(responseQueueName);
queueSender = session.createSender( responseQueue );
System.out.println("Queue Sender created: " );

queueSender.setDeliveryMode( DeliveryMode.NON_PERSISTENT );

if ( messageList != null )
{
messageListSize = messageList.size();
}

if ( correlationIDList != null )
{
correlationIDListSize = correlationIDList.size();
}

System.out.println("messageListSize: " + messageListSize
+ " correlationIDListSize: " + correlationIDListSize );

for ( int i = 0; i < messageListSize; i++ )
{
message = ( String ) messageList.get( i );

// Set the response message
bytesMessage = session.createBytesMessage();
bytesMessage.setJMSTimestamp( System.currentTimeMillis() );
bytesMessage.setJMSExpiration( System.currentTimeMillis() + (10*1000) );
bytesMessage.setJMSDeliveryMode( DeliveryMode.NON_PERSISTENT );
//bytesMessage.setJMSReplyTo( responseQueue );

//bytesMessage.setStringProperty( "JMS_IBM_Format", "AP_BMH_0" );
bytesMessage.setStringProperty( "JMS_IBM_Format", "AP_BMH_0" );

//bytesMessage.setStringProperty( "JMS_IBM_MsgType", "1" );
//bytesMessage.setStringProperty( "JMS_IBM_Character_Set", "819");

//((MQMessage)bytesMessage).characterSet = 819 ;

if ( i < correlationIDListSize )
{
correlationID = ( String ) correlationIDList.get( i );
System.out.println("correlationID: " + correlationID );

if ( correlationID != null
&& correlationID.trim().length() != 0 )
{
bytesMessage.setJMSCorrelationID( correlationID );
}
}

bytesMessage.writeBytes( message.getBytes() );

System.out.println( "Message posted: " + message );

// Post the response on the queue
queueSender.send( bytesMessage );
System.out.println( "Message sent successfully: " );
message = null;
correlationID = null;
}

session.commit();

//close all object
queueSender.close();
session.close();
connection.close();
System.out.println("Message posted successfully" );
}
catch ( JMSException jmsException )
{
try
{
session.rollback();
System.out.println( "Exception occured and session rolled back." );

}
catch ( JMSException jmsNewException )
{
System.out.println(
"Session roll back failed with exception: "
+ jmsNewException );
System.out.println("jmsNewException: " + jmsNewException.getErrorCode());
System.out.println("Linked exception: " + jmsNewException.getLinkedException());
}

System.out.println(
"JMSException in sendMessage(): " + jmsException.getMessage() );
System.out.println("jmsException: " + jmsException.getErrorCode());
System.out.println("Linked exception: " + jmsException.getLinkedException());
//throw new MOSException( MQ_UNABLE_SEND_ERROR );
}
catch ( Exception exception )
{
try
{
session.rollback();
System.out.println(
"Exception occured and session rolled back." );
}
catch ( JMSException jmsException )
{
System.out.println(
"Session roll back failed with exception: "
+ jmsException );
}

System.out.println( exception );

}
finally
{
try
{
if ( queueSender != null )
{
queueSender.close();
}

if ( session != null )
{
session.close();
}
}
catch ( JMSException jmsException )
{
System.out.println("Exception while closing session/queueSender : "
+ jmsException );
}

// Assign unused objects to null
bytesMessage = null;
message = null;
session = null;
queueSender = null;
requestQueue = null;
responseQueue = null;
}

}

/**
* Initializes the class attributes of the session bean No logging is done
* in this class as this will be invoked when the bean is deployed during
* server start up. <code>MOSGlobals</code> may not have been loaded at
* that time. This causes exception to be thrown on the console, when we try
* to use <code>MOSLog</code> methods.
*
* @throws MOSException
* In case any Error occurs while reading from ejb-xml.jar
*/
private void init() throws Exception
{
Context ctx = null;

try
{
ctx = new InitialContext();
// already retrieved in onMessage function
//responseQueueName = ( String ) ctx
// .lookup( DCONCDB_MQ_RESPONSE_QUEUE_NAME );

queueManager = ( String ) ctx.lookup( DCONCDB_MQ_QUEUE_MANAGER );

queueHost = ( String ) ctx.lookup( DCONCDB_MQ_HOST );

serverChannel = ( String ) ctx.lookup( DCONCDB_SERVER_CHANNEL );

queuePort = ( ( Integer ) ctx.lookup( DCONCDB_MQ_PORT ) ).intValue();

// For debugging purpose
buffer = new StringBuffer( " requestQueueName = " );
buffer.append( requestQueueName );
buffer.append( " responseQueueName = " )
.append( responseQueueName );
buffer.append( " queueManager = " ).append( queueManager );
buffer.append( " queueHost = " ).append( queueHost );
buffer.append( " serverChannel = " ).append( serverChannel );
buffer.append( " priority = " ).append( priority );
buffer.append( " queuePort = " ).append( queuePort );

System.out.println(buffer.toString());

factory = new com.ibm.mq.jms.MQQueueConnectionFactory();

// Setting the parameters for connection factory.
factory.setTransportType( JMSC.MQJMS_TP_CLIENT_MQ_TCPIP );
factory.setQueueManager( queueManager );
factory.setHostName( queueHost );
factory.setChannel( serverChannel );
factory.setPort( queuePort );

//Create Queue connection
connection = factory.createQueueConnection();

//Start the connection before further processing
connection.start();
}
catch ( NamingException namingException )
{
System.out.println(namingException.toString());
}
catch ( JMSException mje )
{
System.out.println("JMSException: " + mje.getErrorCode());
System.out.println("Linked exception: " + mje.getLinkedException());
}
catch ( Exception e )
{
System.out.println("Exception: " + e.toString());
System.out.println("Message: " + e.getMessage());
}
finally
{
// Initialise unused objects to null
ctx = null;
}
}