Skip to content

Commit

Permalink
disabled queueBrowser Message.
Browse files Browse the repository at this point in the history
  • Loading branch information
jia020 authored Dec 21, 2023
1 parent 1f31aad commit e360b5d
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -57,7 +57,7 @@ public List<AnalyticalJobVo> doInJms(Session session) throws JMSException {
AnalyticalJobVo jmsMsgVo = new AnalyticalJobVo();
count++;
Message message = (Message) messages.nextElement();
logger.debug("Message " + count + " : " + message);
//logger.debug("Message " + count + " : " + message);
if (message instanceof MapMessage) {
MapMessage mapMessage = (MapMessage) message;
// convert long to date
Expand Down Expand Up @@ -115,7 +115,7 @@ public List<AnalyticalJobVo> doInJms(Session session) throws JMSException {
AnalyticalJobVo jmsMsgVo = new AnalyticalJobVo();
count++;
Message message = (Message) messages.nextElement();
logger.debug("Message " + count + " : " + message);
//logger.debug("Message " + count + " : " + message);
if (message instanceof MapMessage) {
MapMessage mapMessage = (MapMessage) message;
// convert long to date
Expand Down Expand Up @@ -175,7 +175,7 @@ public List<AnalyticalJobResultVo> doInJms(Session session) throws JMSException
//AnalyticalJobResultVo jmsMsgVo = new AnalyticalJobResultVo();
count++;
Message message = (Message) messages.nextElement();
logger.debug("Message " + count + " : " + message);
//logger.debug("Message " + count + " : " + message);
if (message instanceof MapMessage) {
MapMessage mapMessage = (MapMessage) message;
String jobResult = mapMessage.getString("jobResult");
Expand Down Expand Up @@ -220,7 +220,7 @@ public List<TSGJobVo> doInJms(Session session) throws JMSException {
//AnalyticalJobResultVo jmsMsgVo = new AnalyticalJobResultVo();
count++;
Message message = (Message) messages.nextElement();
logger.debug("Message " + count + " : " + message);
//logger.debug("Message " + count + " : " + message);
if (message instanceof MapMessage) {
MapMessage mapMessage = (MapMessage) message;
String jobResult = mapMessage.getString("jobResult");
Expand Down

0 comments on commit e360b5d

Please sign in to comment.