diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/Connector.java b/activemq-broker/src/main/java/org/apache/activemq/broker/Connector.java
index 314a0925715..7d9fcc8f724 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/Connector.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/Connector.java
@@ -86,4 +86,9 @@ public interface Connector extends Service {
      * @return true if connector is started
      */
     public boolean isStarted();
+
+    /**
+     * @return connector name
+     */
+    public String getName();
 }
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
index 593c4f999e3..6106471821a 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
@@ -105,6 +105,7 @@ public String getClientId() {
         return connection.getConnectionId();
     }
 
+    @Override
     public String getConnectionId() {
         return connection.getConnectionId();
     }
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
index 77eb188f5d4..6146fa92bf9 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionViewMBean.java
@@ -68,6 +68,14 @@ public interface ConnectionViewMBean extends Service {
     @MBeanInfo("client id for this connection")
     String getClientId();
 
+    /**
+     * Returns the identifier for this connection
+     *
+     * @return the identifier for this connection
+     */
+    @MBeanInfo("ID for this connection")
+    String getConnectionId();
+
     /**
      * Returns the number of messages to be dispatched to this connection
      * @return the  number of messages pending dispatch
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
index 4493e06a96a..5786172be86 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorView.java
@@ -151,4 +151,9 @@ public boolean isAutoStart() {
     public boolean isStarted() {
         return this.connector.isStarted();
     }
+
+    @Override
+    public String getName() {
+        return this.connector.getName();
+    }
 }
diff --git a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorViewMBean.java b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorViewMBean.java
index e089447c567..c2f99a27548 100644
--- a/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorViewMBean.java
+++ b/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectorViewMBean.java
@@ -101,4 +101,7 @@ public interface ConnectorViewMBean extends Service {
      */
     @MBeanInfo("Connector started")
     boolean isStarted();
+
+    @MBeanInfo("Connector name")
+    String getName();
 }
