Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQP-10: Add more features to broker admin to allow customization of runtime for UN*X

Browse Source
This commit is contained in:
Dave Syer
2011-02-04 15:59:21 +00:00
parent 4915db4bf7
commit 20c1a95e57
5 changed files with 154 additions and 58 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
spring-erlang/src/main/java/org/springframework/erlang/connection/SimpleConnectionFactory.java
View File

@@ -68,6 +68,7 @@ import com.ericsson.otp.erlang.OtpSelf;
* </p>
* @author Mark Pollack
* @author Mark Fisher
* @author Dave Syer
*/
public class SimpleConnectionFactory implements ConnectionFactory, InitializingBean {
@@ -75,24 +76,24 @@ public class SimpleConnectionFactory implements ConnectionFactory, InitializingB
private boolean uniqueSelfNodeName = true;
private String selfNodeName;
private final String selfNodeName;
private String cookie;
private String peerNodeName;
private final String peerNodeName;
private final String cookie;
private OtpSelf otpSelf;
private OtpPeer otpPeer;
public SimpleConnectionFactory(String selfNodeName, String peerNodeName, String cookie) {
this(selfNodeName, peerNodeName);
this.selfNodeName = selfNodeName;
this.peerNodeName = peerNodeName;
this.cookie = cookie;
}
public SimpleConnectionFactory(String selfNodeName, String peerNodeName) {
this.selfNodeName = selfNodeName;
this.peerNodeName = peerNodeName;
this(selfNodeName, peerNodeName, null);
}
public Connection createConnection() throws UnknownHostException, OtpAuthException, IOException {