net.sf.jour.rt.agent
Class BulkEventJMSConsumer

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

All Implemented Interfaces:

javax.jms.MessageListener, ShutdownListener

public class BulkEventJMSConsumer

extends java.lang.Object

implements javax.jms.MessageListener, ShutdownListener

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

Version:

$Revision: 1.1 $ ($Author: vlads $) $Date: 2004/12/12 02:00:01 $

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

Constructor Summary

BulkEventJMSConsumer()

Method Summary

(package private) void	getProperties()
protected java.lang.Object	lookup(javax.naming.Context jndi, java.lang.String name, java.lang.Class target)
static void	main(java.lang.String[] args)
void	onMessage(javax.jms.Message message)
void	shutdown()
static BulkEventJMSConsumer	start()

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

Constructor Detail

BulkEventJMSConsumer

public BulkEventJMSConsumer()

Method Detail

main

public static void main(java.lang.String[] args)

start

public static BulkEventJMSConsumer start()

getProperties

void getProperties()

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener

shutdown

public void shutdown()

Specified by:

shutdown in interface ShutdownListener

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