| |
|
RSS Feed - WebSphere MQ Support
|
RSS Feed - Message Broker Support
|
  |
|
| Websphere 7 MQ Application stops picking up messages |
« View previous topic :: View next topic » |
| Author |
Message
|
| pjcrump |
 Posted: Mon Jul 02, 2012 7:35 am Post subject: Websphere 7 MQ Application stops picking up messages |
 |
|
Newbie
Joined: 29 Jun 2012
Posts: 2
|
I have a websphere based piece of code that is designed to pickup messages off of a MQ Queue and process them. Most of the time the code works fine but every few days, the code continues to run however it stops picking up messages even though there are messages still on the queue. In order to get the process back working I need to bump the application and then everything starts working fine.
The messages can be quite large (up to 4MB per message), I am running on WAS 7
I don't see any messages or exceptions that seem to represent an error. |
|
| Back to top |
|
 |
| pjcrump |
| Posted: Mon Jul 02, 2012 7:40 am Post subject: Here is the code.. |
|
|
Newbie
Joined: 29 Jun 2012
Posts: 2
|
Forgot the code
| Code: |
public class BlipMqProcessor {
protected static final int ONE_SECOND = 1000;
protected static final int ONE_HOUR = 60 * 60 * ONE_SECOND;
protected static final int MQ_READ_TIMEOUT = Integer.parseInt(Constants.MQ_READ_TIMEOUT_IN_SECONDS) * ONE_SECOND;
protected static int previousMqReasonCode;
protected static long previousMqErrorTime;
private BlipXmlProcessor xmlProcessor;
// Member variables for MQ processing
protected MQQueueManager qMgr;
protected MQQueue queue;
protected MQGetMessageOptions gmo;
/**
* Constructs a new BlipMqProcessor with the given values.
*/
public BlipMqProcessor() {
this(new BlipXmlProcessor());
}
/**
* Constructs a new BlipMqProcessor with the given values.
* @param xmlProcessor the processor that will be used to create the
* staging table entries.
*/
public BlipMqProcessor(final BlipXmlProcessor xmlProcessor) {
super();
this.xmlProcessor = xmlProcessor;
}
/**
* Reads XML messages from the Constants.MQ_ACCESS_QUEUE_NAME
*
* @throws BlipModelException if there are any
*/
public void readFromMQ() throws BlipModelException {
try {
createNewConnectionToMQ();
while(true) {
MQMessage outputMessage = new MQMessage();
queue.get(outputMessage,gmo);
String blipModelXml = outputMessage.readLine();
BlipLogs.logXML("BlipREQ", "0", blipModelXml);
processMessage(blipModelXml);
qMgr.commit();
}
} catch (final MQException e) {
if (e.reasonCode != MQException.MQRC_NO_MSG_AVAILABLE) {
handleMqException(e);
}
} catch (final IOException e) {
throw new BlipModelException("MQ", "Error reading MQ message.", "BlipMqProcessor.readFromMQ", e);
} finally {
cleanupMQResources();
}
}
/**
* Clean up MQ resources.
*/
private void cleanupMQResources() {
// Close queue
if(queue != null) {
try {
queue.close();
}catch(final MQException e) {
BlipModelLogger.error("MQ", "BlipMqProcessor", "Problem closing queue: " + e);
}
}
// Disconnect queue manager
if(qMgr != null) {
try {
qMgr.disconnect();
} catch (final MQException e) {
BlipModelLogger.error("MQ", "BlipMqProcessor", "Problem disconnecting from qMgr: " + e);
}
}
}
protected void createNewConnectionToMQ() throws MQException {
try {
MQEnvironment.hostname = Constants.MQ_HOST;
MQEnvironment.channel = Constants.MQ_CHANNEL;
MQEnvironment.port = Integer.parseInt(Constants.MQ_PORT);
if(Constants.MQ_SSL_CIPHER_SUITE != null) {
MQEnvironment.sslCipherSuite = Constants.MQ_SSL_CIPHER_SUITE;
MQEnvironment.sslPeerName = Constants.MQ_SSL_PEER;
} else {
MQEnvironment.sslCipherSuite = "";
MQEnvironment.sslPeerName = "";
}
qMgr = new MQQueueManager(Constants.MQ_QMGR);
int openOptions = MQC.MQOO_INPUT_AS_Q_DEF;
queue = qMgr.accessQueue(Constants.MQ_IN_ACCESS_QUEUE, openOptions);
gmo = new MQGetMessageOptions();
gmo.options = MQC.MQGMO_WAIT | MQC.MQGMO_SYNCPOINT | MQC.MQGMO_FAIL_IF_QUIESCING;
gmo.waitInterval = MQ_READ_TIMEOUT;
} finally {
MQEnvironment.sslCipherSuite = "";
MQEnvironment.sslPeerName = "";
}
}
protected void handleMqException(final MQException e) {
long currentTime = System.currentTimeMillis();
long timeBetweenMqErrors = currentTime - previousMqErrorTime;
if (previousMqReasonCode != e.reasonCode || timeBetweenMqErrors > ONE_HOUR) {
previousMqReasonCode = e.reasonCode;
previousMqErrorTime = currentTime;
BlipModelLogger.error("MQ", "BlipMqProcessor", "MQException reading from Access Queue: " + e);
}
}
} |
|
|
| Back to top |
|
|
| mqjeff |
| Posted: Mon Jul 02, 2012 8:40 am Post subject: |
|
|
Grand Master
Joined: 25 Jun 2008
Posts: 17447
|
Your code will not simply stop reading messages for no reason.
This
| Code: |
} catch (final MQException e) {
if (e.reasonCode != MQException.MQRC_NO_MSG_AVAILABLE) {
handleMqException(e);
} |
Will cause your loop to stop and no further information to be logged. |
|
| Back to top |
|
|
|
|
|
| |
|
Page 1 of 1 |
|
You cannot post new topics in this forum
You cannot reply to topics in this forum
You cannot edit your posts in this forum
You cannot delete your posts in this forum
You cannot vote in polls in this forum
|
|
|
|
