rename default queue

RasaHQ · Mar 16, 2020 · 26ae27c · 26ae27c
1 parent 280c4af
commit 26ae27c
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 8 deletions.
diff --git a/docs/api/event-brokers.rst b/docs/api/event-brokers.rst
@@ -73,7 +73,7 @@ Here is how you add it using Python code:
     pika_broker = PikaEventBroker('localhost',
                                   'username',
                                   'password',
-                                  queues=['rasa_core_events'])
+                                  queues=['rasa_events'])
 
     tracker_store = InMemoryTrackerStore(db=db, event_broker=pika_broker)
 
@@ -110,7 +110,7 @@ example:
         # start consumption of channel
         channel = connection.channel()
         channel.basic_consume(_callback,
-                              queue='rasa_core_events',
+                              queue='rasa_events',
                               no_ack=True)
         channel.start_consuming()
 
@@ -164,7 +164,7 @@ The code below shows an example on how to instantiate a Kafka producer in you sc
     from rasa.core.tracker_store import InMemoryTrackerStore
 
     kafka_broker = KafkaEventBroker(host='localhost:9092',
-                                    topic='rasa_core_events')
+                                    topic='rasa_events')
 
     tracker_store = InMemoryTrackerStore(event_broker=kafka_broker)
 
@@ -183,7 +183,7 @@ list of strings. e.g.:
     kafka_broker = KafkaEventBroker(host=['kafka_broker_1:9092',
                                           'kafka_broker_2:2030',
                                           'kafka_broker_3:9092'],
-                                    topic='rasa_core_events')
+                                    topic='rasa_events')
 
 Authentication and authorization
 ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
@@ -204,7 +204,7 @@ previously configured in the broker server.
                                     sasl_plain_username='kafka_username',
                                     sasl_plain_password='kafka_password',
                                     security_protocol='SASL_PLAINTEXT',
-                                    topic='rasa_core_events')
+                                    topic='rasa_events')
 
 
 If the clients or the brokers in the kafka cluster are located in different
@@ -221,7 +221,7 @@ be provided as arguments, as well as the CA's root certificate.
                                     ssl_keyfile='key.pem',
                                     ssl_check_hostname=True,
                                     security_protocol='SSL',
-                                    topic='rasa_core_events')
+                                    topic='rasa_events')
 
 If the ``ssl_check_hostname`` parameter is enabled, the clients will verify
 if the broker's hostname matches the certificate. It's used on client's connections
@@ -239,7 +239,7 @@ according to the security protocol being used. The following implementation show
     from kafka import KafkaConsumer
     from json import loads
 
-    consumer = KafkaConsumer('rasa_core_events',
+    consumer = KafkaConsumer('rasa_events',
                               bootstrap_servers=['localhost:29093'],
                               value_deserializer=lambda m: json.loads(m.decode('utf-8')),
                               security_protocol='SSL',

diff --git a/rasa/core/brokers/broker.py b/rasa/core/brokers/broker.py
@@ -35,7 +35,6 @@ def is_ready(self) -> bool:
 
         Returns:
             `True` by default, but this may be overridden by subclasses.
-
         """
         return True