in agent/service/src/main/java/org/apache/airavata/mft/agent/MFTAgent.java [57:68]
private void handleCallbacks(List<CallbackEndpoint> callbackEndpoints, String transferId, TransferState transferState) {
if (callbackEndpoints != null && !callbackEndpoints.isEmpty()) {
for (CallbackEndpoint cbe : callbackEndpoints) {
switch (cbe.getType()) {
case HTTP:
break;
case KAFKA:
break;
}
}
}
}