Fix exception when sending a message with event ID using transport pr…

…otocol (#189)

* Do not check event Id before it is set

* Update readme and version

* Remove raw attribute from transport pin for sending

README.md

@@ -1,4 +1,4 @@
-# Connect (4.0.0)
+# Connect (4.0.1)
 
 The "Connect" component is responsible for the communication with a target system.
 This component implements the logic of the interaction protocol, receiving and sending messages from and to the system, respectively.
@@ -127,6 +127,12 @@ spec:
 
 ## Release notes
 
+### 4.0.1
+
+#### Fixed:
+
++ Exception when processing sent message with event ID
+
 ### 4.0.0
 
 + Migration to books/pages cradle 5.0.0

gradle.properties

@@ -1 +1 @@
-release_version = 4.0.0
+release_version = 4.0.1

src/main/java/com/exactpro/th2/conn/TransportMessageSender.java

@@ -60,7 +60,7 @@ public void start() {
 
         logger.info("Subscribing to transport queue with messages to send");
 
-        subscriberMonitor = router.subscribeAll(this, SEND_ATTRIBUTE, QueueAttribute.RAW.getValue());
+        subscriberMonitor = router.subscribeAll(this, SEND_ATTRIBUTE);
     }
 
     public void stop() throws IOException {

src/main/java/com/exactpro/th2/conn/saver/impl/TransportMessageSever.java

@@ -83,10 +83,12 @@ public static MessageGroup convertToGroup(ConnectivityMessage connectivityMessag
             if (SailfishMetadataExtensions.contains(sfMetadata, MetadataProperty.PARENT_EVENT_ID)) {
                 EventID parentEventID = SailfishMetadataExtensions.getParentEventID(sfMetadata);
                 // Should never happen because the Sailfish does not support sending multiple messages at once
-                if (rawMessage.getEventId() != null) {
-                    LOGGER.warn("The parent ID is already set for message {}. Current ID: {}, New ID: {}",
-                            messageId, rawMessage.getEventId(), parentEventID);
-                }
+                // This check is removed because raw message builder throws an IllegalStateException
+                // if the event ID is not set
+//                if (rawMessage.getEventId() != null) {
+//                    LOGGER.warn("The parent ID is already set for message {}. Current ID: {}, New ID: {}",
+//                            messageId, rawMessage.getEventId(), parentEventID);
+//                }
                 rawMessage.setEventId(EventUtilsKt.toTransport(parentEventID));
             }
             Map<String, String> props = defaultIfNull(getMessageProperties(sfMetadata), Collections.emptyMap());