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

guard against MessageEvaluationContext dropping the message whilst doing the check 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@493032 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-01-05 13:39:42 +00:00
parent aebb18cc57
commit f89d4dcaeb
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/command/NetworkBridgeFilter.java
View File

@ -56,11 +56,13 @@ public class NetworkBridgeFilter implements DataStructure, BooleanExpression {
} }
public boolean matches(MessageEvaluationContext message) throws JMSException{ public boolean matches(MessageEvaluationContext mec) throws JMSException{
try{ try{
//for Queues - the message can be acknowledged and dropped whilst still //for Queues - the message can be acknowledged and dropped whilst still
//in the dispatch loop //in the dispatch loop
return message.getMessage() != null && matchesForwardingFilter(message.getMessage()); //so need to get the reference to it
Message message = mec.getMessage();
return message != null && matchesForwardingFilter(message);
}catch(IOException e){ }catch(IOException e){
throw JMSExceptionSupport.create(e); throw JMSExceptionSupport.create(e);
} }