org.jboss.soa.esb.services.routing
Class MessageRouter
java.lang.Object
org.jboss.soa.esb.services.routing.MessageRouter
- Direct Known Subclasses:
- ContentBasedRouter
public abstract class MessageRouter
- extends java.lang.Object
Generic Message Router Interface.
- Author:
- kurt.stam@redhat.com
|
Method Summary |
static void |
deliverMessages(java.util.Collection<java.lang.String[]> destinations,
Message message,
boolean isSplitter)
Sends the message on to the service with the name(s) we just obtained
from the routing. |
abstract java.util.List<java.lang.String> |
route(Message message)
Routes the message to the next destination. |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AGGEGRATOR_TAG
public static final java.lang.String AGGEGRATOR_TAG
- See Also:
- Constant Field Values
SPLITTER_TIME_STAMP
public static final java.lang.String SPLITTER_TIME_STAMP
- See Also:
- Constant Field Values
MessageRouter
public MessageRouter()
route
public abstract java.util.List<java.lang.String> route(Message message)
throws MessageRouterException
- Routes the message to the next destination.
- Parameters:
message -
- Returns:
- List of Strings containing the services to which the message was
routed.
- Throws:
MessageRouterException
deliverMessages
public static void deliverMessages(java.util.Collection<java.lang.String[]> destinations,
Message message,
boolean isSplitter)
throws MessageRouterException
- Sends the message on to the service with the name(s) we just obtained
from the routing.
- Parameters:
destinationServices - -
Collection with the name of the destination services.message - -
the message that needs routing and deliveryboolean - - isSpitter, if true will Tag the messages for
aggregation purposes.
- Throws:
MessageRouterException