Spring AMQP

org.springframework.erlang.connection
Class SimpleConnectionFactory

java.lang.Object
  extended by org.springframework.erlang.connection.SimpleConnectionFactory
All Implemented Interfaces:
InitializingBean, ConnectionFactory

public class SimpleConnectionFactory
extends Object
implements ConnectionFactory, InitializingBean

A simple implementation of ConnectionFactory that return a new connection for each invocation of the createConnection method.

Note that use of this ConnectionFactory with ErlangTemplate has unstable behavior when invoked frequently and will be deprecated. See SingleConnectionFactory for an alternative implementation.

Provides a more traditional API to creating a connection to a remote erlang node than the JInterface API.

The following is taken from the JInterface javadocs that describe the valid node names that can be used. These naming constraints apply to the string values you pass into the node names in SimpleConnectionFactory's constructor.

About nodenames: Erlang nodenames consist of two components, an alivename and a hostname separated by '@'. Additionally, there are two nodename formats: short and long. Short names are of the form "alive@hostname", while long names are of the form "alive@host.fully.qualified.domainname". Erlang has special requirements regarding the use of the short and long formats, in particular they cannot be mixed freely in a network of communicating nodes, however Jinterface makes no distinction. See the Erlang documentation for more information about nodenames.

The constructors for the AbstractNode classes will create names exactly as you provide them as long as the name contains '@'. If the string you provide contains no '@', it will be treated as an alivename and the name of the local host will be appended, resulting in a shortname. Nodenames longer than 255 characters will be truncated without warning.

Upon initialization, this class attempts to read the file .erlang.cookie in the user's home directory, and uses the trimmed first line of the file as the default cookie by those constructors lacking a cookie argument. If for any reason the file cannot be found or read, the default cookie will be set to the empty string (""). The location of a user's home directory is determined using the system property "user.home", which may not be automatically set on all platforms.

Author:
Mark Pollack, Mark Fisher, Dave Syer

Field Summary
protected  org.apache.commons.logging.Log logger
           
 
Constructor Summary
SimpleConnectionFactory(String selfNodeName, String peerNodeName)
           
SimpleConnectionFactory(String selfNodeName, String peerNodeName, String cookie)
           
 
Method Summary
 void afterPropertiesSet()
           
 Connection createConnection()
           
 boolean isUniqueSelfNodeName()
           
 void setUniqueSelfNodeName(boolean uniqueSelfNodeName)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

protected final org.apache.commons.logging.Log logger
Constructor Detail

SimpleConnectionFactory

public SimpleConnectionFactory(String selfNodeName,
                               String peerNodeName,
                               String cookie)

SimpleConnectionFactory

public SimpleConnectionFactory(String selfNodeName,
                               String peerNodeName)
Method Detail

createConnection

public Connection createConnection()
                            throws UnknownHostException,
                                   com.ericsson.otp.erlang.OtpAuthException,
                                   IOException
Specified by:
createConnection in interface ConnectionFactory
Throws:
UnknownHostException
com.ericsson.otp.erlang.OtpAuthException
IOException

isUniqueSelfNodeName

public boolean isUniqueSelfNodeName()

setUniqueSelfNodeName

public void setUniqueSelfNodeName(boolean uniqueSelfNodeName)

afterPropertiesSet

public void afterPropertiesSet()
Specified by:
afterPropertiesSet in interface InitializingBean

Spring AMQP

Copyright © 2011. All Rights Reserved.