This class implements the JMS connection factory. What is being done is,
This Initializer class then instantiates a connection factory, that
is responsible for open connections to the particular broker. The
getConnection() method requests a TCP socket connection with the broker
in question.
Fields inherited from interface cgl.narada.jms.JmsDebugFlags |
JmsConnection_Debug, JmsDestination_Debug, JmsHeader_Debug, JmsLogger_Debug, JmsMessage_Debug, JmsObjectMessage_Debug, JmsProperties_Debug, JmsTextMessage_Debug, JmsTopic_Debug, JmsTopicAndSelectorVerifier_Debug, JmsTopicConnection_Debug, JmsTopicConnectionFactory_Debug, JmsTopicPublisher_Debug, JmsTopicSession_Debug, JmsTopicSubscriber_Debug |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JmsTopicConnectionFactory
public JmsTopicConnectionFactory(String hostName,
int portNum)
JmsTopicConnectionFactory
public JmsTopicConnectionFactory(String hostName,
int portNum,
String transportType)
JmsTopicConnectionFactory
public JmsTopicConnectionFactory(Properties properties,
String transportType,
int entityId)
createTopicConnection
public TopicConnection createTopicConnection(String userName,
String password)
throws JMSException
- Creates a topic connection with the specified user identity.
The connection is created in stopped mode. No messages
will be delivered until the
Connection.start
method
is explicitly called.
- Specified by:
createTopicConnection
in interface TopicConnectionFactory
- Parameters:
userName
- the caller's user namepassword
- the caller's password
- Returns:
- a newly created topic connection
- Throws:
JMSException
- if the JMS provider fails to create a topic
connection due to some internal error.
JMSSecurityException
- if client authentication fails due to
an invalid user name or password.
createTopicConnection
public TopicConnection createTopicConnection()
throws JMSException
- Specified by:
createTopicConnection
in interface TopicConnectionFactory
- Throws:
JMSException
main
public static void main(String[] args)
For comments and suggestions please send
e-mail to
The NaradaBrokering Project