net.sf.jour.rt.agent
Class BulkEventJMSWriter

java.lang.Object
  net.sf.jour.rt.agent.BulkEventJMSWriter

All Implemented Interfaces:

BulkEventLogger

public class BulkEventJMSWriter

extends java.lang.Object

implements BulkEventLogger

TODO Add docs Created on 11.12.2004 Contributing Author(s): Misha Lifschitz (Inital implementation) Vlad Skarzhevskyy (Inital implementation)

Version:

$Revision: 1.2 $ ($Author: vlads $) $Date: 2004/12/15 08:00:36 $

Author:

vlads

Field Summary

protected org.apache.log4j.Logger	log
(package private) java.lang.String	topicBindingName
(package private) javax.jms.TopicConnection	topicConnection
(package private) java.lang.String	topicConnectionFactoryBindingName
(package private) javax.jms.TopicPublisher	topicPublisher
(package private) javax.jms.TopicSession	topicSession

Constructor Summary

BulkEventJMSWriter()

Method Summary

(package private) void	activateConnection()
(package private) boolean	checkConnection()
void	close() Close All and be ready to exit.
void	close(java.lang.Thread key) Close the Queue for this thread.
(package private) void	closeConnection()
(package private) void	getProperties()
boolean	isClose()
protected java.lang.Object	lookup(javax.naming.Context jndi, java.lang.String name, java.lang.Class target)
void	recive(java.lang.Thread key, Queue eventQueue)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.apache.log4j.Logger log

topicConnectionFactoryBindingName

java.lang.String topicConnectionFactoryBindingName

topicBindingName

java.lang.String topicBindingName

topicConnection

javax.jms.TopicConnection topicConnection

topicSession

javax.jms.TopicSession topicSession

topicPublisher

javax.jms.TopicPublisher topicPublisher

Constructor Detail

BulkEventJMSWriter

public BulkEventJMSWriter()

Method Detail

recive

public void recive(java.lang.Thread key,
                   Queue eventQueue)

Specified by:

recive in interface BulkEventLogger

checkConnection

boolean checkConnection()

getProperties

void getProperties()

activateConnection

void activateConnection()

lookup

protected java.lang.Object lookup(javax.naming.Context jndi,
                                  java.lang.String name,
                                  java.lang.Class target)
                           throws javax.naming.NamingException

Throws:

javax.naming.NamingException

closeConnection

void closeConnection()

close

public void close(java.lang.Thread key)

Close the Queue for this thread.

Specified by:

close in interface BulkEventLogger

close

public void close()

Close All and be ready to exit.

Specified by:

close in interface BulkEventLogger

isClose

public boolean isClose()

Specified by:

isClose in interface BulkEventLogger