|
17 | 17 | */ |
18 | 18 | package sif3.infra.rest.queue; |
19 | 19 |
|
| 20 | +import java.util.ArrayList; |
| 21 | +import java.util.List; |
| 22 | + |
20 | 23 | import javax.ws.rs.core.MediaType; |
21 | 24 |
|
22 | 25 | import org.slf4j.Logger; |
|
32 | 35 | import sif3.common.model.PagingInfo; |
33 | 36 | import sif3.common.model.QueryCriteria; |
34 | 37 | import sif3.common.model.SIFEvent; |
| 38 | +import sif3.common.model.ZoneContextInfo; |
35 | 39 | import sif3.common.model.delayed.DelayedResponseReceipt; |
36 | 40 | import sif3.common.ws.ErrorDetails; |
37 | 41 | import sif3.infra.rest.mapper.InfraDataModelMapper; |
@@ -146,9 +150,14 @@ private void processEvent(EventInfo eventInfo) |
146 | 150 | SIFEvent event = eventConsumer.createEventObject(eventPayload, eventInfo.getEventAction(), eventInfo.getUpdateType()); |
147 | 151 | event.setMetadata(eventInfo.getMetadata()); |
148 | 152 | event.setFingerprint(eventInfo.getFingerprint()); |
| 153 | + |
| 154 | + List<ZoneContextInfo> limitToZoneCtxList = new ArrayList<ZoneContextInfo>(); |
| 155 | + limitToZoneCtxList.add(new ZoneContextInfo(eventInfo.getZone(), eventInfo.getContext())); |
| 156 | + event.setLimitToZoneCtxList(limitToZoneCtxList); |
149 | 157 |
|
150 | 158 | // Send event to actual event consumer. |
151 | | - eventConsumer.onEvent(event, eventInfo.getZone(), eventInfo.getContext(), eventInfo.getEventMetadata(), eventInfo.getMessageQueueReaderID(), consumerID); |
| 159 | +// eventConsumer.onEvent(event, eventInfo.getZone(), eventInfo.getContext(), eventInfo.getEventMetadata(), eventInfo.getMessageQueueReaderID(), consumerID); |
| 160 | + eventConsumer.onEvent(event, eventInfo.getEventMetadata(), eventInfo.getMessageQueueReaderID(), consumerID); |
152 | 161 | } |
153 | 162 | } |
154 | 163 |
|
|
0 commit comments