Add execution ID for new example

Signed-off-by: vtiwari5 <[email protected]>

Author: vtiwari5

examples/pom.xml

@@ -381,6 +381,28 @@
                             </to>
                         </configuration>
                     </execution>
+                    <execution>
+                        <id>on-success-sink</id>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>dockerBuild</goal>
+                        </goals>
+                        <configuration>
+                            <from>
+                                <image>amazoncorretto:11</image>
+                            </from>
+                            <container>
+                                <mainClass>
+                                    io.numaproj.numaflow.examples.sink.onsuccess.OnSuccess
+                                </mainClass>
+                            </container>
+                            <to>
+                                <image>
+                                    numaflow-java-examples/on-success-sink:${docker.tag}
+                                </image>
+                            </to>
+                        </configuration>
+                    </execution>
                 </executions>
             </plugin>
         </plugins>

examples/src/main/java/io/numaproj/numaflow/examples/sink/onsuccess/OnSuccess.java

@@ -55,6 +55,11 @@ public ResponseList processMessages(DatumIterator datumIterator) {
         return responseListBuilder.build();
     }
 
+    /**
+     * Example method to simulate write failures/success to primary sink.
+     * Based on whether this returns true/false, we write to fallback sink / onSuccess sink
+     * @return
+     */
     public boolean writeToPrimarySink() {
         Random random = new Random();
         return random.nextBoolean();