biz.hammurapi.jms.adapter
Class BroadcastingProcessor

java.lang.Object
  extended by biz.hammurapi.jms.adapter.BroadcastingProcessor
All Implemented Interfaces:
Processor

public class BroadcastingProcessor
extends java.lang.Object
implements Processor

Broadcasts object to registered processors. Adapter client code can lookup listener and register a processor.

Author:
Pavel

Constructor Summary
BroadcastingProcessor()
           
 
Method Summary
 void addProcessor(Processor processor)
           
 java.lang.Object process(java.lang.Object obj)
          Collects non-null returns from registered processors and returns them as collection Returns null if collection is empty.
 void removeProcessor(Processor processor)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BroadcastingProcessor

public BroadcastingProcessor()
Method Detail

addProcessor

public void addProcessor(Processor processor)

removeProcessor

public void removeProcessor(Processor processor)

process

public java.lang.Object process(java.lang.Object obj)
                         throws java.lang.Exception
Collects non-null returns from registered processors and returns them as collection Returns null if collection is empty.

Specified by:
process in interface Processor
Returns:
Processing result. This result is sent as a reply from listener.
Throws:
java.lang.Exception - If exception is thrown it is also serialized and sent as error reply.


Copyright © 2006 Hammurapi Group. All Rights Reserved.