From 0dd30902befcc88b674da8d040e035aaf3a6448f Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Mon, 4 Mar 2024 14:32:14 +0100 Subject: [PATCH] refactor: Refined channel-states, introduced `ChannelState` -- MOVE * Renamed and moved `LoadInProgressException` ** Moved exception into implementation-specific package ** Renamed exception to `ChannelNotReadyException` * Renamed `ConsumerTaskExecutor` into `ChannelTaskExecutor` * Renamed `ConsumerTaskRunner` into `ChannelTaskRunner` --- .../kafka/ChannelNotReadyException.java} | 0 .../kafka/{ConsumerTaskExecutor.java => ChannelTaskExecutor.java} | 0 .../kafka/{ConsumerTaskRunner.java => ChannelTaskRunner.java} | 0 3 files changed, 0 insertions(+), 0 deletions(-) rename src/main/java/de/juplo/kafka/chat/backend/{domain/exceptions/LoadInProgressException.java => implementation/kafka/ChannelNotReadyException.java} (100%) rename src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/{ConsumerTaskExecutor.java => ChannelTaskExecutor.java} (100%) rename src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/{ConsumerTaskRunner.java => ChannelTaskRunner.java} (100%) diff --git a/src/main/java/de/juplo/kafka/chat/backend/domain/exceptions/LoadInProgressException.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelNotReadyException.java similarity index 100% rename from src/main/java/de/juplo/kafka/chat/backend/domain/exceptions/LoadInProgressException.java rename to src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelNotReadyException.java diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskExecutor.java similarity index 100% rename from src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskExecutor.java rename to src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskExecutor.java diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskRunner.java similarity index 100% rename from src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ConsumerTaskRunner.java rename to src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/ChannelTaskRunner.java -- 2.20.1