diff --git a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/main/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStore.java b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/main/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStore.java index 6fb82f82dfb1a..3b1a91cba732b 100644 --- a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/main/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStore.java +++ b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/main/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStore.java @@ -58,6 +58,13 @@ * .eventHubName("<YOUR_EVENT_HUB_NAME>") * .credential(credential) * .consumerGroup("<YOUR_CONSUMER_GROUP_NAME>") + * .processEvent(eventContext -> { + * System.out.println("Partition id = " + eventContext.getPartitionContext().getPartitionId() + " and " + * + "sequence number of event = " + eventContext.getEventData().getSequenceNumber()); + * }) + * .processError(context -> { + * System.out.println("Error occurred while processing events " + context.getThrowable().getMessage()); + * }) * .buildEventProcessorClient(); * * diff --git a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/samples/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisJavaDocCodeSamples.java b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/samples/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisJavaDocCodeSamples.java index 37497bb0c6407..f914aafd0a91f 100644 --- a/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/samples/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisJavaDocCodeSamples.java +++ b/sdk/eventhubs/azure-messaging-eventhubs-checkpointstore-jedis/src/samples/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisJavaDocCodeSamples.java @@ -41,6 +41,13 @@ public void instantiation() { .eventHubName("") .credential(credential) .consumerGroup("") + .processEvent(eventContext -> { + System.out.println("Partition id = " + eventContext.getPartitionContext().getPartitionId() + " and " + + "sequence number of event = " + eventContext.getEventData().getSequenceNumber()); + }) + .processError(context -> { + System.out.println("Error occurred while processing events " + context.getThrowable().getMessage()); + }) .buildEventProcessorClient(); // END: com.azure.messaging.eventhubs.jedischeckpointstore.instantiation }