activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtu...@apache.org
Subject svn commit: r1431374 - in /activemq/trunk: activemq-broker/src/main/java/org/apache/activemq/broker/ activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ activemq-broker/src/main/java/org/apache/activemq/network/ activemq-core/src/test/java/or...
Date Thu, 10 Jan 2013 14:15:15 GMT
Author: gtully
Date: Thu Jan 10 14:15:15 2013
New Revision: 1431374

URL: http://svn.apache.org/viewvc?rev=1431374&view=rev
Log:
fix typo in utility class name

Added:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java
  (contents, props changed)
      - copied, changed from r1431369, activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSuppurt.java
Removed:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSuppurt.java
Modified:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/MBeanNetworkListener.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/BrokerService.java
Thu Jan 10 14:15:15 2013
@@ -55,7 +55,7 @@ import org.apache.activemq.Service;
 import org.apache.activemq.advisory.AdvisoryBroker;
 import org.apache.activemq.broker.cluster.ConnectionSplitBroker;
 import org.apache.activemq.broker.jmx.AnnotatedMBean;
-import org.apache.activemq.broker.jmx.BrokerMBeanSuppurt;
+import org.apache.activemq.broker.jmx.BrokerMBeanSupport;
 import org.apache.activemq.broker.jmx.BrokerView;
 import org.apache.activemq.broker.jmx.ConnectorView;
 import org.apache.activemq.broker.jmx.ConnectorViewMBean;
@@ -1992,7 +1992,7 @@ public class BrokerService implements Se
     }
 
     private ObjectName createConnectorObjectName(TransportConnector connector) throws MalformedObjectNameException
{
-        return BrokerMBeanSuppurt.createConnectorName(getBrokerObjectName(), "clientConnectors",
connector.getName());
+        return BrokerMBeanSupport.createConnectorName(getBrokerObjectName(), "clientConnectors",
connector.getName());
     }
 
     protected void registerNetworkConnectorMBean(NetworkConnector connector) throws IOException
{
@@ -2007,11 +2007,11 @@ public class BrokerService implements Se
     }
 
     protected ObjectName createNetworkConnectorObjectName(NetworkConnector connector) throws
