[TH2-5073] Different pin attributes for different send: ParsedMessage…

… send and RawMessage send (#122)

README.md

@@ -1,4 +1,4 @@
-# th2 act template (5.1.0)
+# th2 act template (5.1.1)
 
 ## Overview
 
@@ -49,6 +49,7 @@ spec:
       connection-type: mq
       attributes:
         - publish
+        - send
         - transport-group
       filters:
         - metadata:
@@ -59,6 +60,7 @@ spec:
       connection-type: mq
       attributes:
         - publish
+        - send
         - transport-group
       filters:
         - metadata:
@@ -98,6 +100,9 @@ the `protobuf-description-base64` label. Such descriptors can be used to interac
 
 ## Release Notes
 
+### 5.1.1
++ Use pins with `send` pin attribute for parsed messages sends.
+
 ### 5.1.0
 + Added RPC to send raw messages.
 + Updated grpc-act-template to `4.2.0`

gradle.properties

@@ -1,4 +1,4 @@
-release_version=5.1.0
+release_version=5.1.1
 nexus_url=
 nexus_user=
 nexus_password=

src/main/java/com/exactpro/th2/act/ActHandler.java

@@ -98,6 +98,7 @@
 public class ActHandler extends ActImplBase {
     private static final int DEFAULT_RESPONSE_TIMEOUT = 10_000;
     private static final String SEND_RAW_QUEUE_ATTRIBUTE = "send_raw";
+    private static final String SEND_QUEUE_ATTRIBUTE = "send";
     private static final Logger LOGGER = LoggerFactory.getLogger(ActHandler.class);
 
     private final Check1Service check1Service;
@@ -565,7 +566,7 @@ private void sendMessage(Message message, EventID parentEventId) throws IOExcept
             //May be use in future for filtering
             //request.getConnectionId().getSessionAlias();
             MessageID messageID = message.getMetadata().getId();
-            messageRouter.send(toBatch(toGroup(parsedMessage), messageID.getBookName(), messageID.getConnectionId().getSessionGroup()));
+            messageRouter.send(toBatch(toGroup(parsedMessage), messageID.getBookName(), messageID.getConnectionId().getSessionGroup()), SEND_QUEUE_ATTRIBUTE);
             //TODO remove after solving issue TH2-217
             //TODO process response
             EventBatch eventBatch = EventBatch.newBuilder()
@@ -613,7 +614,7 @@ private com.exactpro.th2.common.grpc.Event createSendMessageEvent(ParsedMessage
     private com.exactpro.th2.common.grpc.Event createSendRawMessageEvent(RawMessage message, EventID parentEventId) throws IOException {
         Event event = start()
             .name("Sent raw message to connectivity");
-        com.exactpro.th2.common.event.bean.Message messageBean = EventUtils.createMessageBean(ByteBufUtil.hexDump(message.getBody()));
+        com.exactpro.th2.common.event.bean.Message messageBean = EventUtils.createMessageBean(ByteBufUtil.prettyHexDump(message.getBody()));
         event.status(Status.PASSED);
         event.bodyData(messageBean);
         event.type("Outgoing message");