Fixed name of the subscriber component in the pubsub example

asphalt-framework · Jun 7, 2017 · 88c278f · 88c278f
1 parent 137d040
commit 88c278f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/examples/pubsub/subscriber.py b/examples/pubsub/subscriber.py
@@ -13,7 +13,7 @@ def subscriber(ctx: EventContext, message: str):
     logger.info('Received message from %s: %s', ctx.topic, message)
 
 
-class PublisherComponent(ContainerComponent):
+class SubscriberComponent(ContainerComponent):
     async def start(self, ctx: Context):
         self.add_component('wamp')
         await super().start(ctx)
@@ -27,4 +27,4 @@ async def start(self, ctx: Context):
     print('Usage: {} <topic>'.format(sys.argv[0]), file=sys.stderr)
     sys.exit(1)
 
-run_application(PublisherComponent(), logging=logging.INFO)
+run_application(SubscriberComponent(), logging=logging.INFO)