1 files changed, 0 insertions, 215 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java b/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java
deleted file mode 100644
index 034331abd9..0000000000
--- a/java/broker/src/main/java/org/apache/qpid/server/exchange/AbstractExchangeMBean.java
+++ /dev/null
@@ -1,215 +0,0 @@
-/*
- *
- * 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.qpid.server.exchange;
-
-import org.apache.qpid.AMQException;
-import org.apache.qpid.framing.AMQShortString;
-import org.apache.qpid.management.common.mbeans.ManagedExchange;
-import org.apache.qpid.server.logging.actors.CurrentActor;
-import org.apache.qpid.server.logging.actors.ManagementActor;
-import org.apache.qpid.server.management.AMQManagedObject;
-import org.apache.qpid.server.management.ManagedObject;
-import org.apache.qpid.server.management.ManagedObjectRegistry;
-import org.apache.qpid.server.queue.AMQQueue;
-import org.apache.qpid.server.registry.ApplicationRegistry;
-import org.apache.qpid.server.virtualhost.VirtualHost;
-
-import javax.management.JMException;
-import javax.management.MBeanException;
-import javax.management.MalformedObjectNameException;
-import javax.management.NotCompliantMBeanException;
-import javax.management.ObjectName;
-import javax.management.openmbean.ArrayType;
-import javax.management.openmbean.CompositeType;
-import javax.management.openmbean.OpenDataException;
-import javax.management.openmbean.OpenType;
-import javax.management.openmbean.SimpleType;
-import javax.management.openmbean.TabularType;
-import java.util.Collections;
-
-
-/**
-     * Abstract MBean class. This has some of the methods implemented from
- * management intrerface for exchanges. Any implementaion of an
- * Exchange MBean should extend this class.
- */
-public abstract class AbstractExchangeMBean<T extends AbstractExchange> extends AMQManagedObject implements ManagedExchange
-{
-    // open mbean data types for representing exchange bindings
-    private OpenType[] _bindingItemTypes;
-    private CompositeType _bindingDataType;
-    private TabularType _bindinglistDataType;
-
-
-    private T _exchange;
-
-    public AbstractExchangeMBean(final T abstractExchange) throws NotCompliantMBeanException
-    {
-        super(ManagedExchange.class, ManagedExchange.TYPE);
-        _exchange = abstractExchange;
-    }
-
-    protected void init() throws OpenDataException
-    {
-        _bindingItemTypes = new OpenType[2];
-        _bindingItemTypes[0] = SimpleType.STRING;
-        _bindingItemTypes[1] = new ArrayType(1, SimpleType.STRING);
-        _bindingDataType = new CompositeType("Exchange Binding", "Binding key and Queue names",
-                COMPOSITE_ITEM_NAMES.toArray(new String[COMPOSITE_ITEM_NAMES.size()]),
-                COMPOSITE_ITEM_DESCRIPTIONS.toArray(new String[COMPOSITE_ITEM_DESCRIPTIONS.size()]), _bindingItemTypes);
-        _bindinglistDataType = new TabularType("Exchange Bindings", "Exchange Bindings for " + getName(),
-                                               _bindingDataType, TABULAR_UNIQUE_INDEX.toArray(new String[TABULAR_UNIQUE_INDEX.size()]));
-    }
-
-    public ManagedObject getParentObject()
-    {
-        return _exchange.getVirtualHost().getManagedObject();
-    }
-
-    public T getExchange()
-    {
-        return _exchange;
-    }
-
-
-    public String getObjectInstanceName()
-    {
-        return ObjectName.quote(_exchange.getName());
-    }
-
-    public String getName()
-    {
-        return _exchange.getName();
-    }
-
-    public String getExchangeType()
-    {
-        return _exchange.getTypeShortString().toString();
-    }
-
-    public Integer getTicketNo()
-    {
-        return _exchange.getTicket();
-    }
-
-    public boolean isDurable()
-    {
-        return _exchange.isDurable();
-    }
-
-    public boolean isAutoDelete()
-    {
-        return _exchange.isAutoDelete();
-    }
-
-    // Added exchangetype in the object name lets maangement apps to do any customization required
-    public ObjectName getObjectName() throws MalformedObjectNameException
-    {
-        String objNameString = super.getObjectName().toString();
-        objNameString = objNameString + ",ExchangeType=" + getExchangeType();
-        return new ObjectName(objNameString);
-    }
-
-    protected ManagedObjectRegistry getManagedObjectRegistry()
-    {
-        return ApplicationRegistry.getInstance().getManagedObjectRegistry();
-    }
-
-    public void createNewBinding(String queueName, String binding) throws JMException
-    {
-        VirtualHost vhost = getExchange().getVirtualHost();
-        AMQQueue queue = vhost.getQueueRegistry().getQueue(new AMQShortString(queueName));
-        if (queue == null)
-        {
-            throw new JMException("Queue \"" + queueName + "\" is not registered with the virtualhost.");
-        }
-
-        CurrentActor.set(new ManagementActor(getLogActor().getRootMessageLogger()));
-        try
-        {
-            vhost.getBindingFactory().addBinding(binding,queue,getExchange(),null);
-        }
-        catch (AMQException ex)
-        {
-            JMException jme = new JMException(ex.toString());
-            throw new MBeanException(jme, "Error creating new binding " + binding);
-        }
-        CurrentActor.remove();
-    }
-
-    /**
-     * Removes a queue binding from the exchange.
-     *
-     * @see org.apache.qpid.server.binding.BindingFactory#removeBinding(String, AMQQueue, Exchange, java.util.Map)
-     */
-    public void removeBinding(String queueName, String binding) throws JMException
-    {
-        VirtualHost vhost = getExchange().getVirtualHost();
-        AMQQueue queue = vhost.getQueueRegistry().getQueue(new AMQShortString(queueName));
-        if (queue == null)
-        {
-            throw new JMException("Queue \"" + queueName + "\" is not registered with the virtualhost.");
-        }
-
-        CurrentActor.set(new ManagementActor(getLogActor().getRootMessageLogger()));
-        try
-        {
-            vhost.getBindingFactory().removeBinding(binding, queue, _exchange, Collections.<String, Object>emptyMap());
-        }
-        catch (AMQException ex)
-        {
-            JMException jme = new JMException(ex.toString());
-            throw new MBeanException(jme, "Error removing binding " + binding);
-        }
-        CurrentActor.remove();
-    }
-
-
-    protected OpenType[] getBindingItemTypes()
-    {
-        return _bindingItemTypes;
-    }
-
-    protected void setBindingItemTypes(OpenType[] bindingItemTypes)
-    {
-        _bindingItemTypes = bindingItemTypes;
-    }
-
-    protected CompositeType getBindingDataType()
-    {
-        return _bindingDataType;
-    }
-
-    protected void setBindingDataType(CompositeType bindingDataType)
-    {
-        _bindingDataType = bindingDataType;
-    }
-
-    protected TabularType getBindinglistDataType()
-    {
-        return _bindinglistDataType;
-    }
-
-    protected void setBindinglistDataType(TabularType bindinglistDataType)
-    {
-        _bindinglistDataType = bindinglistDataType;
-    }
-}