org.apache.servicemix.nmr.core
Class FlowRegistryImpl

java.lang.Object
  extended by org.apache.servicemix.nmr.core.ServiceRegistryImpl<Flow>
      extended by 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)


Copyright © 2005-2012 FuseSource. All Rights Reserved.