src/PubSubServiceProvider.php
protected function registerAdapterDependencies()
    {
        $this->app->bind('pubsub.redis.redis_client', function ($app, $parameters) {
            return new RedisClient($parameters['config']);
        });

        $this->app->bind('pubsub.gcloud.pub_sub_client', function ($app, $parameters) {
            return new GoogleCloudPubSubClient($parameters['config']);
        });

        $this->app->bind('pubsub.kafka.topic_conf', function () {
            return new \RdKafka\TopicConf();
        });

        $this->app->bind('pubsub.kafka.producer', function () {
            return new \RdKafka\Producer();
        });

        $this->app->bind('pubsub.kafka.conf', function () {
            return new \RdKafka\Conf();
        });

        $this->app->bind('pubsub.kafka.consumer', function ($app, $parameters) {
            return new \RdKafka\KafkaConsumer($parameters['conf']);
        });

        $this->app->bind('pubsub.http.client', function () {
            return new Client();
        });
    }
protected function registerAdapterDependencies()
    {
        $this->app->bind('pubsub.redis.redis_client', function ($app, $parameters) {
            return new RedisClient($parameters['config']);
        });

        $this->app->bind('pubsub.gcloud.pub_sub_client', function ($app, $parameters) {
            return new GoogleCloudPubSubClient($parameters['config']);
        });

        $this->app->bind('pubsub.kafka.topic_conf', function () {
            return new \RdKafka\TopicConf();
        });

        $this->app->bind('pubsub.kafka.producer', function () {
            return new \RdKafka\Producer();
        });

        $this->app->bind('pubsub.kafka.conf', function () {
            return new \RdKafka\Conf();
        });

        $this->app->bind('pubsub.kafka.consumer', function ($app, $parameters) {
            return new \RdKafka\KafkaConsumer($parameters['conf']);
        });

        $this->app->bind('pubsub.http.client', function () {
            return new Client();
        });
    }
protected function registerAdapterDependencies ( ) { $ this -> app -> bind ( 'pubsub.redis.redis_client' , function ( $ app , $ parameters ) { return new RedisClient ( $ parameters [ 'config' ] ) ; } ) ; $ this -> app -> bind ( 'pubsub.gcloud.pub_sub_client' , function ( $ app , $ parameters ) { return new GoogleCloudPubSubClient ( $ parameters [ 'config' ] ) ; } ) ; $ this -> app -> bind ( 'pubsub.kafka.topic_conf' , function ( ) { return new \ RdKafka \ TopicConf ( ) ; } ) ; $ this -> app -> bind ( 'pubsub.kafka.producer' , function ( ) { return new \ RdKafka \ Producer ( ) ; } ) ; $ this -> app -> bind ( 'pubsub.kafka.conf' , function ( ) { return new \ RdKafka \ Conf ( ) ; } ) ; $ this -> app -> bind ( 'pubsub.kafka.consumer' , function ( $ app , $ parameters ) { return new \ RdKafka \ KafkaConsumer ( $ parameters [ 'conf' ] ) ; } ) ; $ this -> app -> bind ( 'pubsub.http.client' , function ( ) { return new Client ( ) ; } ) ; }
Register adapter dependencies in the container.
Register adapter dependencies in the container .