summaryrefslogtreecommitdiff
path: root/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java')
-rw-r--r--qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java10
1 files changed, 6 insertions, 4 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
index d0231e4d80..0ca43c3e2a 100644
--- a/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
+++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java
@@ -69,6 +69,7 @@ public abstract class AbstractExchange implements Exchange, Managable
private final List<Exchange.Task> _closeTaskList = new CopyOnWriteArrayList<Exchange.Task>();
+ private Map<String, Object> _arguments;
protected AbstractExchangeMBean _exchangeMbean;
@@ -115,9 +116,9 @@ public abstract class AbstractExchange implements Exchange, Managable
* called during initialisation (template method pattern).
* @return the MBean
*/
- protected abstract AbstractExchangeMBean createMBean() throws JMException;
+ protected abstract AbstractExchangeMBean<?> createMBean() throws JMException;
- public void initialise(VirtualHost host, AMQShortString name, boolean durable, int ticket, boolean autoDelete)
+ public void initialise(VirtualHost host, AMQShortString name, boolean durable, int ticket, boolean autoDelete, Map<String, Object> arguments)
throws AMQException
{
_virtualHost = host;
@@ -125,6 +126,7 @@ public abstract class AbstractExchange implements Exchange, Managable
_durable = durable;
_autoDelete = autoDelete;
_ticket = ticket;
+ _arguments = arguments;
// TODO - fix
_id = getConfigStore().createId();
@@ -293,6 +295,7 @@ public abstract class AbstractExchange implements Exchange, Managable
return _bindingCountHigh.get();
}
+ // TODO scd stuff
public final void removeBinding(final Binding binding)
{
onUnbind(binding);
@@ -325,8 +328,7 @@ public abstract class AbstractExchange implements Exchange, Managable
public Map<String, Object> getArguments()
{
- // TODO - Fix
- return Collections.EMPTY_MAP;
+ return _arguments;
}
public UUID getId()