org.apache.servicemix.nmr.core
Class FlowRegistryImpl

java.lang.Object
  org.apache.servicemix.nmr.core.ServiceRegistryImpl<Flow>
      org.apache.servicemix.nmr.core.FlowRegistryImpl

All Implemented Interfaces:

Flow, FlowRegistry, ServiceRegistry<Flow>

public class FlowRegistryImpl
extends ServiceRegistryImpl<Flow>
implements FlowRegistry

The default implementation of FlowRegistry.

Since:

4.0

Version:

$Revision: $

Field Summary

Fields inherited from interface org.apache.servicemix.nmr.api.internal.Flow

ID

Constructor Summary

FlowRegistryImpl()

Method Summary

boolean	canDispatch(InternalExchange exchange, InternalEndpoint endpoint) Check if this flow can be used to dispatch the given Exchange
void	dispatch(InternalExchange exchange) Dispatch the Exchange using this flow.
AuthorizationService	getAuthorizationService()
EndpointRegistry	getRegistry()
protected boolean	internalDispatch(InternalExchange exchange, InternalEndpoint endpoint, boolean setDestination)
void	setAuthorizationService(AuthorizationService authorizationService)
void	setNonOsgiFlows(Collection<Flow> flows)
void	setRegistry(EndpointRegistry registry)

Methods inherited from class org.apache.servicemix.nmr.core.ServiceRegistryImpl

doRegister, doUnregister, getProperties, getServices, register, unregister

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.servicemix.nmr.api.service.ServiceRegistry

getProperties, getServices, register, unregister

Constructor Detail

FlowRegistryImpl

public FlowRegistryImpl()

Method Detail

getRegistry

public EndpointRegistry getRegistry()

setRegistry

public void setRegistry(EndpointRegistry registry)

getAuthorizationService

public AuthorizationService getAuthorizationService()

setAuthorizationService

public void setAuthorizationService(AuthorizationService authorizationService)

canDispatch

public boolean canDispatch(InternalExchange exchange,
                           InternalEndpoint endpoint)

Description copied from interface: Flow

Check if this flow can be used to dispatch the given Exchange

Specified by:

canDispatch in interface Flow

Parameters:

exchange - the exchange to check

endpoint - the endpoint where the exchange is to be dispatched

Returns:

true if the flow can be used, false otherwise

setNonOsgiFlows

public void setNonOsgiFlows(Collection<Flow> flows)

dispatch

public void dispatch(InternalExchange exchange)

Description copied from interface: Flow

Dispatch the Exchange using this flow.

Specified by:

dispatch in interface Flow

Parameters:

exchange - the exchange to dispatch

internalDispatch

protected boolean internalDispatch(InternalExchange exchange,
                                   InternalEndpoint endpoint,
                                   boolean setDestination)