fmt

examples/test_sse_events.rs

@@ -10,6 +10,10 @@ struct TestActivity;
 
 #[async_trait]
 impl ActivityHandler for TestActivity {
+    fn activity_type(&self) -> String {
+        "test_activity".to_string()
+    }
+
     async fn handle(
         &self,
         payload: serde_json::Value,
@@ -20,10 +24,6 @@ impl ActivityHandler for TestActivity {
         println!("✅ Completed test activity");
         Ok(Some(serde_json::json!({"status": "completed"})))
     }
-
-    fn activity_type(&self) -> String {
-        "test_activity".to_string()
-    }
 }
 
 /// Example to test SSE event emission

src/activity/activity.rs

@@ -344,6 +344,12 @@ pub type ActivityHandlerResult<T = Option<serde_json::Value>> = Result<T, Activi
 /// ```
 #[async_trait]
 pub trait ActivityHandler: Send + Sync {
+    /// Return the activity type string that this handler processes.
+    ///
+    /// This string is used to match activities with their handlers when they are
+    /// registered with the worker engine. It should be unique and descriptive.
+    fn activity_type(&self) -> String;
+
     /// Process the activity with the given payload and context.
     ///
     /// This method is called by the worker engine to execute the activity.
@@ -367,12 +373,6 @@ pub trait ActivityHandler: Send + Sync {
         context: ActivityContext,
     ) -> ActivityHandlerResult;
 
-    /// Return the activity type string that this handler processes.
-    ///
-    /// This string is used to match activities with their handlers when they are
-    /// registered with the worker engine. It should be unique and descriptive.
-    fn activity_type(&self) -> String;
-
     /// Called once when an activity enters the dead letter state.
     ///
     /// This callback is triggered when an activity has exhausted all retry attempts