de.fhg.fokus.diameter.DiameterPeer.DiameterWorker Class Reference

List of all members.

---

Detailed Description

DiameterWorker gets a DiameterTask out of the task queue and delivers them to the listeners for further processes, if they are defined.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition at line 47 of file DiameterWorker.java.

Public Member Functions
	DiameterWorker (int id, ArrayBlockingQueue< DiameterTask > tasks)
	Constructs a DiameterWorker.
void	run ()
	Delivers a DiameterTask to a listener.
void	shutdown ()
	Shuts downs the Diameter worker.
Package Attributes
int	id
Private Attributes
boolean	running
ArrayBlockingQueue< DiameterTask >	queueTasks
Static Private Attributes
static final Logger	LOGGER = Logger.getLogger(DiameterWorker.class)
	The logger.

---

Constructor & Destructor Documentation

de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.DiameterWorker	(	int	id,
		ArrayBlockingQueue< DiameterTask >	tasks
	)

Constructs a DiameterWorker.

Parameters:

	id	An id number of the DiameterWorker.
	tasks	Task queue for saving all DiameterTasks.

Definition at line 63 of file DiameterWorker.java.

                                                                          {
        this.id = id;
        this.running = true;
        this.queueTasks = tasks;
        this.start();
    }

---

Member Function Documentation

void de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.run

(

)

Delivers a DiameterTask to a listener.

See also:

java.lang.Thread.run()

Definition at line 77 of file DiameterWorker.java.

References de.fhg.fokus.diameter.DiameterPeer.peer.Peer.diameterPeer, de.fhg.fokus.diameter.DiameterPeer.DiameterPeer.eventListeners, de.fhg.fokus.diameter.DiameterPeer.peer.Peer.FQDN, de.fhg.fokus.diameter.DiameterPeer.data.DiameterTask.msg, de.fhg.fokus.diameter.DiameterPeer.data.DiameterTask.peer, de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.queueTasks, de.fhg.fokus.diameter.DiameterPeer.EventListener.recvMessage(), and de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.running.

                      {
        DiameterTask task;
        int i, size;
        EventListener e;
        Vector listeners;
        
        while(running){
            task=null;
            try {
                task = (DiameterTask) queueTasks.take();
            } catch (InterruptedException e1) { }
        
            if (task==null||task.peer==null||task.msg==null) {
                //LOGGER.debug("["+id+"]ety "+queueTasks.size());
                continue;
            }
            //LOGGER.debug("["+id+"]got "+queueTasks.size());
            //LOGGER.debug("processing");
            listeners = task.peer.diameterPeer.eventListeners;
//          if (listeners.size()>0) ((EventListener) listeners.get(0)).recvMessage(task.peer.FQDN,task.msg);
            size = listeners.size();
            for(i=0;i<size;i++){
                e = (EventListener) listeners.get(i); 
                e.recvMessage(task.peer.FQDN,task.msg);
            }
        }
        //LOGGER.debug("["+id+"]end "+queueTasks.size());
    }

void de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.shutdown

(

)

Shuts downs the Diameter worker.

Definition at line 110 of file DiameterWorker.java.

    {
        this.running = false;
        
        // poison the queue (now it just wakes the worker)
        try {
            this.queueTasks.put(new DiameterTask(null,null));
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

---

Member Data Documentation

final Logger de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.LOGGER = Logger.getLogger(DiameterWorker.class) [static, private]

The logger.

Definition at line 50 of file DiameterWorker.java.

int de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.id [package]

Definition at line 52 of file DiameterWorker.java.

boolean de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.running [private]

Definition at line 53 of file DiameterWorker.java.

Referenced by de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.run().

ArrayBlockingQueue<DiameterTask> de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.queueTasks [private]

Definition at line 54 of file DiameterWorker.java.

Referenced by de.fhg.fokus.diameter.DiameterPeer.DiameterWorker.run().

---

The documentation for this class was generated from the following file:

• /tmp/snapshot2008906/JavaDiameterPeer/src/de/fhg/fokus/diameter/DiameterPeer/DiameterWorker.java

---