org.glite.data.common.distribution.producer
Class FiremanProducer

java.lang.Object
  extended byorg.glite.data.common.distribution.producer.FiremanProducer

public class FiremanProducer
extends java.lang.Object

Produces messages on the hierarchical catalog topic.


Field Summary
protected  javax.jms.Topic m_catalogTopic
           
protected  javax.jms.Connection m_connx
           
protected  javax.jms.ConnectionFactory m_connxF
           
protected  javax.naming.Context m_initialCtx
           
 
Constructor Summary
FiremanProducer()
           
 
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
 

Field Detail

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
Constructor Detail

FiremanProducer

public FiremanProducer()
Method Detail

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