honeymoose/hapi-fhir
1
0
Fork 0
mirror of https://github.com/hapifhir/hapi-fhir.git synced 2025-02-07 05:28:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

Rename queue to channel

Browse Source
This commit is contained in:
Tadgh 2020-08-01 13:12:32 -07:00
parent 2cf48eb9b9
commit 46251af81a
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hapi-fhir-jpaserver-empi/src/main/java/ca/uhn/fhir/jpa/empi/svc/EmpiBatchSvcImpl.java
View File

@ -55,7 +55,7 @@ public class EmpiBatchSvcImpl implements IEmpiBatchSvc {
private EmpiSearchParamSvc myEmpiSearchParamSvc;
@Autowired
private IEmpiChannelSubmitterSvc myEmpiQueueSubmitterSvc;
private IEmpiChannelSubmitterSvc myEmpiChannelSubmitterSvc;
private static final int BUFFER_SIZE = 100;
@ -121,7 +121,7 @@ public class EmpiBatchSvcImpl implements IEmpiBatchSvc {
List<IBaseResource> resourcesToSubmit = new ArrayList<>();
theSearchBuilder.loadResourcesByPid(thePidsToSubmit, Collections.emptyList(), resourcesToSubmit, false, null);
resourcesToSubmit
.forEach(resource -> myEmpiQueueSubmitterSvc.submitResourceToEmpiChannel(resource));
.forEach(resource -> myEmpiChannelSubmitterSvc.submitResourceToEmpiChannel(resource));
return resourcesToSubmit.size();
}
@ -143,7 +143,7 @@ public class EmpiBatchSvcImpl implements IEmpiBatchSvc {
resolveTargetTypeOrThrowException(theId.getResourceType());
IFhirResourceDao resourceDao = myDaoRegistry.getResourceDao(theId.getResourceType());
IBaseResource read = resourceDao.read(theId);
myEmpiQueueSubmitterSvc.submitResourceToEmpiChannel(read);
myEmpiChannelSubmitterSvc.submitResourceToEmpiChannel(read);
return 1;
}

2
hapi-fhir-jpaserver-empi/src/main/java/ca/uhn/fhir/jpa/empi/svc/EmpiChannelSubmitterSvcImpl.java
View File

@ -34,7 +34,7 @@ import org.springframework.messaging.MessageChannel;
import static ca.uhn.fhir.empi.api.IEmpiSettings.EMPI_CHANNEL_NAME;
/**
* This class is responsible for manual submissions of {@link IAnyResource} resources onto the Empi Queue.
* This class is responsible for manual submissions of {@link IAnyResource} resources onto the Empi Channel.
*/
public class EmpiChannelSubmitterSvcImpl implements IEmpiChannelSubmitterSvc {
private MessageChannel myEmpiChannelProducer;