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

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

All Implemented Interfaces:

SenderModule

public class FlowControllerModule
extends java.lang.Object
implements SenderModule

The Flow Controller Module.

The configured flows to control are activating in the Router Monitor. Then the module calculates at each RATE_CALCULATE_PERIOD the effective rate on the controlled flow.

It tries to regulates the flow according the target rate, by slowing down the flow if necessary, using the priority Priority Queues.

Since:

3.1

Author:

rnaudin - EBM Websourcing

Field Summary

static java.lang.String

REGULATION_CONFIGURATION_FILE

Constructor Summary

FlowControllerModule()

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

Field Detail

REGULATION_CONFIGURATION_FILE

public static final java.lang.String REGULATION_CONFIGURATION_FILE

See Also:

Constant Field Values

Constructor Detail

FlowControllerModule

public FlowControllerModule()

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