Refactor message handling to ensure UTF-8 decoding.

Decoded messages to UTF-8 strings before sending to IBM MQ. Updated all relevant message-sending paths to use the decoded `message_str` for consistency and error prevention.

Author: liornabat

README.md

@@ -124,6 +124,7 @@ data:
           # when sender_mode is custom, you can set the following parameters
           #message_format: MQHRF2
           #message_ccsid: 1208
+          log_sent_messages: true
           poll_interval_ms: 100
       - name: ibm_to_kubemq
         type: ibm_mq_to_kubemq
@@ -139,6 +140,7 @@ data:
           receiver_mode: default
           # enable logging received messages
           log_received_messages: true
+          log_sent_messages: true
           poll_interval_ms: 100
         target:
           address: kubemq-cluster-grpc:50000

Taskfile.yml

@@ -3,7 +3,7 @@
 version: '3'
 
 vars:
-  VERSION: v0.5.0
+  VERSION: v0.6.0
   IMAGE_NAME: europe-docker.pkg.dev/kubemq/images/ibm-mq-connector
 
 tasks:

src/ibm_mq/client.py

@@ -176,7 +176,10 @@ async def send_message(self, message: bytes):
         if not self.is_connected:
             self.logger.error("Not connected to IBM MQ")
             raise IBMMQConnectionError("Not connected to IBM MQ")
+
         message_str = message.decode("utf-8")
+        if self.config.log_sent_messages:
+            self.logger.info(f"Sending message: {message_str}")
 
         async def _send_message():
             try:

src/ibm_mq/config.py

@@ -20,6 +20,7 @@ class Config(BaseModel):
     log_received_messages: bool = Field(
         default=False, description="Log received messages"
     )
+    log_sent_messages: bool = Field(default=False, description="Log sent messages")
     sender_mode: Optional[str] = Field("default", description="Sender mode")
     poll_interval_ms: int = Field(
         default=100, ge=1, description="Poll interval in milliseconds"