org.pricingnexus.worker
Class RPPconsumer

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--org.pricingnexus.worker.RPPconsumer

All Implemented Interfaces:

java.lang.Runnable

public class RPPconsumer

extends java.lang.Thread

This class belongs directly as worker class to the RawPriceProcessor. It's task is to consume the raw price messages and process them: 1) Identify them in the database, 2) Update Database and 3) send the out again with the unique internal instrument ID. If 1) is not possible, send a request for static data gathering out. $Header$

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

RPPconsumer(javax.jms.TopicPublisher simplePriceTCPublisher, javax.jms.QueueReceiver rawPriceQUReceiver, javax.jms.QueueSender sdRequestQUSender, JmsWrapper staticDataRequest, IniReader iniObject)
The constructor need three pointers to two queue connections and to one topic connection.

Method Summary

void	run() This is just an almost infinite loop that waits for incoming messages and processes them.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

RPPconsumer

public RPPconsumer(javax.jms.TopicPublisher simplePriceTCPublisher,
                   javax.jms.QueueReceiver rawPriceQUReceiver,
                   javax.jms.QueueSender sdRequestQUSender,
                   JmsWrapper staticDataRequest,
                   IniReader iniObject)

The constructor need three pointers to two queue connections and to one topic connection. They are hreadsafe so easy to use among all consumer threads. We'll later deduct the session- and message-producer/consumer objects we need so far from them

Method Detail

run

public void run()

This is just an almost infinite loop that waits for incoming messages and processes them. It ends as soon as the "stopFlag" is set to true. Something that should be done by the corresponding RawPriceProcessor thread

Overrides:

run in class java.lang.Thread