Commit ca36c63a authored by Federico Sismondi's avatar Federico Sismondi

deleted useless code

parent 15025268
...@@ -36,22 +36,6 @@ def publish_tun_start(exchange, channel, agent_id, ipv6_host, ipv6_prefix, ipv6_ ...@@ -36,22 +36,6 @@ def publish_tun_start(exchange, channel, agent_id, ipv6_host, ipv6_prefix, ipv6_
) )
def publish_tun_bootrap_success(exchange, channel, agent_id):
msg = MsgAgentTunStart(
name=agent_id,
)
channel.basic_publish(
exchange=exchange,
routing_key=MsgAgentTunStarted.routing_key.replace('*', agent_id),
mandatory=True,
properties=pika.BasicProperties(
content_type='application/json',
),
body=msg.to_json()
)
def check_response(channel, queue_name, agent_id): def check_response(channel, queue_name, agent_id):
method, header, body = channel.basic_get(queue=queue_name) method, header, body = channel.basic_get(queue=queue_name)
if body is not None: if body is not None:
...@@ -90,7 +74,6 @@ def bootstrap(amqp_url, amqp_exchange, agent_id, ipv6_host, ipv6_prefix, ipv6_no ...@@ -90,7 +74,6 @@ def bootstrap(amqp_url, amqp_exchange, agent_id, ipv6_host, ipv6_prefix, ipv6_no
time.sleep(RETRY_PERIOD) time.sleep(RETRY_PERIOD)
if check_response(channel, agent_event_q, agent_id): if check_response(channel, agent_event_q, agent_id):
logging.debug("Agent tun bootstrapped") logging.debug("Agent tun bootstrapped")
publish_tun_bootrap_success(amqp_exchange, channel, agent_id)
break break
elif i < 3: elif i < 3:
pass pass
......
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