From e44aee930ea5d9e481ec23a62f8f82521abd541d Mon Sep 17 00:00:00 2001
From: Robert Davies <rajdavies@apache.org>
Date: Fri, 31 Mar 2006 08:58:20 +0000
Subject: [PATCH] added properties for userName/password

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@390370 13f79535-47bb-0310-9956-ffa450edef68
---
 .../activemq/broker/ft/MasterConnector.java   | 34 +++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
index 9cf173cc9d..bc27c5c224 100644
--- a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
+++ b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
@@ -58,6 +58,8 @@ public class MasterConnector implements Service{
     private AtomicBoolean masterActive=new AtomicBoolean(false);
     private AtomicBoolean started=new AtomicBoolean(false);
     private final IdGenerator idGenerator=new IdGenerator();
+    private String userName;
+    private String password;
 
     ConnectionInfo connectionInfo;
     SessionInfo sessionInfo;
@@ -126,6 +128,8 @@ public class MasterConnector implements Service{
         connectionInfo=new ConnectionInfo();
         connectionInfo.setConnectionId(new ConnectionId(idGenerator.generateId()));
         connectionInfo.setClientId(idGenerator.generateId());
+        connectionInfo.setUserName(userName);
+        connectionInfo.setPassword(password);
         localBroker.oneway(connectionInfo);
         remoteBroker.oneway(connectionInfo);
 
@@ -240,10 +244,40 @@ public class MasterConnector implements Service{
     public void setRemoteURI(URI remoteURI){
         this.remoteURI=remoteURI;
     }
+    
+    /**
+     * @return Returns the password.
+     */
+    public String getPassword(){
+        return password;
+    }
+
+    /**
+     * @param password The password to set.
+     */
+    public void setPassword(String password){
+        this.password=password;
+    }
+
+    /**
+     * @return Returns the userName.
+     */
+    public String getUserName(){
+        return userName;
+    }
+
+    /**
+     * @param userName The userName to set.
+     */
+    public void setUserName(String userName){
+        this.userName=userName;
+    }
 
     private void shutDown(){
         masterActive.set(false);
         broker.masterFailed();
         ServiceSupport.dispose(this);
     }
+
+   
 }