建立SOA架构中的事件驱动服务 (7)

onfigurationBuilder();
　　manager = builder.createStartedManager(true,
　　protocol + "tmp/events");
　　eventClient = new MuleClient();
　　receiveEndpoint = new MuleEndpoint(protocol
　　+ "tmp/events/receive");
　　sendEndpoint = new MuleEndpoint(protocol + "tmp/events/send");
　　}
　　catch (UMOException e)
　　{
　　System.err.println(e);
　　}
　　}
　　/**
　　* Stops this event manager.
　　*/
　　public void stop()
　　{
　　try
　　{
　　manager.stop();
　　}　　　　 catch (UMOException e)
　　{
　　System.err.println(e);
　　}
　　}
　　/**
　　* Retrieves the protocol this event manager uses.
　　* @return
　　*/
　　public String getProtocol()
　　{
　　
　　return protocol;
　　}　　　/**
　　* Registers a service to receive event messages.
　　*
　　* @param serviceName
　　The name to associate with the service.
　　* @param implementation
　　Either a container reference to the service
　　*
　　or a fully-qualified class name
　　*
　　to use as the component implementation.
　　*/
　　public void registerService(String serviceName,
　　String implementation)
　　throws EventException
　　{
　　if (!manager.getModel().isComponentRegistered(serviceName))
　　{
　　try
　　{
　　builder.registerComponent(implementation,
　　serviceName,
　　receiveEndpoint,
　　sendEndpoint);
　　}
　　catch (UMOException e)
　　{
　　throw new EventException(e.toString());
　　}
　　}
　　}　　　/**
　　* Unregisters a service from receiving event messages.
　　*
　　* @param serviceName　The name associated with the service to unregister.
　　*/
　　public void unregisterService(String serviceName)
　　throws EventException
　　{
　　try
　　{
　　builder.unregisterComponent(serviceName);
　　}
　　catch (UMOException e)
　　{
　　throw new EventException(e.toString());
　　}
　　}
　　/**
　　* Sends an event message synchronously to a given service.
　　*
　　* @param serviceName
　　The name of the service to which the event
　　*
　　message is to be sent.
　　* @param payload
　　The content of the event message
　　* @return Object
　　The result, if any.
　　* @throws EventException on error
　　*/
　　public Object sendSynchronousEvent(String serviceName,
　　Object payload)
　　throws EventException
　　{
　　try
　　{
　　if (!manager.getModel().isComponentRegistered(serviceName))
　　{
　　throw new EventException("Service: " + serviceName
　　+ " is not registered.");
　　}
　　String transformers = null;
　　
　　Map messageProperties = null;
　　UMOMessage result = eventClient.sendDirect(serviceName,
　　transformers,
　　payload,
　　messageProperties);
　　if (result == null)
　　{
　　return