org.mule.extension.internal.routing

Class RoutingManager<T,I,C>

java.lang.Object

org.mule.extension.internal.routing.RoutingManager<T,I,C>

Type Parameters:

T - the payload type that the listener accepts.

I - the request input attributes type that the listener accepts.

C - the configuration object for a given route.

public class RoutingManager<T,I,C>
extends Object

Routing manager that serves as intermediary, passing messages back and forth between operations and sources.

Sources register listeners callbacks on it and it verifies that:

• For every routingKey in a route operation there's ONE and ONLY ONE listener with that key.
• For every listener, there's AT LEAST ONE route operation with a matching key.

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<RoutingKey,Function<org.mule.runtime.extension.api.runtime.operation.Result<T,I>,DefaultRoutingContext>>	callbacks
protected Map<RoutingKey,C>	routeConfigurations

Constructor Summary

Constructors

Constructor and Description
RoutingManager()

Method Summary

Modifier and Type	Method and Description
C	getExpansionParametersConfig(RoutingKey routingKey)
void	registerListener(RoutingKey routingKey, Function<org.mule.runtime.extension.api.runtime.operation.Result<T,I>,DefaultRoutingContext> callback, C config)
RoutingContext	route(RoutingKey routingKey, org.mule.runtime.extension.api.runtime.operation.Result<T,I> sourceInput)
void	unregisterListenerContext(RoutingKey routingKey)

Methods inherited from class java.lang.Object

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

Field Detail

routeConfigurations

protected final Map<RoutingKey,C> routeConfigurations

callbacks

protected final Map<RoutingKey,Function<org.mule.runtime.extension.api.runtime.operation.Result<T,I>,DefaultRoutingContext>> callbacks

Constructor Detail

RoutingManager

public RoutingManager()

Method Detail

registerListener

public void registerListener(RoutingKey routingKey,
                             Function<org.mule.runtime.extension.api.runtime.operation.Result<T,I>,DefaultRoutingContext> callback,
                             C config)

unregisterListenerContext

public void unregisterListenerContext(RoutingKey routingKey)

getExpansionParametersConfig

public C getExpansionParametersConfig(RoutingKey routingKey)

route

public RoutingContext route(RoutingKey routingKey,
                            org.mule.runtime.extension.api.runtime.operation.Result<T,I> sourceInput)