|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.agila.impl.QueueServiceImpl
public class QueueServiceImpl
Constructor Summary | |
---|---|
QueueServiceImpl(MessageProcessor mp)
|
Method Summary | |
---|---|
EngineMessage |
dequeue()
|
void |
enqueue(EngineMessage em)
Sends an engine message to the core engine for processing. |
void |
run()
|
void |
start()
|
EngineMessage |
unwrap(java.lang.Object o)
Unwraps a transport object to get the enclosed engine message This is necessary because the transport receiver may be decoupled from the QueueService implementation, and this will isolate the transport from clients and other services |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueueServiceImpl(MessageProcessor mp)
Method Detail |
---|
public void start()
public EngineMessage dequeue()
public void enqueue(EngineMessage em)
QueueService
enqueue
in interface QueueService
public EngineMessage unwrap(java.lang.Object o)
unwrap
in interface QueueService
o
-
public void run()
run
in interface java.lang.Runnable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |