org.fusesource.stomp.jms
Class StompJmsConnectionFactory

java.lang.Object
  org.fusesource.stomp.jms.jndi.JNDIStorable
      org.fusesource.stomp.jms.StompJmsConnectionFactory

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, javax.naming.Referenceable

public class StompJmsConnectionFactory
extends JNDIStorable
implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory

Jms ConnectionFactory implementation

See Also:

Serialized Form

Constructor Summary

StompJmsConnectionFactory()
Constructor

Method Summary

protected void	buildFromProperties(java.util.Map<java.lang.String,java.lang.String> map) Set the properties that will represent the instance in JNDI
javax.jms.Connection	createConnection()
javax.jms.Connection	createConnection(java.lang.String userName, java.lang.String password)
javax.jms.QueueConnection	createQueueConnection()
javax.jms.QueueConnection	createQueueConnection(java.lang.String userName, java.lang.String password)
javax.jms.TopicConnection	createTopicConnection()
javax.jms.TopicConnection	createTopicConnection(java.lang.String userName, java.lang.String password)
java.lang.String	getBrokerURI()
java.lang.String	getLocalURI()
java.lang.String	getPassword()
java.lang.String	getQueuePrefix()
java.lang.String	getTempQueuePrefix()
java.lang.String	getTempTopicPrefix()
java.lang.String	getTopicPrefix()
java.lang.String	getUsername()
boolean	isForceAsyncSend()
protected void	populateProperties(java.util.Map<java.lang.String,java.lang.String> map) Initialize the instance from properties stored in JNDI
void	setBrokerURI(java.lang.String brokerURI)
void	setForceAsyncSend(boolean forceAsyncSend)
void	setLocalURI(java.lang.String localURI)
void	setPassword(java.lang.String password)
void	setProperties(java.util.Map<java.lang.String,java.lang.String> map) set the properties for this instance as retrieved from JNDI
void	setProperties(java.util.Properties props) Set properties
void	setQueuePrefix(java.lang.String queuePrefix)
void	setTempQueuePrefix(java.lang.String tempQueuePrefix)
void	setTempTopicPrefix(java.lang.String tempTopicPrefix)
void	setTopicPrefix(java.lang.String topicPrefix)
void	setUsername(java.lang.String username)

Methods inherited from class org.fusesource.stomp.jms.jndi.JNDIStorable

getProperties, getProperty, getReference, readExternal, writeExternal

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StompJmsConnectionFactory

public StompJmsConnectionFactory()

Constructor

Method Detail

setProperties

public void setProperties(java.util.Properties props)

Set properties

Parameters:

props -

setProperties

public void setProperties(java.util.Map<java.lang.String,java.lang.String> map)

Description copied from class: JNDIStorable

set the properties for this instance as retrieved from JNDI

Overrides:

setProperties in class JNDIStorable

buildFromProperties

protected void buildFromProperties(java.util.Map<java.lang.String,java.lang.String> map)

Description copied from class: JNDIStorable

Set the properties that will represent the instance in JNDI

Specified by:

buildFromProperties in class JNDIStorable

Parameters:

map -

populateProperties

protected void populateProperties(java.util.Map<java.lang.String,java.lang.String> map)

Description copied from class: JNDIStorable

Initialize the instance from properties stored in JNDI

Specified by:

populateProperties in class JNDIStorable

Parameters:

map -

createTopicConnection

public javax.jms.TopicConnection createTopicConnection()
                                                throws javax.jms.JMSException

Specified by:

createTopicConnection in interface javax.jms.TopicConnectionFactory

Returns:

a TopicConnection

Throws:

javax.jms.JMSException

See Also:

TopicConnectionFactory.createTopicConnection()

createTopicConnection

public javax.jms.TopicConnection createTopicConnection(java.lang.String userName,
                                                       java.lang.String password)
                                                throws javax.jms.JMSException

Specified by:

createTopicConnection in interface javax.jms.TopicConnectionFactory

Parameters:

userName -

password -

Returns:

a TopicConnection

Throws:

javax.jms.JMSException

See Also:

TopicConnectionFactory.createTopicConnection(java.lang.String, java.lang.String)

createConnection

public javax.jms.Connection createConnection()
                                      throws javax.jms.JMSException

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Returns:

a Connection

Throws:

javax.jms.JMSException

See Also:

ConnectionFactory.createConnection()

createConnection

public javax.jms.Connection createConnection(java.lang.String userName,
                                             java.lang.String password)
                                      throws javax.jms.JMSException

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Parameters:

userName -

password -

Returns:

Connection

Throws:

javax.jms.JMSException

See Also:

ConnectionFactory.createConnection(java.lang.String, java.lang.String)

createQueueConnection

public javax.jms.QueueConnection createQueueConnection()
                                                throws javax.jms.JMSException

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Returns:

a QueueConnection

Throws:

javax.jms.JMSException

See Also:

QueueConnectionFactory.createQueueConnection()

createQueueConnection

public javax.jms.QueueConnection createQueueConnection(java.lang.String userName,
                                                       java.lang.String password)
                                                throws javax.jms.JMSException

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Parameters:

userName -

password -

Returns:

a QueueConnection

Throws:

javax.jms.JMSException

See Also:

QueueConnectionFactory.createQueueConnection(java.lang.String, java.lang.String)

getBrokerURI

public java.lang.String getBrokerURI()

Returns:

the brokerURI

setBrokerURI

public void setBrokerURI(java.lang.String brokerURI)

Parameters:

brokerURI - the brokerURI to set

getLocalURI

public java.lang.String getLocalURI()

Returns:

the localURI

setLocalURI

public void setLocalURI(java.lang.String localURI)

Parameters:

localURI - the localURI to set

getUsername

public java.lang.String getUsername()

Returns:

the username

setUsername

public void setUsername(java.lang.String username)

Parameters:

username - the username to set

getPassword

public java.lang.String getPassword()

Returns:

the password

setPassword

public void setPassword(java.lang.String password)

Parameters:

password - the password to set

isForceAsyncSend

public boolean isForceAsyncSend()

setForceAsyncSend

public void setForceAsyncSend(boolean forceAsyncSend)

getQueuePrefix

public java.lang.String getQueuePrefix()

setQueuePrefix

public void setQueuePrefix(java.lang.String queuePrefix)

getTempQueuePrefix

public java.lang.String getTempQueuePrefix()

setTempQueuePrefix

public void setTempQueuePrefix(java.lang.String tempQueuePrefix)

getTempTopicPrefix

public java.lang.String getTempTopicPrefix()

setTempTopicPrefix

public void setTempTopicPrefix(java.lang.String tempTopicPrefix)

getTopicPrefix

public java.lang.String getTopicPrefix()

setTopicPrefix

public void setTopicPrefix(java.lang.String topicPrefix)