From c30a6a81c478389c44cf37d5d0930f62013bc293 Mon Sep 17 00:00:00 2001
From: "Hiram R. Chirino" <chirino@apache.org>
Date: Tue, 20 Dec 2005 21:19:28 +0000
Subject: [PATCH] the useEmbeddedBroker property not needed anymore.

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@358106 13f79535-47bb-0310-9956-ffa450edef68
---
 .../activemq/axis/ActiveMQVendorAdapter.java  | 20 -------------------
 .../activemq/benchmark/BenchmarkSupport.java  | 12 -----------
 2 files changed, 32 deletions(-)

diff --git a/activemq-optional/src/main/java/org/activemq/axis/ActiveMQVendorAdapter.java b/activemq-optional/src/main/java/org/activemq/axis/ActiveMQVendorAdapter.java
index 2fae9e26e5..4e3482170d 100755
--- a/activemq-optional/src/main/java/org/activemq/axis/ActiveMQVendorAdapter.java
+++ b/activemq-optional/src/main/java/org/activemq/axis/ActiveMQVendorAdapter.java
@@ -52,11 +52,6 @@ public class ActiveMQVendorAdapter extends BeanVendorAdapter {
      */
     public final static String DEFAULT_PASSWORD = "defaultPassword";
 
-    /**
-     * Specifies whether the broker is embedded
-     */
-    public final static String EMBEDDED_BROKER = "embeddedBroker";
-
 
     public QueueConnectionFactory getQueueConnectionFactory(HashMap properties)
             throws Exception {
@@ -84,14 +79,10 @@ public class ActiveMQVendorAdapter extends BeanVendorAdapter {
         if (jmsUrl.getPropertyValue(DEFAULT_PASSWORD) != null) {
             properties.put(DEFAULT_PASSWORD, jmsUrl.getPropertyValue(DEFAULT_PASSWORD));
         }
-        if (jmsUrl.getPropertyValue(EMBEDDED_BROKER) != null) {
-            properties.put(EMBEDDED_BROKER, jmsUrl.getPropertyValue(EMBEDDED_BROKER));
-        }
     }
 
     public boolean isMatchingConnectionFactory(ConnectionFactory connectionFactory, JMSURLHelper jmsURL, HashMap properties) {
         String brokerURL = null;
-        boolean embeddedBroker = false;
 
         if (connectionFactory instanceof ActiveMQConnectionFactory) {
             ActiveMQConnectionFactory amqConnectionFactory =
@@ -99,7 +90,6 @@ public class ActiveMQVendorAdapter extends BeanVendorAdapter {
 
             // get existing queue connection factory properties
             brokerURL = amqConnectionFactory.getBrokerURL();
-            embeddedBroker = amqConnectionFactory.isUseEmbeddedBroker();
         }
 
         // compare broker url
@@ -107,16 +97,6 @@ public class ActiveMQVendorAdapter extends BeanVendorAdapter {
         if (!brokerURL.equals(propertyBrokerURL)) {
             return false;
         }
-
-        // compare load balancing flag
-        String tmpEmbeddedBroker = (String) properties.get(EMBEDDED_BROKER);
-        boolean propertyEmbeddedBroker = false;
-        if (tmpEmbeddedBroker != null) {
-            propertyEmbeddedBroker = Boolean.valueOf(tmpEmbeddedBroker).booleanValue();
-        }
-        if (embeddedBroker != propertyEmbeddedBroker) {
-            return false;
-        }
         return true;
     }
 }
diff --git a/activemq-optional/src/main/java/org/activemq/benchmark/BenchmarkSupport.java b/activemq-optional/src/main/java/org/activemq/benchmark/BenchmarkSupport.java
index ecf63113dd..11a9c95e3f 100755
--- a/activemq-optional/src/main/java/org/activemq/benchmark/BenchmarkSupport.java
+++ b/activemq-optional/src/main/java/org/activemq/benchmark/BenchmarkSupport.java
@@ -42,7 +42,6 @@ public class BenchmarkSupport {
     protected int connectionCount = 1;
     protected int batch = 1000;
     protected Destination destination;
-    protected boolean embeddedBroker = false;
     private boolean topic = true;
     private boolean durable = false;
 
@@ -112,14 +111,6 @@ public class BenchmarkSupport {
         this.durable = durable;
     }
 
-    public boolean isEmbeddedBroker() {
-        return embeddedBroker;
-    }
-
-    public void setEmbeddedBroker(boolean embeddedBroker) {
-        this.embeddedBroker = embeddedBroker;
-    }
-
     public int getConnectionCount() {
         return connectionCount;
     }
@@ -148,9 +139,6 @@ public class BenchmarkSupport {
 
     protected ActiveMQConnectionFactory createFactory() {
         ActiveMQConnectionFactory answer = new ActiveMQConnectionFactory(getUrl());
-        if (embeddedBroker) {
-            answer.setUseEmbeddedBroker(true);
-        }
         return answer;
     }