diff --git a/core/src/main/java/io/temporal/samples/nexus/caller/CallerStarter.java b/core/src/main/java/io/temporal/samples/nexus/caller/CallerStarter.java
index 23dd0f5e..5c17b2fd 100644
--- a/core/src/main/java/io/temporal/samples/nexus/caller/CallerStarter.java
+++ b/core/src/main/java/io/temporal/samples/nexus/caller/CallerStarter.java
@@ -16,7 +16,7 @@
  *  express or implied. See the License for the specific language governing
  *  permissions and limitations under the License.
  */
-
+// @@@SNIPSTART samples-java-nexus-caller-starter
 package io.temporal.samples.nexus.caller;
 
 import io.temporal.client.WorkflowClient;
@@ -51,3 +51,4 @@ public static void main(String[] args) {
         WorkflowStub.fromTyped(helloWorkflow).getExecution().getRunId());
   }
 }
+// @@@SNIPEND
\ No newline at end of file
diff --git a/core/src/main/java/io/temporal/samples/nexus/caller/CallerWorker.java b/core/src/main/java/io/temporal/samples/nexus/caller/CallerWorker.java
index e7be0ae4..2d9ad92c 100644
--- a/core/src/main/java/io/temporal/samples/nexus/caller/CallerWorker.java
+++ b/core/src/main/java/io/temporal/samples/nexus/caller/CallerWorker.java
@@ -16,7 +16,7 @@
  *  express or implied. See the License for the specific language governing
  *  permissions and limitations under the License.
  */
-
+// @@@SNIPSTART samples-java-nexus-caller-worker
 package io.temporal.samples.nexus.caller;
 
 import io.temporal.client.WorkflowClient;
@@ -49,3 +49,4 @@ public static void main(String[] args) {
     factory.start();
   }
 }
+// @@@SNIPEND
\ No newline at end of file
diff --git a/core/src/main/java/io/temporal/samples/nexus/handler/HandlerWorker.java b/core/src/main/java/io/temporal/samples/nexus/handler/HandlerWorker.java
index 71a78f91..efe7b892 100644
--- a/core/src/main/java/io/temporal/samples/nexus/handler/HandlerWorker.java
+++ b/core/src/main/java/io/temporal/samples/nexus/handler/HandlerWorker.java
@@ -16,7 +16,7 @@
  *  express or implied. See the License for the specific language governing
  *  permissions and limitations under the License.
  */
-
+// @@@SNIPSTART samples-java-nexus-handler-worker
 package io.temporal.samples.nexus.handler;
 
 import io.temporal.client.WorkflowClient;
@@ -39,3 +39,4 @@ public static void main(String[] args) {
     factory.start();
   }
 }
+// @@@SNIPEND
diff --git a/core/src/main/java/io/temporal/samples/nexus/handler/NexusServiceImpl.java b/core/src/main/java/io/temporal/samples/nexus/handler/NexusServiceImpl.java
index 4d6cb3ca..95b3836c 100644
--- a/core/src/main/java/io/temporal/samples/nexus/handler/NexusServiceImpl.java
+++ b/core/src/main/java/io/temporal/samples/nexus/handler/NexusServiceImpl.java
@@ -26,6 +26,7 @@
 import io.temporal.nexus.WorkflowClientOperationHandlers;
 import io.temporal.samples.nexus.service.NexusService;
 
+// @@@SNIPSTART samples-java-nexus-handler
 // To create a service implementation, annotate the class with @ServiceImpl and provide the
 // interface that the service implements. The service implementation class should have methods that
 // return OperationHandler that correspond to the operations defined in the service interface.
@@ -63,3 +64,4 @@ public OperationHandler<NexusService.HelloInput, NexusService.HelloOutput> hello
                 ::hello);
   }
 }
+// @@@SNIPEND
diff --git a/core/src/main/java/io/temporal/samples/nexus/options/ClientOptions.java b/core/src/main/java/io/temporal/samples/nexus/options/ClientOptions.java
index 49d0dde2..6ebe9e73 100644
--- a/core/src/main/java/io/temporal/samples/nexus/options/ClientOptions.java
+++ b/core/src/main/java/io/temporal/samples/nexus/options/ClientOptions.java
@@ -16,7 +16,7 @@
  *  express or implied. See the License for the specific language governing
  *  permissions and limitations under the License.
  */
-
+// @@@SNIPSTART samples-java-nexus-cli
 package io.temporal.samples.nexus.options;
 
 import io.grpc.netty.shaded.io.netty.handler.ssl.SslContextBuilder;
@@ -25,11 +25,12 @@
 import io.temporal.client.WorkflowClientOptions;
 import io.temporal.serviceclient.WorkflowServiceStubs;
 import io.temporal.serviceclient.WorkflowServiceStubsOptions;
+import org.apache.commons.cli.*;
+
+import javax.net.ssl.SSLException;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 import java.util.Arrays;
-import javax.net.ssl.SSLException;
-import org.apache.commons.cli.*;
 
 public class ClientOptions {
   public static WorkflowClient getWorkflowClient(String[] args) {
@@ -123,3 +124,4 @@ public static WorkflowClient getWorkflowClient(String[] args) {
         service, WorkflowClientOptions.newBuilder().setNamespace(namespace).build());
   }
 }
+// @@@SNIPEND
\ No newline at end of file
diff --git a/core/src/main/java/io/temporal/samples/nexus/service/NexusService.java b/core/src/main/java/io/temporal/samples/nexus/service/NexusService.java
index e12dcbe9..3ca90da0 100644
--- a/core/src/main/java/io/temporal/samples/nexus/service/NexusService.java
+++ b/core/src/main/java/io/temporal/samples/nexus/service/NexusService.java
@@ -24,6 +24,7 @@
 import io.nexusrpc.Operation;
 import io.nexusrpc.Service;
 
+// @@@SNIPSTART samples-java-nexus-service
 @Service
 public interface NexusService {
   enum Language {
@@ -104,3 +105,4 @@ public String getMessage() {
   @Operation
   EchoOutput echo(EchoInput input);
 }
+// @@@SNIPEND