org.ow2.petals.jbi.messaging.routing.module
Class FlowFilterModule

java.lang.Object
  org.ow2.petals.jbi.messaging.routing.module.FlowFilterModule

All Implemented Interfaces:

SenderModule

public class FlowFilterModule
extends java.lang.Object
implements SenderModule

The Flow Filter Module.

The configured flows to filter are monitored by this module. Each time a component attempts a send, it is countered as an effective send.

If the number of the component send attempts overflows the maximum accepted in a window, the messages are pending until the next window, by using the Priority Queues.

Since:

3.1

Author:

rnaudin - EBM Websourcing

Constructor Summary

FlowFilterModule()

Method Summary

void	electEndpoints(java.util.Map<ServiceEndpoint,TransportSendContext> electedEndpoints, ComponentContext sourceComponentContext, org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper exchangeDecorator) Elect a list of candidate endpoints to be destination of the exchange.
protected void	start() Start the Fractal component
protected void	stop() Stop the Fractal component

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowFilterModule

public FlowFilterModule()

Method Detail

electEndpoints

public void electEndpoints(java.util.Map<ServiceEndpoint,TransportSendContext> electedEndpoints,
                           ComponentContext sourceComponentContext,
                           org.ow2.petals.jbi.messaging.exchange.MessageExchangeWrapper exchangeDecorator)
                    throws RoutingException

Description copied from interface: SenderModule

Elect a list of candidate endpoints to be destination of the exchange.

Specified by:

electEndpoints in interface SenderModule

exchangeDecorator - the exchange decorator to send

Throws:

RoutingException

start

protected void start()
              throws org.ow2.petals.regulation.RegulationException

Start the Fractal component

Throws:

org.ow2.petals.regulation.RegulationException

RoutingException

stop

protected void stop()

Stop the Fractal component