Closed vrdmr closed 4 years ago
Solves https://github.com/Azure/azure-functions-java-worker/issues/355.
String Example:
public class Function { @FunctionName("EventGridTriggerTest") public void run(@EventGridTrigger(name = "event") String content, @EventGridOutput(name = "outputEvent", topicEndpointUri = "MyEventGridTopicUriSetting", topicKeySetting = "MyEventGridTopicKeySetting") OutputBinding<String> outputEvent, final ExecutionContext context) { context.getLogger().info("Java EventGrid trigger processed a request." + content); final String eventGridOutputDocument = "{\"id\": \"1807\", \"eventType\": \"recordInserted\", \"subject\": \"myapp/cars/java\", \"eventTime\":\"2017-08-10T21:03:07+00:00\", \"data\": {\"make\": \"Ducati\",\"model\": \"Monster\"}, \"dataVersion\": \"1.0\"}"; outputEvent.setValue(eventGridOutputDocument); } }
POJO Example:
public class Function { @FunctionName("EventGridTriggerTest") public void run(@EventGridTrigger(name = "event") String content, @EventGridOutput(name = "outputEvent", topicEndpointUri = "MyEventGridTopicUriSetting", topicKeySetting = "MyEventGridTopicKeySetting") OutputBinding<EventGridEvent> outputEvent, final ExecutionContext context) { context.getLogger().info("Java EventGrid trigger processed a request." + content); final EventGridEvent eventGridOutputDocument = new EventGridEvent(); eventGridOutputDocument.setId("1807"); eventGridOutputDocument.setEventType("recordInserted"); eventGridOutputDocument.setEventTime("2017-08-10T21:03:07+00:00"); eventGridOutputDocument.setDataVersion("1.0"); eventGridOutputDocument.setSubject("myapp/cars/java"); eventGridOutputDocument.setData("{\"make\": \"Ducati\",\"model\":\"monster\""); outputEvent.setValue(eventGridOutputDocument); } } class EventGridEvent { private String id; private String eventType; private String subject; private String eventTime; private String dataVersion; private String data; public String getId() { return id; } public String getData() { return data; } public void setData(String data) { this.data = data; } public String getDataVersion() { return dataVersion; } public void setDataVersion(String dataVersion) { this.dataVersion = dataVersion; } public String getEventTime() { return eventTime; } public void setEventTime(String eventTime) { this.eventTime = eventTime; } public String getSubject() { return subject; } public void setSubject(String subject) { this.subject = subject; } public String getEventType() { return eventType; } public void setEventType(String eventType) { this.eventType = eventType; } public void setId(String id) { this.id = id; } }
Solves https://github.com/Azure/azure-functions-java-worker/issues/355.
String Example:
POJO Example: