Fix publisher

pybondi/messagebus.py

@@ -76,5 +76,5 @@ def consume(self, event: Event):
             try:
                 consumer(event)
             except Exception as exception:
-                logger.error(f"Error while consuming event {event}")
+                logger.error(f"Error {exception} while consuming event {event}")
                 logger.debug(exception, exc_info=True)

pybondi/publisher.py

@@ -8,27 +8,26 @@ class Base(ABC):
     An abstract base class for a publisher.
 
     A publisher is responsible for publishing messages to external systems
-    using callables as subscribers. It should implement the methods to
-    mantain transacional consistency and resource management using the
-    begin, commit, rollback and close methods.
+    using callable subscribers. It should implement the methods to mantain 
+    transacional consistency and resource management using the begin, commit,
+    rollback and close methods.
 
 
     The difference between a publisher and a messagebus is that a publisher
     is responsible for publish data from the inside of the bounded context
     to outside systems. A message bus is responsible for routing events and
     commands within the bounded context, and handle them inside a transaction.
 
-    Messages passed to the publisher should be serializable objects and 
-    inmutable.
+    Messages passed to the publisher should be serializable objects.
     """
 
     @abstractmethod
-    def handle(self,topic: str, message: Any) -> None:
+    def publish(self, topic: str, message: Any) -> None:
         """
-        Receives a message from the publisher.
+        Publishes a message to a topic.
 
         Args:
-            message: The message to be received.
+            message: The message to be published.
         """
 
     @abstractmethod
@@ -75,7 +74,7 @@ def subscribe(self, topic: str, subscriber: Callable):
         '''
         self.subscribers.setdefault(topic, []).append(subscriber)
 
-    def handle(self, topic: str, message: Any):
+    def publish(self, topic: str, message: Any):
         '''
         Receives a message from the publisher. 
         '''

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "pybondi"
-version = "0.3.0"
+version = "0.3.1"
 description = "A lightweight library for creating event driven systems using domain driven design."
 authors = ["Eric Cardozo <[email protected]>"]
 license = "MIT"

tests/test_publisher.py

@@ -10,7 +10,7 @@ def test_subscribe_and_publish_message(publisher: Publisher):
     subscriber = Mock()
     publisher.subscribe("topic1", subscriber)
 
-    publisher.handle("topic1", "test message")
+    publisher.publish("topic1", "test message")
     publisher.commit()
     subscriber.assert_called_once_with("test message")
 
@@ -19,15 +19,15 @@ def test_multiple_subscribers_on_same_topic(publisher: Publisher):
     subscriber2 = Mock()
     publisher.subscribe("topic1", subscriber1)
     publisher.subscribe("topic1", subscriber2)
-    publisher.handle("topic1", "test message")
+    publisher.publish("topic1", "test message")
     publisher.commit()
 
     subscriber1.assert_called_once_with("test message")
     subscriber2.assert_called_once_with("test message")
 
 def test_no_subscribers_no_errors(publisher: Publisher):
     # Handle a message with no subscribers
-    publisher.handle("topic1", "test message")
+    publisher.publish("topic1", "test message")
     try:
         publisher.commit()
     except Exception as e:
@@ -37,7 +37,7 @@ def test_rollback_message(publisher: Publisher):
     subscriber = Mock()
     publisher.subscribe("topic1", subscriber)
 
-    publisher.handle("topic1", "test message")
+    publisher.publish("topic1", "test message")
     publisher.rollback()
 
     publisher.commit()