org.apache.agila.impl
Class QueueServiceImpl

java.lang.Object
  extended by org.apache.agila.impl.QueueServiceImpl
All Implemented Interfaces:
java.lang.Runnable, QueueService

public class QueueServiceImpl
extends java.lang.Object
implements QueueService, java.lang.Runnable

Version:
$Id: $
Author:
Geir Magnusson Jr.

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

QueueServiceImpl

public QueueServiceImpl(MessageProcessor mp)
Method Detail

start

public void start()

dequeue

public EngineMessage dequeue()

enqueue

public void enqueue(EngineMessage em)
Description copied from interface: QueueService
Sends an engine message to the core engine for processing.

Specified by:
enqueue in interface QueueService

unwrap

public 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

Specified by:
unwrap in interface QueueService
Parameters:
o -
Returns:

run

public void run()
Specified by:
run in interface java.lang.Runnable


Copyright © 2004-2005 The Apache Software Foundation. All Rights Reserved.