You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2007/09/05 17:39:37 UTC
svn commit: r572972 - in
/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter:
AnyChildDestinationNode.java DestinationNode.java
Author: chirino
Date: Wed Sep 5 08:39:36 2007
New Revision: 572972
URL: http://svn.apache.org/viewvc?rev=572972&view=rev
Log:
Adding missing files that did not get commited in last patch applicaiton.
Added:
activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java
activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java
Added: activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java
URL: http://svn.apache.org/viewvc/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java?rev=572972&view=auto
==============================================================================
--- activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java (added)
+++ activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/AnyChildDestinationNode.java Wed Sep 5 08:39:36 2007
@@ -0,0 +1,140 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.filter;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.Iterator;
+import java.util.Set;
+
+/**
+ * An implementation of {@link DestinationNode} which navigates all the children of the given node
+ * ignoring the name of the current path (so for navigating using * in a wildcard).
+ *
+ * @version $Revision: 478324 $
+ */
+public class AnyChildDestinationNode implements DestinationNode {
+ private DestinationNode node;
+
+ public AnyChildDestinationNode(DestinationNode node) {
+ this.node = node;
+ }
+
+ public void appendMatchingValues(Set answer, String[] paths, int startIndex) {
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ child.appendMatchingValues(answer, paths, startIndex);
+ }
+ }
+
+
+ public void appendMatchingWildcards(Set answer, String[] paths, int startIndex) {
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ child.appendMatchingWildcards(answer, paths, startIndex);
+ }
+ }
+
+
+ public void appendDescendantValues(Set answer) {
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ child.appendDescendantValues(answer);
+ }
+ }
+
+ public DestinationNode getChild(String path) {
+ final Collection list = new ArrayList();
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ DestinationNode answer = child.getChild(path);
+ if (answer != null) {
+ list.add(answer);
+ }
+ }
+ if (!list.isEmpty()) {
+ return new AnyChildDestinationNode(this) {
+ protected Collection getChildNodes() {
+ return list;
+ }
+ };
+ }
+ return null;
+ }
+
+ public Collection getDesendentValues() {
+ Collection answer = new ArrayList();
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ answer.addAll(child.getDesendentValues());
+ }
+ return answer;
+ }
+
+ public Collection getValues() {
+ Collection answer = new ArrayList();
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ answer.addAll(child.getValues());
+ }
+ return answer;
+ }
+
+
+ public Collection getChildren() {
+ Collection answer = new ArrayList();
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ answer.addAll(child.getChildren());
+ }
+ return answer;
+ }
+
+ public Collection removeDesendentValues() {
+ Collection answer = new ArrayList();
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ answer.addAll(child.removeDesendentValues());
+ }
+ return answer;
+ }
+
+ public Collection removeValues() {
+ Collection answer = new ArrayList();
+ Iterator iter = getChildNodes().iterator();
+ while (iter.hasNext()) {
+ DestinationNode child = (DestinationNode) iter.next();
+ answer.addAll(child.removeValues());
+ }
+ return answer;
+ }
+
+ protected Collection getChildNodes() {
+ return node.getChildren();
+ }
+}
+
+
Added: activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java
URL: http://svn.apache.org/viewvc/activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java?rev=572972&view=auto
==============================================================================
--- activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java (added)
+++ activemq/branches/activemq-4.1/activemq-core/src/main/java/org/apache/activemq/filter/DestinationNode.java Wed Sep 5 08:39:36 2007
@@ -0,0 +1,46 @@
+/**
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.activemq.filter;
+
+import java.util.Collection;
+import java.util.Set;
+
+/**
+ * Represents a node in the {@link DestinationMap} tree
+ *
+ * @version $Revision: 478324 $
+ */
+public interface DestinationNode {
+ void appendMatchingValues(Set answer, String[] paths, int startIndex);
+
+ void appendMatchingWildcards(Set answer, String[] paths, int startIndex);
+
+ void appendDescendantValues(Set answer);
+
+ Collection getDesendentValues();
+
+ DestinationNode getChild(String path);
+
+ Collection getValues();
+
+ Collection getChildren();
+
+ Collection removeDesendentValues();
+
+ Collection removeValues();
+}