From 36239d251361a0db7c56c41adf4e1d6841674f8c Mon Sep 17 00:00:00 2001
From: John Fallows <john@aklivity.io>
Date: Thu, 27 Jun 2024 14:33:02 -0700
Subject: [PATCH] Refactor signaler class name (#1111)

---
 .../runtime/engine/internal/registry/EngineWorker.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/runtime/engine/src/main/java/io/aklivity/zilla/runtime/engine/internal/registry/EngineWorker.java b/runtime/engine/src/main/java/io/aklivity/zilla/runtime/engine/internal/registry/EngineWorker.java
index 569778d597..c74bd9cd33 100644
--- a/runtime/engine/src/main/java/io/aklivity/zilla/runtime/engine/internal/registry/EngineWorker.java
+++ b/runtime/engine/src/main/java/io/aklivity/zilla/runtime/engine/internal/registry/EngineWorker.java
@@ -206,7 +206,7 @@ public class EngineWorker implements EngineContext, Agent
     private final DeadlineTimerWheel timerWheel;
     private final Long2ObjectHashMap<Runnable> tasksByTimerId;
     private final Long2ObjectHashMap<Future<?>> futuresById;
-    private final ElektronSignaler signaler;
+    private final EngineSignaler signaler;
     private final Long2ObjectHashMap<MessageConsumer> correlations;
     private final Long2ObjectHashMap<AgentRunner> exportersById;
     private final Map<String, ModelContext> modelsByType;
@@ -339,7 +339,7 @@ public EngineWorker(
         this.timerWheel = new DeadlineTimerWheel(MILLISECONDS, currentTimeMillis(), 512, 1024);
         this.tasksByTimerId = new Long2ObjectHashMap<>();
         this.futuresById = new Long2ObjectHashMap<>();
-        this.signaler = new ElektronSignaler(executor, Math.max(config.bufferSlotCapacity(), 512));
+        this.signaler = new EngineSignaler(executor, Math.max(config.bufferSlotCapacity(), 512));
 
         this.poller = new Poller();
 
@@ -1902,7 +1902,7 @@ private Int2ObjectHashMap<MessageConsumer>[] initDispatcher()
         return dispatcher;
     }
 
-    private final class ElektronSignaler implements Signaler
+    private final class EngineSignaler implements Signaler
     {
         private final ThreadLocal<SignalFW.Builder> signalRW;
 
@@ -1910,7 +1910,7 @@ private final class ElektronSignaler implements Signaler
 
         private long nextFutureId;
 
-        private ElektronSignaler(
+        private EngineSignaler(
             ExecutorService executorService,
             int slotCapacity)
         {