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

minor generics, import, and javadoc cleanup 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@732184 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
David Jencks 2009-01-06 23:52:36 +00:00
parent e2c83d6fb6
commit 34acbdc154
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
activemq-core/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
View File

@ -17,9 +17,8 @@
package org.apache.activemq.broker.region;
import java.io.IOException;
import java.util.Iterator;
import java.util.Set;
import java.util.List;
import java.util.Set;
import org.apache.activemq.broker.Broker;
import org.apache.activemq.broker.ConnectionContext;
@ -108,14 +107,17 @@ public class DestinationFilter implements Destination {
/**
* Sends a message to the given destination which may be a wildcard
* @param context broker context
* @param message message to send
* @param destination possibly wildcard destination to send the message to
* @throws Exception on error
*/
protected void send(ProducerBrokerExchange context, Message message, ActiveMQDestination destination)
throws Exception {
Broker broker = context.getConnectionContext().getBroker();
Set destinations = broker.getDestinations(destination);
Set<Destination> destinations = broker.getDestinations(destination);
for (Iterator iter = destinations.iterator(); iter.hasNext();) {
Destination dest = (Destination)iter.next();
for (Destination dest : destinations) {
dest.send(context, message.copy());
}
}