Index: activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java
===================================================================
--- activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java	(revision 582029)
+++ activemq-core/src/main/java/org/apache/activemq/broker/BrokerService.java	(working copy)
@@ -782,6 +782,15 @@
         this.managementContext = managementContext;
     }
 
+    public NetworkConnector getNetworkConnectorByName(String connectorName) {
+        for(NetworkConnector connector : networkConnectors) {
+            if(connector.getName().equals(connectorName)) {
+                return connector;
+            }
+        }
+        return null;
+    }
+
     public String[] getNetworkConnectorURIs() {
         return networkConnectorURIs;
     }
@@ -790,6 +799,15 @@
         this.networkConnectorURIs = networkConnectorURIs;
     }
 
+    public TransportConnector getConnectorByName(String connectorName) {
+        for(TransportConnector connector : transportConnectors) {
+            if(connector.getName().equals(connectorName)) {
+                return connector;
+            }
+        }
+        return null;
+    }
+
     public String[] getTransportConnectorURIs() {
         return transportConnectorURIs;
     }
Index: activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java
===================================================================
--- activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java	(revision 582029)
+++ activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerView.java	(working copy)
@@ -24,12 +24,14 @@
 import org.apache.activemq.broker.Broker;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.ConnectionContext;
+import org.apache.activemq.broker.TransportConnector;
 import org.apache.activemq.broker.region.Subscription;
 import org.apache.activemq.command.ActiveMQQueue;
 import org.apache.activemq.command.ActiveMQTopic;
 import org.apache.activemq.command.ConsumerId;
 import org.apache.activemq.command.ConsumerInfo;
 import org.apache.activemq.command.RemoveSubscriptionInfo;
+import org.apache.activemq.network.NetworkConnector;
 //import org.apache.log4j.LogManager;
 //import org.apache.log4j.PropertyConfigurator;
 
@@ -156,6 +158,30 @@
         return broker.getInactiveDurableTopicSubscribers();
     }
 
+    public String addConnector(String discoveryAddress) throws Exception {
+        TransportConnector connector = brokerService.addConnector(discoveryAddress);
+        connector.start();
+        return connector.getName();
+    }
+
+    public String addNetworkConnector(String discoveryAddress) throws Exception {
+        NetworkConnector connector = brokerService.addNetworkConnector(discoveryAddress);
+        connector.start();
+        return connector.getName();
+    }
+
+    public boolean removeConnector(String connectorName) throws Exception {
+        TransportConnector connector = brokerService.getConnectorByName(connectorName);
+        connector.stop();
+        return brokerService.removeConnector(connector);
+    }
+
+    public boolean removeNetworkConnector(String connectorName) throws Exception {
+        NetworkConnector connector = brokerService.getNetworkConnectorByName(connectorName);
+        connector.stop();
+        return brokerService.removeNetworkConnector(connector);
+    }
+
     public void addTopic(String name) throws Exception {
         broker.addDestination(getConnectionContext(broker.getContextBroker()), new ActiveMQTopic(name));
     }
Index: activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java
===================================================================
--- activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java	(revision 582029)
+++ activemq-core/src/main/java/org/apache/activemq/broker/jmx/BrokerViewMBean.java	(working copy)
@@ -90,6 +90,14 @@
 
     ObjectName[] getTemporaryQueueSubscribers();
 
+    String addConnector(String discoveryAddress) throws Exception;
+
+    String addNetworkConnector(String discoveryAddress) throws Exception;
+
+    boolean removeConnector(String connectorName) throws Exception;
+
+    boolean removeNetworkConnector(String connectorName) throws Exception;
+
     /**
      * Adds a Topic destination to the broker.
      *