diff --git a/src/main/java/com/exactpro/th2/conn/TransportMessageSender.java b/src/main/java/com/exactpro/th2/conn/TransportMessageSender.java index 1b1ff55..7b061b2 100644 --- a/src/main/java/com/exactpro/th2/conn/TransportMessageSender.java +++ b/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 {