diff --git a/src/Facades/Kafka.php b/src/Facades/Kafka.php index cdfb253d..9a3a69e2 100644 --- a/src/Facades/Kafka.php +++ b/src/Facades/Kafka.php @@ -15,9 +15,9 @@ * @method static void assertPublishedOnTimes(string $topic, int $times = 1, ProducerMessage $expectedMessage = null, callable $callback = null) * @method static void assertNothingPublished() * @method static void shouldReceiveMessages(\Junges\Kafka\Contracts\ConsumerMessage|\Junges\Kafka\Contracts\ConsumerMessage[] $messages) - * @mixin \Junges\Kafka\Kafka + * @mixin \Junges\Kafka\Factory * - * @see \Junges\Kafka\Kafka + * @see \Junges\Kafka\Factory */ class Kafka extends Facade { @@ -31,6 +31,6 @@ public static function fake(): KafkaFake public static function getFacadeAccessor(): string { - return \Junges\Kafka\Kafka::class; + return \Junges\Kafka\Factory::class; } } diff --git a/src/Kafka.php b/src/Factory.php similarity index 96% rename from src/Kafka.php rename to src/Factory.php index 6d25c34d..d0840292 100644 --- a/src/Kafka.php +++ b/src/Factory.php @@ -8,7 +8,7 @@ use Junges\Kafka\Contracts\MessageProducer; use Junges\Kafka\Producers\ProducerBuilder; -class Kafka implements KafkaManager +class Factory implements KafkaManager { use Macroable; diff --git a/src/Providers/LaravelKafkaServiceProvider.php b/src/Providers/LaravelKafkaServiceProvider.php index ac2eb92f..adab06bb 100644 --- a/src/Providers/LaravelKafkaServiceProvider.php +++ b/src/Providers/LaravelKafkaServiceProvider.php @@ -13,7 +13,7 @@ use Junges\Kafka\Contracts\MessagePublisher; use Junges\Kafka\Contracts\MessageSerializer; use Junges\Kafka\Contracts\ProducerMessage; -use Junges\Kafka\Kafka; +use Junges\Kafka\Factory; use Junges\Kafka\Logger; use Junges\Kafka\Message\ConsumedMessage; use Junges\Kafka\Message\Deserializers\JsonDeserializer; @@ -44,11 +44,11 @@ public function register() $this->app->bind(ConsumerMessage::class, ConsumedMessage::class); - $this->app->bind(MessagePublisher::class, Kafka::class); + $this->app->bind(MessagePublisher::class, Factory::class); - $this->app->bind(ConsumeMessagesFromKafka::class, Kafka::class); + $this->app->bind(ConsumeMessagesFromKafka::class, Factory::class); - $this->app->bind(KafkaManager::class, Kafka::class); + $this->app->bind(KafkaManager::class, Factory::class); $this->app->singleton(LoggerContract::class, Logger::class); }