Fix Azure Redis Checkpoint Store Samples Issue (#41511)

* Fixed issue#40921 * Standard format * fix ci issue
Azure · Oct 1, 2024 · e083a77 · e083a77
1 parent fd60255
commit e083a77
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/...c/main/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStore.java b/...c/main/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisCheckpointStore.java
@@ -58,6 +58,13 @@
  *     .eventHubName&#40;&quot;&lt;YOUR_EVENT_HUB_NAME&gt;&quot;&#41;
  *     .credential&#40;credential&#41;
  *     .consumerGroup&#40;&quot;&lt;YOUR_CONSUMER_GROUP_NAME&gt;&quot;&#41;
+ *     .processEvent&#40;eventContext -&gt; &#123;
+ *         System.out.println&#40;&quot;Partition id = &quot; + eventContext.getPartitionContext&#40;&#41;.getPartitionId&#40;&#41; + &quot; and &quot;
+ *             + &quot;sequence number of event = &quot; + eventContext.getEventData&#40;&#41;.getSequenceNumber&#40;&#41;&#41;;
+ *     &#125;&#41;
+ *     .processError&#40;context -&gt; &#123;
+ *         System.out.println&#40;&quot;Error occurred while processing events &quot; + context.getThrowable&#40;&#41;.getMessage&#40;&#41;&#41;;
+ *     &#125;&#41;
  *     .buildEventProcessorClient&#40;&#41;;
  * </pre>
  * <!-- end com.azure.messaging.eventhubs.jedischeckpointstore.instantiation -->

diff --git a/...les/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisJavaDocCodeSamples.java b/...les/java/com/azure/messaging/eventhubs/checkpointstore/jedis/JedisJavaDocCodeSamples.java
@@ -41,6 +41,13 @@ public void instantiation() {
             .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();
         // END: com.azure.messaging.eventhubs.jedischeckpointstore.instantiation
     }