File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed
packages/core/minos-microservice-networks/minos/networks/brokers Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -27,7 +27,7 @@ class BrokerQueue(ABC, MinosSetup):
2727
2828 async def enqueue (self , message : BrokerMessage ) -> None :
2929 """Enqueue method."""
30- logger .info (f"Enqueuing { message !r} message..." )
30+ logger .debug (f"Enqueuing { message !r} message..." )
3131 await self ._enqueue (message )
3232
3333 @abstractmethod
@@ -45,7 +45,7 @@ async def __anext__(self) -> BrokerMessage:
4545 async def dequeue (self ) -> BrokerMessage :
4646 """Dequeue method."""
4747 message = await self ._dequeue ()
48- logger .info (f"Dequeuing { message !r} message..." )
48+ logger .debug (f"Dequeuing { message !r} message..." )
4949 return message
5050
5151 @abstractmethod
Original file line number Diff line number Diff line change @@ -24,7 +24,7 @@ async def send(self, message: BrokerMessage) -> None:
2424 :param message: The message to be sent.
2525 :return: This method does not return anything.
2626 """
27- logger .info (f"Sending { message !r} message..." )
27+ logger .debug (f"Sending { message !r} message..." )
2828 await self ._send (message )
2929
3030 @abstractmethod
Original file line number Diff line number Diff line change @@ -58,7 +58,7 @@ async def receive(self) -> BrokerMessage:
5858 :return: A ``BrokerMessage`` instance.
5959 """
6060 message = await self ._receive ()
61- logger .info (f"Receiving { message !r} message..." )
61+ logger .debug (f"Receiving { message !r} message..." )
6262 return message
6363
6464 @abstractmethod
You can’t perform that action at this time.
0 commit comments