diff --git a/activemq-web-console/src/main/webapp/WEB-INF/tags/jms/forEachConnection.tag b/activemq-web-console/src/main/webapp/WEB-INF/tags/jms/forEachConnection.tag
index 6b6af7e3a20..dfa333ca672 100644
--- a/activemq-web-console/src/main/webapp/WEB-INF/tags/jms/forEachConnection.tag
+++ b/activemq-web-console/src/main/webapp/WEB-INF/tags/jms/forEachConnection.tag
@@ -23,9 +23,8 @@
 <%
 	Iterator it = broker.getConnections(connectorName).iterator();
 	while (it.hasNext()) {
-		String conName = (String) it.next();
-		ConnectionViewMBean con = broker.getConnection(conName);
-		request.setAttribute(connectionName, conName);
+		ConnectionViewMBean con = (ConnectionViewMBean) it.next();
+		request.setAttribute(connectionName, con.getClientId());
 		request.setAttribute(connection, con);
 %>
 <jsp:doBody/>
diff --git a/activemq-web-console/src/main/webapp/connections.jsp b/activemq-web-console/src/main/webapp/connections.jsp
index be280edeed1..fe75bce9e7b 100644
--- a/activemq-web-console/src/main/webapp/connections.jsp
+++ b/activemq-web-console/src/main/webapp/connections.jsp
@@ -28,8 +28,8 @@
 
 <h2>Connections</h2>
 
-<c:forEach items="${requestContext.brokerQuery.connectors}" var="connectorName">
-<h3>Connector <c:out value="${connectorName}" /></h3>
+<c:forEach items="${requestContext.brokerQuery.connectors}" var="connector">
+<h3>Connector <c:out value="${connector.name}" /></h3>
 
 <table id="connections" class="sortable autostripe">
 <thead>
@@ -41,7 +41,7 @@
 </tr>
 </thead>
 <tbody>
-<jms:forEachConnection broker="${requestContext.brokerQuery}" connectorName="${connectorName}"
+<jms:forEachConnection broker="${requestContext.brokerQuery}" connectorName="${connector.name}"
 	connection="con" connectionName="conName">
 <tr>
 
diff --git a/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacade.java b/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacade.java
index 720ebcbb16d..5f3646a82e3 100644
--- a/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacade.java
+++ b/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacade.java
@@ -134,12 +134,12 @@ Collection<DurableSubscriptionViewMBean> getInactiveDurableTopicSubscribers()
 			throws Exception;
 
 	/**
-	 * The names of all transport connectors of the broker (f.e. openwire, ssl)
+	 * All transport connectors of the broker (f.e. openwire, ssl)
 	 * 
 	 * @return not <code>null</code>
 	 * @throws Exception
 	 */
-	Collection<String> getConnectors() throws Exception;
+	Collection<ConnectorViewMBean> getConnectors() throws Exception;
 
 	/**
 	 * A transport connectors.
@@ -160,8 +160,7 @@ Collection<DurableSubscriptionViewMBean> getInactiveDurableTopicSubscribers()
 	Collection<ConnectionViewMBean> getConnections() throws Exception;
 
 	/**
-	 * The names of all connections to a specific transport connectors of the
-	 * broker.
+	 * All connections to a specific transport connectors of the broker.
 	 * 
 	 * @see #getConnection(String)
 	 * @param connectorName
@@ -169,7 +168,7 @@ Collection<DurableSubscriptionViewMBean> getInactiveDurableTopicSubscribers()
 	 * @return not <code>null</code>
 	 * @throws Exception
 	 */
-	Collection<String> getConnections(String connectorName) throws Exception;
+	Collection<ConnectionViewMBean> getConnections(String connectorName) throws Exception;
 
 	/**
 	 * A specific connection to the broker.
diff --git a/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java b/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java
index 5f8d7df610c..09e1b7cb27d 100644
--- a/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java
+++ b/activemq-web/src/main/java/org/apache/activemq/web/BrokerFacadeSupport.java
@@ -169,16 +169,13 @@ public Collection<ConnectionViewMBean> getConnections() throws Exception {
 
     @Override
     @SuppressWarnings("unchecked")
-    public Collection<String> getConnections(String connectorName) throws Exception {
+    public Collection<ConnectionViewMBean> getConnections(String connectorName) throws Exception {
         String brokerName = getBrokerName();
         ObjectName query = new ObjectName("org.apache.activemq:type=Broker,brokerName=" + brokerName
-            + ",connector=clientConnectors,connectorName=" + connectorName + ",connectionViewType=clientId" + ",connectionName=*");        Set<ObjectName> queryResult = queryNames(query, null);
-        Collection<String> result = new ArrayList<String>(queryResult.size());
-        for (ObjectName on : queryResult) {
-            String name = StringUtils.replace(on.getKeyProperty("connectionName"), "_", ":");
-            result.add(name);
-        }
-        return result;
+            + ",connector=clientConnectors,connectorName=" + connectorName + ",connectionViewType=clientId,connectionName=*");
+        Set<ObjectName> queryResult = queryNames(query, null);
+        return getManagedObjects(queryResult.toArray(new ObjectName[queryResult.size()]),
+                ConnectionViewMBean.class);
     }
 
     @Override
@@ -198,14 +195,13 @@ public ConnectionViewMBean getConnection(String connectionName) throws Exception
 
     @Override
     @SuppressWarnings("unchecked")
-    public Collection<String> getConnectors() throws Exception {
+    public Collection<ConnectorViewMBean> getConnectors() throws Exception {
         String brokerName = getBrokerName();
         ObjectName query = new ObjectName("org.apache.activemq:type=Broker,brokerName=" + brokerName + ",connector=clientConnectors,connectorName=*");
         Set<ObjectName> queryResult = queryNames(query, null);
         Collection<String> result = new ArrayList<String>(queryResult.size());
-        for (ObjectName on : queryResult)
-            result.add(on.getKeyProperty("connectorName"));
-        return result;
+        return getManagedObjects(queryResult.toArray(new ObjectName[queryResult.size()]),
+                ConnectorViewMBean.class);
     }
 
     @Override