org.glite.data.common.distribution.producer
Class FiremanProducer
java.lang.Object
org.glite.data.common.distribution.producer.FiremanProducer
- public class FiremanProducer
- extends java.lang.Object
Produces messages on the hierarchical catalog topic.
Method Summary |
void |
init()
Default constructor for local host catalog channel on server 0. |
void |
init(java.lang.String JNDIhost,
java.lang.String JNDIport,
java.lang.String JMSserverName,
java.lang.String topicName)
intializes factories, jndi contexts |
static void |
main(java.lang.String[] args)
|
void |
publishCatalogEntry(FiremanMessage msg)
Called from catalog impl publishes msg onto the root topic. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
m_initialCtx
protected javax.naming.Context m_initialCtx
m_connxF
protected javax.jms.ConnectionFactory m_connxF
m_connx
protected javax.jms.Connection m_connx
m_catalogTopic
protected javax.jms.Topic m_catalogTopic
FiremanProducer
public FiremanProducer()
main
public static void main(java.lang.String[] args)
init
public void init()
throws javax.jms.JMSException,
javax.naming.NamingException
- Default constructor for local host catalog channel on server 0.
- Throws:
javax.jms.JMSException
javax.naming.NamingException
init
public void init(java.lang.String JNDIhost,
java.lang.String JNDIport,
java.lang.String JMSserverName,
java.lang.String topicName)
throws javax.jms.JMSException,
javax.naming.NamingException
- intializes factories, jndi contexts
- Throws:
javax.jms.JMSException
javax.naming.NamingException
publishCatalogEntry
public void publishCatalogEntry(FiremanMessage msg)
throws javax.jms.JMSException
- Called from catalog impl publishes msg onto the root topic.
Object published holds op id (add,del,upd etc)
source site id (as taken from the naming server)
usertoken (originating the op)
and the native FiremanCat object.
- Parameters:
msg
- Serializable object holding:
source site id (as taken from the naming server)
usertoken (originating the op)
native FiremanCat object with data
- Throws:
javax.jms.JMSException