Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix so that we can get the messages. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@384255 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-03-08 16:27:16 +00:00
parent 4aa503f4af
commit 5d9d499e66
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
activemq-core/src/main/java/org/apache/activemq/broker/region/Queue.java
View File

@ -432,6 +432,7 @@ public class Queue implements Destination {
for (Iterator iter = messages.iterator(); iter.hasNext();) { for (Iterator iter = messages.iterator(); iter.hasNext();) {
try { try {
MessageReference r = (MessageReference) iter.next(); MessageReference r = (MessageReference) iter.next();
r.incrementReferenceCount();
try { try {
Message m = r.getMessage(); Message m = r.getMessage();
if (m != null) { if (m != null) {