* During the registration, the broker obtains the initial functionality * from consumer, using the {@link Consumer#getConsumerFunctionality()}, and * register that functionality into system and concrete infrastructure * services. - * + * *
* Note that consumer could register additional functionality at later point * by using service and functionality specific APIs. - * + * *
* The consumer is required to use returned session for all communication
* with broker or one of the broker services. The session is announced to
* the consumer by invoking
* {@link Consumer#onSessionInitiated(ConsumerSession)}.
- *
+ *
* @param cons
* Consumer to be registered.
- * @param context
+ * @param context
* @return a session specific to consumer registration
* @throws IllegalArgumentException
* If the consumer is null.
@@ -89,28 +93,28 @@ public interface Broker {
/**
* Registers the {@link Provider}, which will use the SAL layer.
- *
+ *
*
* During the registration, the broker obtains the initial functionality * from consumer, using the {@link Provider#getProviderFunctionality()}, and * register that functionality into system and concrete infrastructure * services. - * + * *
* Note that consumer could register additional functionality at later point * by using service and functionality specific APIs (e.g. * {@link ProviderSession#addRpcImplementation(QName, RpcImplementation)} - * + * *
* The consumer is required to use returned session for all
* communication with broker or one of the broker services. The session is
* announced to the consumer by invoking
* {@link Provider#onSessionInitiated(ProviderSession)}.
- *
- *
+ *
+ *
* @param prov
* Provider to be registered.
- * @param context
+ * @param context
* @return a session unique to the provider registration.
* @throws IllegalArgumentException
* If the provider is null.
@@ -121,25 +125,25 @@ public interface Broker {
/**
* {@link Consumer} specific access to the SAL functionality.
- *
+ *
*
* ConsumerSession is {@link Consumer}-specific access to the SAL * functionality and infrastructure services. - * + * *
* The session serves to store SAL context (e.g. registration of * functionality) for the consumer and provides access to the SAL * infrastructure services and other functionality provided by * {@link Provider}s. - * - - * + * + * + * */ public interface ConsumerSession { /** * Sends an RPC to other components registered to the broker. - * + * * @see RpcImplementation * @param rpc * Name of RPC @@ -154,7 +158,7 @@ public interface Broker { /** * Returns a session specific instance (implementation) of requested * service - * + * * @param service * Broker service * @return Session specific implementation of service @@ -163,44 +167,44 @@ public interface Broker { /** * Closes a session between consumer and broker. - * + * *
* The close operation unregisters a consumer and remove all registered * functionality of the consumer from the system. - * + * */ void close(); } /** * {@link Provider} specific access to the SAL functionality. - * + * *
* ProviderSession is {@link Provider}-specific access to the SAL * functionality and infrastructure services, which also allows for exposing * the provider's functionality to the other {@link Consumer}s. - * + * *
* The session serves to store SAL context (e.g. registration of * functionality) for the providers and exposes access to the SAL * infrastructure services, dynamic functionality registration and any other * functionality provided by other {@link Provider}s. - * + * */ public interface ProviderSession extends ConsumerSession { /** * Registers an implementation of the rpc. - * + * *
* The registered rpc functionality will be available to all other * consumers and providers registered to the broker, which are aware of * the {@link QName} assigned to the rpc. - * + * *
* There is no assumption that rpc type is in the set returned by * invoking {@link RpcImplementation#getSupportedRpcs()}. This allows * for dynamic rpc implementations. - * + * * @param rpcType * Name of Rpc * @param implementation @@ -208,26 +212,16 @@ public interface Broker { * @throws IllegalArgumentException * If the name of RPC is invalid */ - void addRpcImplementation(QName rpcType, - RpcImplementation implementation) + RpcRegistration addRpcImplementation(QName rpcType, RpcImplementation implementation) throws IllegalArgumentException; - /** - * Unregisters an Rpc implementation - * - * @param rpcType - * Name of Rpc - * @param implementation - * Registered Implementation of the Rpc functionality - * @throws IllegalArgumentException - */ - void removeRpcImplementation(QName rpcType, - RpcImplementation implementation) - throws IllegalArgumentException; + RoutedRpcRegistration addRoutedRpcImplementation(QName rpcType, RpcImplementation implementation); + + RoutedRpcRegistration addMountedRpcImplementation(QName rpcType, RpcImplementation implementation); /** * Closes a session between provider and SAL. - * + * *
* The close operation unregisters a provider and remove all registered
* functionality of the provider from the system.
@@ -237,5 +231,20 @@ public interface Broker {
@Override
boolean isClosed();
+
+ Set