Commit 60d84957 authored by Federico Sismondi's avatar Federico Sismondi

small fixes

parent 78bdfd24
......@@ -115,6 +115,7 @@ class TunConsumer(BaseConsumer):
self.log.debug(("Headers", message.headers))
#self.log.debug(("body", message.body))
self.log.debug(("Body", body))
self.log.debug(("Message type (_type field)", body["_type"]))
self.log.debug('\n* * * * * * * * * * * * * * * * * * * * * * *')
# body is already a dict, no need to json.load it
......
......@@ -503,6 +503,7 @@ class OpenTunLinux(object):
routing_key = "data.tun.fromAgent.{name}".format(name=self.name)
log.debug("This is my routing key: %s" % routing_key)
# dispatch to EventBus
# TODO move timestamp.msg id and roiuting key, add them as headers , not payload
msg = {
"_type": "packet.sniffed.raw",
"interface_name": self.ifname,
......@@ -706,6 +707,7 @@ class OpenTunMACOS(object):
routing_key = "data.tun.fromAgent.{name}".format(name=self.name)
log.debug("This is my routing key: %s" % routing_key)
# dispatch to EventBus
# TODO move timestamp.msg id and roiuting key, add them as headers , not payload
msg = {
"_type": "packet.sniffed.raw",
"interface_name": self.ifname,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment