diff --git a/cowrie/ssh/forwarding.py b/cowrie/ssh/forwarding.py
index e535542e..52af0cc5 100644
--- a/cowrie/ssh/forwarding.py
+++ b/cowrie/ssh/forwarding.py
@@ -42,7 +42,7 @@ def cowrieOpenConnectForwardingClient(remoteWindow, remoteMaxPacket, data, avata
         if remoteHP[1] in redirects:
             remoteHPNew = redirects[remoteHP[1]]
             log.msg(eventid='cowrie.direct-tcpip.redirect',
-                format='redirecting direct-tcp connection request %(src_ip)s:%(src_port)d->%(dst_ip)s:%(dst_port)d to %(new_ip)s:%(new_port)d',
+                format='redirected direct-tcp connection request %(src_ip)s:%(src_port)d->%(dst_ip)s:%(dst_port)d to %(new_ip)s:%(new_port)d',
                     new_ip=remoteHPNew[0], new_port=remoteHPNew[1],
                     dst_ip=remoteHP[0], dst_port=remoteHP[1],
                     src_ip=origHP[0], src_port=origHP[1])
@@ -79,7 +79,7 @@ class FakeForwardingChannel(forwarding.SSHConnectForwardingChannel):
         """
         """
         log.msg(eventid='cowrie.direct-tcpip.data',
-            format='direct-tcp forward request to %(dst_ip)s:%(dst_port)s with data %(data)s',
+            format='discarded direct-tcp forward request to %(dst_ip)s:%(dst_port)s with data %(data)s',
             dst_ip=self.hostport[0], dst_port=self.hostport[1], data=repr(data))
         self._close("Connection refused")