com.j_spaces.jms

Class GSConnectionFactoryImpl

java.lang.Object

com.j_spaces.jms.GSConnectionFactoryImpl

All Implemented Interfaces:

Externalizable, Serializable, Remote, javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory

Direct Known Subclasses:

GSQueueConnectionFactoryImpl, GSTopicConnectionFactoryImpl, GSXAConnectionFactoryImpl

public class GSConnectionFactoryImpl
extends Object
implements javax.jms.ConnectionFactory, javax.jms.QueueConnectionFactory, javax.jms.TopicConnectionFactory, Externalizable, Remote

Implements the javax.jms.ConnectionFactory interface.
It also in charge of the following:
- Finding a SpaceProxy according to te provided space url.
- Generating connection id's.
- Managing the gigaspaces space urls used by the jms connections.
- Creates the ParserManager for selector usage.

Version:

4.0

Author:

Gershon Diner

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor and Description
GSConnectionFactoryImpl() Required for Externalizable
GSConnectionFactoryImpl(IJSpace space, IMessageConverter messageConverter)

Method Summary

Modifier and Type	Method and Description
javax.jms.Connection	createConnection()
javax.jms.Connection	createConnection(String userName, String password)
javax.jms.QueueConnection	createQueueConnection()
javax.jms.QueueConnection	createQueueConnection(String userName, String password)
javax.jms.TopicConnection	createTopicConnection()
javax.jms.TopicConnection	createTopicConnection(String userName, String password)
protected GSJMSAdmin	getAdmin()
TransactionManager	getDistributedTransactionManager()
TransactionManager	getLocalTransactionManager()
protected IMessageConverter	getMessageConverter()
protected IJSpace	getSpace()
protected String	getSpaceName()
protected SpaceURL	getSpaceURL()
protected String	nextCnxKey() According to the m_connFactoryType we decide what would be the connection key prefix.
void	readExternal(ObjectInput in)
protected void	setSpaceSecurityContext(String username, String password)
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

_logger

protected static final org.slf4j.Logger _logger

Constructor Detail

GSConnectionFactoryImpl

public GSConnectionFactoryImpl()

Required for Externalizable

GSConnectionFactoryImpl

public GSConnectionFactoryImpl(IJSpace space,
                               IMessageConverter messageConverter)
                        throws javax.jms.JMSException

Throws:

javax.jms.JMSException

Method Detail

getMessageConverter

protected IMessageConverter getMessageConverter()

getSpace

protected IJSpace getSpace()

getSpaceName

protected String getSpaceName()

getSpaceURL

protected SpaceURL getSpaceURL()

getAdmin

protected GSJMSAdmin getAdmin()
                       throws javax.jms.JMSException

Throws:

javax.jms.JMSException

setSpaceSecurityContext

protected void setSpaceSecurityContext(String username,
                                       String password)
                                throws javax.jms.JMSException

Throws:

javax.jms.JMSException

nextCnxKey

protected String nextCnxKey()

According to the m_connFactoryType we decide what would be the connection key prefix. Using tc prefix for TopicConnection or qc prefix for QueueConnection, or Using xatc prefix for XATopicConnection or xaqc prefix for XAQueueConnection.

Returns:

the next connection key.

getLocalTransactionManager

public TransactionManager getLocalTransactionManager()
                                              throws javax.jms.JMSException

Throws:

javax.jms.JMSException

getDistributedTransactionManager

public TransactionManager getDistributedTransactionManager()
                                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

createConnection

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

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Throws:

javax.jms.JMSException

createConnection

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

Specified by:

createConnection in interface javax.jms.ConnectionFactory

Throws:

javax.jms.JMSException

createQueueConnection

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

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Throws:

javax.jms.JMSException

createQueueConnection

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

Specified by:

createQueueConnection in interface javax.jms.QueueConnectionFactory

Throws:

javax.jms.JMSException

createTopicConnection

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

Specified by:

createTopicConnection in interface javax.jms.TopicConnectionFactory

Throws:

javax.jms.JMSException

createTopicConnection

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

Specified by:

createTopicConnection in interface javax.jms.TopicConnectionFactory

Throws:

javax.jms.JMSException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException