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);
}
}
|