Azure / Azure/azure-functions-java-worker

ServiceBus support with partition and duplicate detection

Abierto
#337 1 comentario 0 reacciones 0 asignados Ver en GitHub
area:java-functions New Feature
Lenguaje dominante
Java
Estrellas
103
Forks
74
Merge medio
4 d 8 h
PR fusionados (30 d)
2

Descripción

We try to send messages to ServiceBus using functions binding. Bellow Code worked without partitions. But we are facing issues with partition and duplicate detection.

@ServiceBusQueueOutput
@ServiceBusTopicOutput

Sample code to reproduce this issue

```
@FunctionName("QueueTrigger")
public void run(
@ServiceBusQueueTrigger(name = "inMessage", queueName = "%sbInputQueue%", connection = "sbconnection") Message inMessage,
@ServiceBusTopicOutput(name = "topicMessage", topicName = "fx-demo-topic", subscriptionName = "fx-demo-subscription", connection = "sbconnection") OutputBinding topicMessage,
final ExecutionContext context) {

context.getLogger().info("Queue Msg Received " + inMessage.toString());

topicMessage.setValue(inMessage);

context.getLogger().info("Java Service Bus Listing Queue trigger executed.");
}
}
```
Error message :

System.Private.CoreLib: Exception while executing function: Functions.QueueTrigger. Microsoft.Azure.ServiceBus: Message to a partitioned entity with duplicate detection enabled must have either PartitionKey or MessageId

Guía de contribución

Abrir la guía de contribución

Línea de trabajo

Comience con el binding @ServiceBusTopicOutput en la función QueueTrigger reproducida y la excepción de Service Bus notificada. Siga cómo el worker de Java crea el Message saliente para entidades particionadas con la detección de duplicados habilitada. Se considera terminado cuando la reproducción proporcionada ya no falla y mantiene el comportamiento esperado de particionamiento y detección de duplicados.

Escrito por el modelo de indexación a partir del texto del issue.

Evaluación

Stack tecnológico
azure, java
Área
backend, distributed-systems
Tipo de issue
Error
Dificultad
4/5
Tiempo estimado
3-5 días
Estado de actividad
Estancado
Claridad
Necesita aclaración
Aptitud para principiantes
25/100

Recibe los nuevos issues en tu correo

Un resumen breve de issues de GitHub para principiantes.