omq.server

Class InvocationThread

java.lang.Object

java.lang.Thread

omq.server.InvocationThread

All Implemented Interfaces:

java.lang.Runnable

public class InvocationThread
extends java.lang.Thread

An invocationThread waits for requests an invokes them.

Author:

Sergi Toda

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
InvocationThread(RemoteObject obj, java.util.concurrent.BlockingQueue<com.rabbitmq.client.QueueingConsumer.Delivery> deliveryQueue, Serializer serializer)

Method Summary

Methods

Modifier and Type	Method and Description
java.util.concurrent.BlockingQueue<com.rabbitmq.client.QueueingConsumer.Delivery>	getDeliveryQueue()
RemoteObject	getObj()
void	run()
void	setDeliveryQueue(java.util.concurrent.BlockingQueue<com.rabbitmq.client.QueueingConsumer.Delivery> deliveryQueue)
void	setObj(RemoteObject obj)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

InvocationThread

public InvocationThread(RemoteObject obj,
                java.util.concurrent.BlockingQueue<com.rabbitmq.client.QueueingConsumer.Delivery> deliveryQueue,
                Serializer serializer)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

getObj

public RemoteObject getObj()

setObj

public void setObj(RemoteObject obj)

getDeliveryQueue

public java.util.concurrent.BlockingQueue<com.rabbitmq.client.QueueingConsumer.Delivery> getDeliveryQueue()

setDeliveryQueue

public void setDeliveryQueue(java.util.concurrent.BlockingQueue<com.rabbitmq.client.QueueingConsumer.Delivery> deliveryQueue)