summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java')
-rw-r--r--qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java12
1 files changed, 9 insertions, 3 deletions
diff --git a/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java b/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java
index 56f118cf7d..cf6e98d6ca 100644
--- a/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java
+++ b/qpid/java/broker/src/test/java/org/apache/qpid/server/exchange/DefaultExchangeFactoryTest.java
@@ -170,9 +170,15 @@ public class DefaultExchangeFactoryTest extends QpidTestCase
public void testCreateDefaultExchangeFactoryWithCustomExchangeType()
{
- ExchangeType<?> customeExchangeType = new ExchangeType<Exchange>()
+ ExchangeType<?> customExchangeType = new ExchangeType<Exchange>()
{
@Override
+ public String getType()
+ {
+ return getName().toString();
+ }
+
+ @Override
public AMQShortString getName()
{
return new AMQShortString("my-custom-exchange");
@@ -192,7 +198,7 @@ public class DefaultExchangeFactoryTest extends QpidTestCase
}
};
- _stubbedExchangeTypes.add(customeExchangeType);
+ _stubbedExchangeTypes.add(customExchangeType);
_stubbedExchangeTypes.add(_directExchangeType);
_stubbedExchangeTypes.add(_topicExchangeType);
_stubbedExchangeTypes.add(_fanoutExchangeType);
@@ -206,7 +212,7 @@ public class DefaultExchangeFactoryTest extends QpidTestCase
assertTrue("Fanout exchange type is not found", registeredTypes.contains(_fanoutExchangeType));
assertTrue("Topic exchange type is not found", registeredTypes.contains(_topicExchangeType));
assertTrue("Headers exchange type is not found", registeredTypes.contains(_headersExchangeType));
- assertTrue("Custom exchange type is not found", registeredTypes.contains(customeExchangeType));
+ assertTrue("Custom exchange type is not found", registeredTypes.contains(customExchangeType));
}
private final class TestExchangeFactory extends DefaultExchangeFactory