Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
titleMuleIntegrationKernel.java
borderStylesolid
package org.openregistry.integration.internal;

import org.mule.module.client.MuleClient;
import org.openregistry.integration.IntegrationKernel;

public class MuleIntegrationKernel implements IntegrationKernel {

        @Autowired
        private MuleClient mule;

	public void processAndDispatchToDownstreamSystems(Object identityDataPayload) throws IntegrationFlowException {
       

            //The name of the endpoint to dispatch to could be configured of course
            this.mule.dispatch("oir-inbound-endpoint", identityDataPayload, null);
       }
 
        



	void dispatchToDownstreamSystems(Object identityDataPayload) throws IntegrationFlowException {

             //The name of the endpoint to dispatch to could be configured of course
            this.mule.dispatch("downstream-inbound-endpoint", identityDataPayload, null);
       }
	
       void dispatchToPeerSystems(Object identityDataPayload) throws IntegrationFlowException {
       

            //The name of the endpoint to dispatch to could be configured of course
           this.mule.dispatch("peer-inbound-endpoint", identityDataPayload, null);
       }
}