Author: rgodfrey
Date: Thu Mar 1 14:55:40 2012
New Revision: 1295603
URL: http://svn.apache.org/viewvc?rev=1295603&view=rev
Log:
[NO-JIRA] : [AMQP 1-0 Sandbox] Undo class name change
Added:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java
(contents, props changed)
- copied, changed from r1295542,
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorMessageFilter.java
Removed:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorMessageFilter.java
Modified:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/TopicExchange.java
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/FilterManagerFactory.java
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/test/java/org/apache/qpid/server/SelectorParserTest.java
Modified:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/TopicExchange.java
URL:
http://svn.apache.org/viewvc/qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/TopicExchange.java?rev=1295603&r1=1295602&r2=1295603&view=diff
==============================================================================
---
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/TopicExchange.java
(original)
+++
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/TopicExchange.java
Thu Mar 1 14:55:40 2012
@@ -33,7 +33,7 @@ import org.apache.qpid.server.queue.Base
import org.apache.qpid.server.virtualhost.VirtualHost;
import org.apache.qpid.server.binding.Binding;
import org.apache.qpid.server.exchange.topic.*;
-import org.apache.qpid.server.filter.JMSSelectorMessageFilter;
+import org.apache.qpid.server.filter.JMSSelectorFilter;
import org.apache.qpid.server.message.InboundMessage;
import javax.management.JMException;
@@ -86,7 +86,7 @@ public class TopicExchange extends Abstr
private final Map<Binding, FieldTable> _bindings = new HashMap<Binding,
FieldTable>();
- private final Map<String, WeakReference<JMSSelectorMessageFilter>>
_selectorCache = new WeakHashMap<String,
WeakReference<JMSSelectorMessageFilter>>();
+ private final Map<String, WeakReference<JMSSelectorFilter>> _selectorCache
= new WeakHashMap<String, WeakReference<JMSSelectorFilter>>();
public TopicExchange()
{
@@ -178,17 +178,17 @@ public class TopicExchange extends Abstr
}
- private JMSSelectorMessageFilter createSelectorFilter(final FieldTable
args) throws AMQInvalidArgumentException
+ private JMSSelectorFilter createSelectorFilter(final FieldTable args)
throws AMQInvalidArgumentException
{
final String selectorString =
args.getString(AMQPFilterTypes.JMS_SELECTOR.getValue());
- WeakReference<JMSSelectorMessageFilter> selectorRef =
_selectorCache.get(selectorString);
- JMSSelectorMessageFilter selector = null;
+ WeakReference<JMSSelectorFilter> selectorRef =
_selectorCache.get(selectorString);
+ JMSSelectorFilter selector = null;
if(selectorRef == null || (selector = selectorRef.get())==null)
{
- selector = new JMSSelectorMessageFilter(selectorString);
- _selectorCache.put(selectorString, new
WeakReference<JMSSelectorMessageFilter>(selector));
+ selector = new JMSSelectorFilter(selectorString);
+ _selectorCache.put(selectorString, new
WeakReference<JMSSelectorFilter>(selector));
}
return selector;
}
Modified:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/FilterManagerFactory.java
URL:
http://svn.apache.org/viewvc/qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/FilterManagerFactory.java?rev=1295603&r1=1295602&r2=1295603&view=diff
==============================================================================
---
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/FilterManagerFactory.java
(original)
+++
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/FilterManagerFactory.java
Thu Mar 1 14:55:40 2012
@@ -51,7 +51,7 @@ public class FilterManagerFactory
if (selector != null && !selector.equals(""))
{
manager = new SimpleFilterManager();
- manager.add(new JMSSelectorMessageFilter(selector));
+ manager.add(new JMSSelectorFilter(selector));
}
}
Copied:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java
(from r1295542,
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorMessageFilter.java)
URL:
http://svn.apache.org/viewvc/qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java?p2=qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java&p1=qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorMessageFilter.java&r1=1295542&r2=1295603&rev=1295603&view=diff
==============================================================================
---
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorMessageFilter.java
(original)
+++
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java
Thu Mar 1 14:55:40 2012
@@ -26,14 +26,14 @@ import org.apache.qpid.server.filter.jms
import org.apache.qpid.server.queue.Filterable;
-public class JMSSelectorMessageFilter implements MessageFilter
+public class JMSSelectorFilter implements MessageFilter
{
- private final static Logger _logger =
org.apache.log4j.Logger.getLogger(JMSSelectorMessageFilter.class);
+ private final static Logger _logger =
org.apache.log4j.Logger.getLogger(JMSSelectorFilter.class);
private String _selector;
private BooleanExpression _matcher;
- public JMSSelectorMessageFilter(String selector) throws
AMQInvalidArgumentException
+ public JMSSelectorFilter(String selector) throws
AMQInvalidArgumentException
{
_selector = selector;
_matcher = new SelectorParser().parse(selector);
Propchange:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/filter/JMSSelectorFilter.java
------------------------------------------------------------------------------
svn:keywords = Rev Date
Modified:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
URL:
http://svn.apache.org/viewvc/qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java?rev=1295603&r1=1295602&r2=1295603&view=diff
==============================================================================
---
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
(original)
+++
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java
Thu Mar 1 14:55:40 2012
@@ -44,7 +44,6 @@ import org.apache.qpid.amqp_1_0.type.Uns
import org.apache.qpid.amqp_1_0.type.messaging.Accepted;
import org.apache.qpid.amqp_1_0.type.messaging.ExactSubjectFilter;
import org.apache.qpid.amqp_1_0.type.messaging.Filter;
-import org.apache.qpid.amqp_1_0.type.messaging.JMSSelectorFilter;
import org.apache.qpid.amqp_1_0.type.messaging.MatchingSubjectFilter;
import org.apache.qpid.amqp_1_0.type.messaging.NoLocalFilter;
import org.apache.qpid.amqp_1_0.type.messaging.Released;
@@ -58,7 +57,7 @@ import org.apache.qpid.amqp_1_0.type.tra
import org.apache.qpid.server.exchange.DirectExchange;
import org.apache.qpid.server.exchange.Exchange;
import org.apache.qpid.server.exchange.TopicExchange;
-import org.apache.qpid.server.filter.JMSSelectorMessageFilter;
+import org.apache.qpid.server.filter.JMSSelectorFilter;
import org.apache.qpid.server.filter.SimpleFilterManager;
import org.apache.qpid.server.queue.AMQQueue;
import org.apache.qpid.server.queue.AMQQueueFactory;
@@ -102,7 +101,7 @@ public class SendingLink_1_0 implements
boolean noLocal = false;
- JMSSelectorMessageFilter messageFilter = null;
+ JMSSelectorFilter messageFilter = null;
if(destination instanceof QueueDestination)
{
@@ -126,13 +125,13 @@ public class SendingLink_1_0 implements
actualFilters.put(entry.getKey(), entry.getValue());
noLocal = true;
}
- else if(messageFilter == null && entry.getValue()
instanceof JMSSelectorFilter)
+ else if(messageFilter == null && entry.getValue()
instanceof org.apache.qpid.amqp_1_0.type.messaging.JMSSelectorFilter)
{
- JMSSelectorFilter selectorFilter = (JMSSelectorFilter)
entry.getValue();
+
org.apache.qpid.amqp_1_0.type.messaging.JMSSelectorFilter selectorFilter =
(org.apache.qpid.amqp_1_0.type.messaging.JMSSelectorFilter) entry.getValue();
try
{
- messageFilter = new
JMSSelectorMessageFilter(selectorFilter.getValue());
+ messageFilter = new
JMSSelectorFilter(selectorFilter.getValue());
actualFilters.put(entry.getKey(),
entry.getValue());
}
Modified:
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/test/java/org/apache/qpid/server/SelectorParserTest.java
URL:
http://svn.apache.org/viewvc/qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/test/java/org/apache/qpid/server/SelectorParserTest.java?rev=1295603&r1=1295602&r2=1295603&view=diff
==============================================================================
---
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/test/java/org/apache/qpid/server/SelectorParserTest.java
(original)
+++
qpid/branches/rg-amqp-1-0-sandbox/qpid/java/broker/src/test/java/org/apache/qpid/server/SelectorParserTest.java
Thu Mar 1 14:55:40 2012
@@ -1,7 +1,7 @@
package org.apache.qpid.server;
import junit.framework.TestCase;
-import org.apache.qpid.server.filter.JMSSelectorMessageFilter;
+import org.apache.qpid.server.filter.JMSSelectorFilter;
import org.apache.qpid.AMQException;/*
*
* Licensed to the Apache Software Foundation (ASF) under one
@@ -104,7 +104,7 @@ public class SelectorParserTest extends
{
try
{
- new JMSSelectorMessageFilter(selector);
+ new JMSSelectorFilter(selector);
}
catch (AMQException e)
{
@@ -116,7 +116,7 @@ public class SelectorParserTest extends
{
try
{
- new JMSSelectorMessageFilter(selector);
+ new JMSSelectorFilter(selector);
fail("Selector '" + selector + "' was parsed ");
}
catch (AMQException e)
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
