Skip to content

Commit 5ab8af1

Browse files
author
Joerg Huber
committed
Apply changed to adhere to new EventConsumer<L> Interface.
1 parent 32ee2b8 commit 5ab8af1

2 files changed

Lines changed: 13 additions & 3 deletions

File tree

SIF3InfraREST/SIF3Demo/sif3-demo-web/src/main/java/systemic/sif3/demo/rest/consumer/AUDataModelEventConsumer.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -85,12 +85,17 @@ public AUDataModelEventConsumer()
8585
* @see sif3.common.interfaces.EventConsumer#onEvent(sif3.common.model.SIFEvent, sif3.common.model.SIFZone, sif3.common.model.SIFContext, java.lang.String)
8686
*/
8787
@Override
88-
public void processEvent(SIFEvent<L> sifEvent, SIFZone zone, SIFContext context, EventMetadata metadata, String msgReadID, String consumerID)
88+
// public void processEvent(SIFEvent<L> sifEvent, SIFZone zone, SIFContext context, EventMetadata metadata, String msgReadID, String consumerID)
89+
public void processEvent(SIFEvent<L> sifEvent, EventMetadata metadata, String msgReadID, String consumerID)
8990
{
9091
String consumerName = getPrettyName()+"(QueueID:"+msgReadID+"; ConsumerID: "+consumerID+")";
9192

9293
// We know from the framework that zone and context is never null. For the time being we just log the event.
93-
logger.debug(consumerName +" received an event from Zone = "+zone.getId()+", Context = "+context.getId()+" and Event Metadata = "+metadata);
94+
SIFZone zone = sifEvent.getLimitToZoneCtxList().get(0).getZone();
95+
SIFContext context = sifEvent.getLimitToZoneCtxList().get(0).getContext();
96+
97+
// logger.debug(consumerName +" received an event from Zone = "+zone.getId()+", Context = "+context.getId()+" and Event Metadata = "+metadata);
98+
logger.debug(consumerName +" received an event from Zone = "+zone+", Context = "+context+" and Event Metadata = "+metadata);
9499
dumpObject(sifEvent, zone, context, msgReadID, consumerID);
95100

96101
// Pretend to be busy for a long time to test threading

SIF3InfraREST/SIF3Demo/sif3-demo-web/src/main/java/systemic/sif3/demo/rest/consumer/CSVStudentConsumer.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -181,10 +181,15 @@ public SIFEvent<String> createEventObject(Object sifObjectList, EventAction even
181181
* @see sif3.infra.rest.consumer.AbstractEventConsumer#processEvent(sif3.common.model.SIFEvent, sif3.common.model.SIFZone, sif3.common.model.SIFContext, sif3.common.model.EventMetadata, java.lang.String, java.lang.String)
182182
*/
183183
@Override
184-
public void processEvent(SIFEvent<String> sifEvent, SIFZone zone, SIFContext context, EventMetadata metadata, String msgReadID, String consumerID)
184+
// public void processEvent(SIFEvent<L> sifEvent, SIFZone zone, SIFContext context, EventMetadata metadata, String msgReadID, String consumerID)
185+
public void processEvent(SIFEvent<String> sifEvent, EventMetadata metadata, String msgReadID, String consumerID)
185186
{
186187
// We know from the framework that zone and context is never null. For the time being we just log the event.
187188
String timestamp = DateUtils.getISO8601withSecFraction(new Date());
189+
SIFZone zone = sifEvent.getLimitToZoneCtxList().get(0).getZone();
190+
SIFContext context = sifEvent.getLimitToZoneCtxList().get(0).getContext();
191+
188192
logger.debug(RECORD_MARKER+"Record processed by Thread ID = "+Thread.currentThread().getId()+"\n"+sifEvent.getEventAction().name()+" Events from Queue Reader "+ msgReadID+"\nReceived at "+timestamp+" from Zone = "+zone.getId()+" and Context = "+context.getId()+"\nData:\n"+sifEvent.getSIFObjectList()+RECORD_MARKER);
189193
}
194+
190195
}

0 commit comments

Comments
 (0)