|
Lines 75-87
Link Here
|
| 75 |
if (reply != null) { |
75 |
if (reply != null) { |
| 76 |
|
76 |
|
| 77 |
if (log.isDebugEnabled()) { |
77 |
if (log.isDebugEnabled()) { |
| 78 |
log.debug("Received message, correlation id:" + reply.getJMSCorrelationID()); |
78 |
log.debug("Received message, correlation id:" |
|
|
79 |
+ reply.getJMSCorrelationID()); |
| 79 |
} |
80 |
} |
| 80 |
|
81 |
|
| 81 |
if (reply.getJMSCorrelationID() == null) { |
82 |
if (reply.getJMSCorrelationID() == null) { |
| 82 |
log.warn("Received message with correlation id null. Discarding message ..."); |
83 |
log |
|
|
84 |
.warn("Received message with correlation id null. Discarding message ..."); |
| 83 |
} else { |
85 |
} else { |
| 84 |
MessageAdmin.getAdmin().putReply(reply.getJMSCorrelationID(), reply); |
86 |
MessageAdmin.getAdmin().putReply( |
|
|
87 |
reply.getJMSCorrelationID(), reply); |
| 85 |
} |
88 |
} |
| 86 |
} |
89 |
} |
| 87 |
|
90 |
|
|
Lines 90-98
Link Here
|
| 90 |
} |
93 |
} |
| 91 |
} |
94 |
} |
| 92 |
// not active anymore |
95 |
// not active anymore |
| 93 |
if (session != null) { |
96 |
// close consumer, session & connection |
|
|
97 |
if (consumer != null) { |
| 94 |
try { |
98 |
try { |
| 95 |
session.close(); |
99 |
consumer.close(); |
|
|
100 |
if (session != null) |
| 101 |
session.close(); |
| 96 |
if (conn != null) |
102 |
if (conn != null) |
| 97 |
conn.close(); |
103 |
conn.close(); |
| 98 |
} catch (JMSException e) { |
104 |
} catch (JMSException e) { |