diff --git a/src/KafkaServiceProvider.php b/src/KafkaServiceProvider.php index e9d0a0b..83ba7a6 100644 --- a/src/KafkaServiceProvider.php +++ b/src/KafkaServiceProvider.php @@ -14,41 +14,8 @@ class KafkaServiceProvider extends ServiceProvider */ public function boot() { - $this->publishes([ - __DIR__ . '/../config/kafka.php' => config_path('kafka.php'), - ], 'laravel-kafka-config'); - $this->app['queue']->addConnector('kafka', function () { return new KafkaConnector(); }); } - - /** - * Register the service provider. - * - * @return void - */ - public function register() - { - $this->registerConfig(); - } - - - /** - * Setup the config. - * - * @return void - */ - public function registerConfig() - { - $this->mergeConfigFrom( - __DIR__ . '/../config/queue.php', - 'queue.connections.kafka' - ); - - $this->mergeConfigFrom( - __DIR__ . '/../config/kafka.php', - 'kafka' - ); - } } diff --git a/src/KafkaServiceProviderBK.php b/src/KafkaServiceProviderBK.php index af09fab..ed3264b 100644 --- a/src/KafkaServiceProviderBK.php +++ b/src/KafkaServiceProviderBK.php @@ -16,7 +16,7 @@ use RamiiYoussef\Kafka\Console\ConsumeCommand; use RamiiYoussef\Kafka\Console\RestartCommand; -class ServiceProvider extends BaseServiceProvider implements DeferrableProvider +class KafkaServiceProviderBK extends BaseServiceProvider implements DeferrableProvider { /** * Is sig enabled