com.lyrisoft.chat.server.remote
Class Distributor

java.lang.Object
  |
  +--com.lyrisoft.chat.server.remote.Distributor

All Implemented Interfaces:

javax.jms.MessageListener, java.lang.Runnable

public class Distributor

extends java.lang.Object

implements javax.jms.MessageListener, java.lang.Runnable

Handles sending and receiving messages over JMS TODO: connect should create an initial context and try to connect, and rotate

Field Summary

protected boolean	_connected
protected java.util.Hashtable	_env
protected java.lang.String	_jmsPass
protected java.lang.String	_jmsUser
protected javax.naming.Context	_jndiContext
protected boolean	_keepGoing
protected int	_providerUrl
protected java.lang.String[]	_providerUrls
protected java.util.List	_queue
protected ChatServer	_server
protected java.lang.String	_topicName
protected javax.jms.TopicPublisher	_topicPublisher
protected javax.jms.TopicSession	_topicSession

Constructor Summary

Distributor(ChatServer server, java.util.Properties p)

Method Summary

java.lang.Object	jndiLookup(java.lang.String name)
void	onMessage(javax.jms.Message message)
void	push(javax.jms.Message msg)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

_server

protected ChatServer _server

_queue

protected java.util.List _queue

_env

protected java.util.Hashtable _env

_providerUrls

protected java.lang.String[] _providerUrls

_providerUrl

protected int _providerUrl

_jndiContext

protected javax.naming.Context _jndiContext

_jmsUser

protected java.lang.String _jmsUser

_jmsPass

protected java.lang.String _jmsPass

_topicName

protected java.lang.String _topicName

_topicPublisher

protected javax.jms.TopicPublisher _topicPublisher

_topicSession

protected javax.jms.TopicSession _topicSession

_keepGoing

protected boolean _keepGoing

_connected

protected boolean _connected

Constructor Detail

Distributor

public Distributor(ChatServer server,
                   java.util.Properties p)
            throws PropertyException

Method Detail

jndiLookup

public java.lang.Object jndiLookup(java.lang.String name)
                            throws javax.naming.NamingException

run

public void run()

Specified by:

run in interface java.lang.Runnable

push

public void push(javax.jms.Message msg)

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener