Skip to content

Commit 895a2ba

Browse files
author
Joerg Huber
committed
Fixed issue where payload was not set for XQUERYTEMPLATE.
1 parent c7f8fca commit 895a2ba

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

SIF3InfraREST/SIF3REST/src/main/java/sif3/infra/rest/queue/LocalMessageConsumer.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@
3636
import sif3.common.model.PagingInfo;
3737
import sif3.common.model.QueryCriteria;
3838
import sif3.common.model.SIFEvent;
39+
import sif3.common.model.StringPayload;
3940
import sif3.common.model.ZoneContextInfo;
4041
import sif3.common.model.delayed.DelayedResponseReceipt;
4142
import sif3.common.model.job.PhaseInfo;
@@ -44,6 +45,7 @@
4445
import sif3.infra.common.conversion.InfraUnmarshalFactory;
4546
import sif3.infra.common.model.JobCollectionType;
4647
import sif3.infra.rest.consumer.AbstractFunctionalServiceConsumer;
48+
import sif3.infra.rest.consumer.AbstractNamedQueryConsumer;
4749
import sif3.infra.rest.mapper.InfraDataModelMapper;
4850
import sif3.infra.rest.queue.types.DelayedBaseInfo;
4951
import sif3.infra.rest.queue.types.ErrorInfo;
@@ -353,7 +355,9 @@ private void processResponse(ResponseInfo responseInfo)
353355
}
354356
case XQUERYTEMPLATE:
355357
{
356-
delayedConsumer.onQuery(payloadObject, paging, delayedReceipt);
358+
AbstractNamedQueryConsumer nqc = (AbstractNamedQueryConsumer)minimalConsumer;
359+
nqc.processDelayedNamedQuery(new StringPayload(responseInfo.getPayload(), responseInfo.getMediaType()), paging, delayedReceipt);
360+
357361
break;
358362
}
359363
case FUNCTIONAL:

0 commit comments

Comments
 (0)