svn commit: r390370 - /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java

[ra...@apache.org]

Author: rajdavies
Date: Fri Mar 31 00:58:20 2006
New Revision: 390370

URL: http://svn.apache.org/viewcvs?rev=390370&view=rev
Log:
added properties for userName/password

Modified:
    incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java

Modified: incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java
URL: http://svn.apache.org/viewcvs/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java?rev=390370&r1=390369&r2=390370&view=diff
==============================================================================
--- incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java (original)
+++ incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java Fri Mar 31 00:58:20 2006
@@ -58,6 +58,8 @@
     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 @@
         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 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);
     }
+
+   
 }