Cherry pick branch 'genexuslabs:AzureFunctions' into beta

Author: sjuarez

gxazureserverless/src/main/java/com/genexus/cloud/serverless/azure/handler/AzureServiceBusQueueHandler.java

@@ -21,7 +21,7 @@ public void run(
 		context.getLogger().info("GeneXus Service Bus Queue trigger handler. Function processed: " + context.getFunctionName() + " Invocation Id: " + context.getInvocationId());
 		setupServerlessMappings(context.getFunctionName());
 		ServiceBusBatchMessageProcessor queueBatchMessageProcessor = new ServiceBusBatchMessageProcessor();
-		ServiceBusProcessedMessage queueMessage = queueBatchMessageProcessor.processQueueMessage(executor,messages);
+		ServiceBusProcessedMessage queueMessage = queueBatchMessageProcessor.processQueueMessage(context, executor, messages);
 		try {
 			EventMessageResponse response = dispatchEvent(queueMessage.getEventMessages(),queueMessage.getRawMessage());
 			if (response.hasFailed()) {

gxazureserverless/src/main/java/com/genexus/cloud/serverless/azure/handler/AzureServiceBusTopicHandler.java

@@ -21,7 +21,7 @@ public void run(
 		context.getLogger().info("GeneXus Service Bus Topic trigger handler. Function processed: " + context.getFunctionName() + " Invocation Id: " + context.getInvocationId());
 		setupServerlessMappings(context.getFunctionName());
 		ServiceBusBatchMessageProcessor queueBatchMessageProcessor = new ServiceBusBatchMessageProcessor();
-		ServiceBusProcessedMessage queueMessage = queueBatchMessageProcessor.processQueueMessage(executor,messages);
+		ServiceBusProcessedMessage queueMessage = queueBatchMessageProcessor.processQueueMessage(context, executor, messages);
 		try {
 			EventMessageResponse response = dispatchEvent(queueMessage.getEventMessages(), queueMessage.getRawMessage());
 			if (response.hasFailed()) {

gxazureserverless/src/main/java/com/genexus/cloud/serverless/helpers/ServiceBusBatchMessageProcessor.java

@@ -4,18 +4,23 @@
 import com.genexus.cloud.serverless.JSONHelper;
 import com.genexus.cloud.serverless.model.EventMessage;
 import com.genexus.cloud.serverless.model.EventMessages;
+import com.microsoft.azure.functions.ExecutionContext;
 import com.sun.jna.platform.win32.Guid;
 
+import java.time.Instant;
+import java.util.Date;
+
 public class ServiceBusBatchMessageProcessor {
-	public ServiceBusProcessedMessage processQueueMessage(GXProcedureExecutor executor, String[] messages) {
+	public ServiceBusProcessedMessage processQueueMessage(ExecutionContext context, GXProcedureExecutor executor, String[] messages) {
 		String rawMessage = "";
 		EventMessages eventMessages = new EventMessages();
 		switch (executor.getMethodSignatureIdx()) {
 			case 0: {
 				for(String message : messages)
 				{
 					EventMessage msg = new EventMessage();
-					msg.setMessageId(Guid.GUID.newGuid().toString()); // This is a fake Id.
+					msg.setMessageId(context.getInvocationId()); // This is a fake Id.
+					msg.setMessageDate(Date.from(Instant.now())); //This is the time of processing not the enqueued time. Until now, this metadata is not available.
 					msg.setMessageData(message);
 					eventMessages.add(msg);
 				}