MalformedObjectNameException {
-        return BrokerMBeanSuppurt.createNetworkConnectorName(getBrokerObjectName(), "networkConnectors",
connector.getName());
+        return BrokerMBeanSupport.createNetworkConnectorName(getBrokerObjectName(), "networkConnectors",
connector.getName());
     }
 
     public ObjectName createDuplexNetworkConnectorObjectName(String transport) throws MalformedObjectNameException
{
-        return BrokerMBeanSuppurt.createNetworkConnectorName(getBrokerObjectName(), "duplexNetworkConnectors",
transport.toString());
+        return BrokerMBeanSupport.createNetworkConnectorName(getBrokerObjectName(), "duplexNetworkConnectors",
transport.toString());
     }
 
     protected void unregisterNetworkConnectorMBean(NetworkConnector connector) {
@@ -2028,7 +2028,7 @@ public class BrokerService implements Se
     protected void registerProxyConnectorMBean(ProxyConnector connector) throws IOException
{
         ProxyConnectorView view = new ProxyConnectorView(connector);
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createNetworkConnectorName(getBrokerObjectName(),
"proxyConnectors", connector.getName());
+            ObjectName objectName = BrokerMBeanSupport.createNetworkConnectorName(getBrokerObjectName(),
"proxyConnectors", connector.getName());
             AnnotatedMBean.registerMBean(getManagementContext(), view, objectName);
         } catch (Throwable e) {
             throw IOExceptionSupport.create("Broker could not be registered in JMX: " + e.getMessage(),
e);
@@ -2038,7 +2038,7 @@ public class BrokerService implements Se
     protected void registerJmsConnectorMBean(JmsConnector connector) throws IOException {
         JmsConnectorView view = new JmsConnectorView(connector);
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createNetworkConnectorName(getBrokerObjectName(),
"jmsConnectors", connector.getName());
+            ObjectName objectName = BrokerMBeanSupport.createNetworkConnectorName(getBrokerObjectName(),
"jmsConnectors", connector.getName());
             AnnotatedMBean.registerMBean(getManagementContext(), view, objectName);
         } catch (Throwable e) {
             throw IOExceptionSupport.create("Broker could not be registered in JMX: " + e.getMessage(),
e);
@@ -2157,7 +2157,7 @@ public class BrokerService implements Se
             if (isUseJmx()) {
                 JobSchedulerViewMBean view = new JobSchedulerView(sb.getJobScheduler());
                 try {
-                    ObjectName objectName = BrokerMBeanSuppurt.createJobSchedulerServiceName(getBrokerObjectName());
+                    ObjectName objectName = BrokerMBeanSupport.createJobSchedulerServiceName(getBrokerObjectName());
                     AnnotatedMBean.registerMBean(getManagementContext(), view, objectName);
                     this.adminView.setJMSJobScheduler(objectName);
                 } catch (Throwable e) {
@@ -2170,7 +2170,7 @@ public class BrokerService implements Se
         if (isUseJmx()) {
             HealthViewMBean statusView = new HealthView((ManagedRegionBroker)getRegionBroker());
             try {
-                ObjectName objectName = BrokerMBeanSuppurt.createHealthServiceName(getBrokerObjectName());
+                ObjectName objectName = BrokerMBeanSupport.createHealthServiceName(getBrokerObjectName());
                 AnnotatedMBean.registerMBean(getManagementContext(), statusView, objectName);
             } catch (Throwable e) {
                 throw IOExceptionSupport.create("Status MBean could not be registered in
JMX: "
@@ -2221,7 +2221,7 @@ public class BrokerService implements Se
     }
 
     protected ObjectName createBrokerObjectName() throws MalformedObjectNameException  {
-        return BrokerMBeanSuppurt.createBrokerObjectName(getManagementContext().getJmxDomainName(),
getBrokerName());
+        return BrokerMBeanSupport.createBrokerObjectName(getManagementContext().getJmxDomainName(),
getBrokerName());
     }
 
     protected TransportConnector createTransportConnector(URI brokerURI) throws Exception
{

Copied: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java
(from r1431369, activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSuppurt.java)
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java?p2=activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java&p1=activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSuppurt.java&r1=1431369&r2=1431374&rev=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSuppurt.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java
Thu Jan 10 14:15:15 2013
@@ -28,7 +28,7 @@ import org.apache.activemq.command.Produ
 import org.apache.activemq.transaction.XATransaction;
 import org.apache.activemq.util.JMXSupport;
 
-public class BrokerMBeanSuppurt {
+public class BrokerMBeanSupport {
 
     // MBean Name Creation
 

Propchange: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/BrokerMBeanSupport.java
------------------------------------------------------------------------------
    svn:keywords = Rev Date

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ConnectionView.java
Thu Jan 10 14:15:15 2013
@@ -153,7 +153,7 @@ public class ConnectionView implements C
 
     private ObjectName createConsumerQueury(String clientId) throws IOException {
         try {
-            return BrokerMBeanSuppurt.createConsumerQueury(managementContext.getJmxDomainName(),
clientId);
+            return BrokerMBeanSupport.createConsumerQueury(managementContext.getJmxDomainName(),
clientId);
         } catch (Throwable e) {
             throw IOExceptionSupport.create(e);
         }
@@ -161,7 +161,7 @@ public class ConnectionView implements C
 
     private ObjectName createProducerQueury(String clientId) throws IOException {
         try {
-            return BrokerMBeanSuppurt.createProducerQueury(managementContext.getJmxDomainName(),
clientId);
+            return BrokerMBeanSupport.createProducerQueury(managementContext.getJmxDomainName(),
clientId);
         } catch (Throwable e) {
             throw IOExceptionSupport.create(e);
         }

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/DestinationView.java
Thu Jan 10 14:15:15 2013
@@ -446,7 +446,7 @@ public class DestinationView implements 
         int index = 0;
         for (Subscription subscription : subscriptions) {
             String connectionClientId = subscription.getContext().getClientId();
-            answer[index++] = BrokerMBeanSuppurt.createSubscriptionName(brokerObjectName,
connectionClientId, subscription.getConsumerInfo());
+            answer[index++] = BrokerMBeanSupport.createSubscriptionName(brokerObjectName,
connectionClientId, subscription.getConsumerInfo());
         }
         return answer;
     }

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedRegionBroker.java
Thu Jan 10 14:15:15 2013
@@ -161,7 +161,7 @@ public class ManagedRegionBroker extends
     public void register(ActiveMQDestination destName, Destination destination) {
         // TODO refactor to allow views for custom destinations
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createDestinationName(brokerObjectName,
destName);
+            ObjectName objectName = BrokerMBeanSupport.createDestinationName(brokerObjectName,
destName);
             DestinationView view;
             if (destination instanceof Queue) {
                 view = new QueueView(this, (Queue)destination);
@@ -181,7 +181,7 @@ public class ManagedRegionBroker extends
 
     public void unregister(ActiveMQDestination destName) {
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createDestinationName(brokerObjectName,
destName);
+            ObjectName objectName = BrokerMBeanSupport.createDestinationName(brokerObjectName,
destName);
             unregisterDestination(objectName);
         } catch (Exception e) {
             LOG.error("Failed to unregister " + destName, e);
@@ -193,7 +193,7 @@ public class ManagedRegionBroker extends
 
         SubscriptionKey key = new SubscriptionKey(context.getClientId(), sub.getConsumerInfo().getSubscriptionName());
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createSubscriptionName(brokerObjectName,
connectionClientId, sub.getConsumerInfo());
+            ObjectName objectName = BrokerMBeanSupport.createSubscriptionName(brokerObjectName,
connectionClientId, sub.getConsumerInfo());
             SubscriptionView view;
             if (sub.getConsumerInfo().getConsumerId().getConnectionId().equals("OFFLINE"))
{
                 // add offline subscribers to inactive list
@@ -251,7 +251,7 @@ public class ManagedRegionBroker extends
     public void addProducer(ConnectionContext context, ProducerInfo info) throws Exception
{
         super.addProducer(context, info);
         String connectionClientId = context.getClientId();
-        ObjectName objectName = BrokerMBeanSuppurt.createProducerName(brokerObjectName, context.getClientId(),
info);
+        ObjectName objectName = BrokerMBeanSupport.createProducerName(brokerObjectName, context.getClientId(),
info);
         String userName = brokerService.isPopulateUserNameInMBeans() ? context.getUserName()
: null;
         ProducerView view = new ProducerView(info, connectionClientId, userName, this);
         registerProducer(objectName, info.getDestination(), view);
@@ -259,7 +259,7 @@ public class ManagedRegionBroker extends
 
     @Override
     public void removeProducer(ConnectionContext context, ProducerInfo info) throws Exception
{
-        ObjectName objectName = BrokerMBeanSuppurt.createProducerName(brokerObjectName, context.getClientId(),
info);
+        ObjectName objectName = BrokerMBeanSupport.createProducerName(brokerObjectName, context.getClientId(),
info);
         unregisterProducer(objectName);
         super.removeProducer(context, info);
     }
@@ -269,7 +269,7 @@ public class ManagedRegionBroker extends
         if (exchange != null && exchange.getProducerState() != null && exchange.getProducerState().getInfo()
!= null) {
             ProducerInfo info = exchange.getProducerState().getInfo();
             if (info.getDestination() == null && info.getProducerId() != null) {
-                ObjectName objectName = BrokerMBeanSuppurt.createProducerName(brokerObjectName,
exchange.getConnectionContext().getClientId(), info);
+                ObjectName objectName = BrokerMBeanSupport.createProducerName(brokerObjectName,
exchange.getConnectionContext().getClientId(), info);
                 ProducerView view = this.dynamicDestinationProducers.get(objectName);
                 if (view != null) {
                     ActiveMQDestination dest = message.getDestination();
@@ -508,7 +508,7 @@ public class ManagedRegionBroker extends
     protected void addInactiveSubscription(SubscriptionKey key, SubscriptionInfo info, Subscription
subscription) {
         try {
             ConsumerInfo offlineConsumerInfo = subscription != null ? subscription.getConsumerInfo()
: ((TopicRegion)getTopicRegion()).createInactiveConsumerInfo(info);
-            ObjectName objectName = BrokerMBeanSuppurt.createSubscriptionName(brokerObjectName,
info.getClientId(), offlineConsumerInfo);
+            ObjectName objectName = BrokerMBeanSupport.createSubscriptionName(brokerObjectName,
info.getClientId(), offlineConsumerInfo);
             SubscriptionView view = new InactiveDurableSubscriptionView(this, key.getClientId(),
info, subscription);
 
             try {
@@ -676,7 +676,7 @@ public class ManagedRegionBroker extends
     public ObjectName registerSlowConsumerStrategy(AbortSlowConsumerStrategy strategy) throws
MalformedObjectNameException {
         ObjectName objectName = null;
         try {
-            objectName = BrokerMBeanSuppurt.createAbortSlowConsumerStrategyName(brokerObjectName,
strategy);
+            objectName = BrokerMBeanSupport.createAbortSlowConsumerStrategyName(brokerObjectName,
strategy);
             if (!registeredMBeans.contains(objectName))  {
                 AbortSlowConsumerStrategyView view = new AbortSlowConsumerStrategyView(this,
strategy);
                 AsyncAnnotatedMBean.registerMBean(asyncInvokeService, mbeanTimeout, managementContext,
view, objectName);
@@ -691,7 +691,7 @@ public class ManagedRegionBroker extends
 
     public void registerRecoveredTransactionMBean(XATransaction transaction) {
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createXATransactionName(brokerObjectName,
transaction);
+            ObjectName objectName = BrokerMBeanSupport.createXATransactionName(brokerObjectName,
transaction);
             if (!registeredMBeans.contains(objectName))  {
                 RecoveredXATransactionView view = new RecoveredXATransactionView(this, transaction);
                 AsyncAnnotatedMBean.registerMBean(asyncInvokeService, mbeanTimeout, managementContext,
view, objectName);
@@ -705,7 +705,7 @@ public class ManagedRegionBroker extends
 
     public void unregister(XATransaction transaction) {
         try {
-            ObjectName objectName = BrokerMBeanSuppurt.createXATransactionName(brokerObjectName,
transaction);
+            ObjectName objectName = BrokerMBeanSupport.createXATransactionName(brokerObjectName,
transaction);
             if (registeredMBeans.remove(objectName)) {
                 try {
                     managementContext.unregisterMBean(objectName);

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/ManagedTransportConnection.java
Thu Jan 10 14:15:15 2013
@@ -116,7 +116,7 @@ public class ManagedTransportConnection 
 
     protected ObjectName createObjectName(String type, String value) throws IOException {
         try {
-            return BrokerMBeanSuppurt.createConnectionViewByType(connectorName, type, value);
+            return BrokerMBeanSupport.createConnectionViewByType(connectorName, type, value);
         } catch (Throwable e) {
             throw IOExceptionSupport.create(e);
         }

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/jmx/SubscriptionView.java
Thu Jan 10 14:15:15 2013
@@ -90,7 +90,7 @@ public class SubscriptionView implements
 
     private ObjectName createConnectionQuery(ManagementContext ctx, String brokerName) throws
IOException {
         try {
-            return BrokerMBeanSuppurt.createConnectionQuery(ctx.getJmxDomainName(), brokerName,
clientId);
+            return BrokerMBeanSupport.createConnectionQuery(ctx.getJmxDomainName(), brokerName,
clientId);
         } catch (Throwable e) {
             throw IOExceptionSupport.create(e);
         }

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/MBeanNetworkListener.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/MBeanNetworkListener.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/MBeanNetworkListener.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/MBeanNetworkListener.java
Thu Jan 10 14:15:15 2013
@@ -21,7 +21,7 @@ import javax.management.ObjectName;
 
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.jmx.AnnotatedMBean;
-import org.apache.activemq.broker.jmx.BrokerMBeanSuppurt;
+import org.apache.activemq.broker.jmx.BrokerMBeanSupport;
 import org.apache.activemq.broker.jmx.NetworkBridgeView;
 import org.apache.activemq.broker.jmx.NetworkBridgeViewMBean;
 import org.slf4j.Logger;
@@ -79,7 +79,7 @@ public class MBeanNetworkListener implem
     }
 
     protected ObjectName createNetworkBridgeObjectName(NetworkBridge bridge) throws MalformedObjectNameException
{
-        return BrokerMBeanSuppurt.createNetworkBridgeObjectName(connectorName, bridge.getRemoteAddress());
+        return BrokerMBeanSupport.createNetworkBridgeObjectName(connectorName, bridge.getRemoteAddress());
     }
 
     public void setCreatedByDuplex(boolean createdByDuplex) {

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/network/NetworkConnector.java
Thu Jan 10 14:15:15 2013
@@ -30,7 +30,7 @@ import javax.management.ObjectName;
 import org.apache.activemq.Service;
 import org.apache.activemq.broker.BrokerService;
 import org.apache.activemq.broker.jmx.AnnotatedMBean;
-import org.apache.activemq.broker.jmx.BrokerMBeanSuppurt;
+import org.apache.activemq.broker.jmx.BrokerMBeanSupport;
 import org.apache.activemq.broker.jmx.NetworkBridgeView;
 import org.apache.activemq.broker.jmx.NetworkBridgeViewMBean;
 import org.apache.activemq.command.ActiveMQDestination;
@@ -229,7 +229,7 @@ public abstract class NetworkConnector e
     }
 
     protected ObjectName createNetworkBridgeObjectName(NetworkBridge bridge) throws MalformedObjectNameException
{
-        return BrokerMBeanSuppurt.createNetworkBridgeObjectName(getObjectName(), bridge.getRemoteAddress());
+        return BrokerMBeanSupport.createNetworkBridgeObjectName(getObjectName(), bridge.getRemoteAddress());
     }
 
     // ask all the bridges as we can't know to which this consumer is tied

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java?rev=1431374&r1=1431373&r2=1431374&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/broker/jmx/MBeanTest.java
Thu Jan 10 14:15:15 2013
@@ -1081,7 +1081,7 @@ public class MBeanTest extends EmbeddedB
             }
         }
         ObjectName query = //new ObjectName(domain + ":type=Broker,brokerName=localhost,connector=*,"
+ "connectorName=*,connectionName=MBeanTest");
-            BrokerMBeanSuppurt.createConnectionQuery(domain, "localhost", connection.getClientID());
+            BrokerMBeanSupport.createConnectionQuery(domain, "localhost", connection.getClientID());
 
         Set<ObjectName> names = mbeanServer.queryNames(query, null);
         boolean found = false;



Mime
View raw message