Signed-off-by: Xu Xijian <hdxuxijian(a)163.com>
---
src/lib/lifecycle.cr | 4 ++--
src/lib/mq.cr | 4 ++--
src/lib/sched.cr | 4 ++--
src/scheduler/close_job.cr | 2 +-
src/scheduler/find_job_boot.cr | 2 +-
src/scheduler/update_job_parameter.cr | 2 +-
6 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/src/lib/lifecycle.cr b/src/lib/lifecycle.cr
index 1eb6264..4bd2ac0 100644
--- a/src/lib/lifecycle.cr
+++ b/src/lib/lifecycle.cr
@@ -79,7 +79,7 @@ class Lifecycle
"job_state" => "abnormal",
"testbox" => testbox
}
- @mq.pushlish_confirm("job_mq", msg.to_json)
+ @mq.publish_confirm("job_mq", msg.to_json)
@match[testbox].delete(id)
end
end
@@ -313,7 +313,7 @@ class Lifecycle
mq_queue = get_machine_reboot_queue(testbox)
machine.as_h.delete("history")
machine.as_h["testbox"] = JSON::Any.new(testbox)
- @mq.pushlish_confirm(mq_queue, machine.to_json, durable: true)
+ @mq.publish_confirm(mq_queue, machine.to_json, durable: true)
machine["state"] = "rebooting_queue"
machine["time"] = Time.local.to_s("%Y-%m-%dT%H:%M:%S+0800")
diff --git a/src/lib/mq.cr b/src/lib/mq.cr
index 980585d..1c7f4b7 100644
--- a/src/lib/mq.cr
+++ b/src/lib/mq.cr
@@ -37,7 +37,7 @@ class MQClient
Singleton::Of(self).instance
end
- def pushlish_confirm(queue, msg, passive = false, durable = false, exclusive = false, auto_delete = false)
+ def publish_confirm(queue, msg, passive = false, durable = false, exclusive = false, auto_delete = false)
q = @ch.queue(queue, passive, durable, exclusive, auto_delete)
if durable
q.publish_confirm(msg, props: AMQ::Protocol::Properties.new(delivery_mode: 2))
@@ -46,7 +46,7 @@ class MQClient
end
end
- def pushlish(queue, msg, passive = false, durable = false, exclusive = false, auto_delete = false)
+ def publish(queue, msg, passive = false, durable = false, exclusive = false, auto_delete = false)
q = @ch.queue(queue, passive, durable, exclusive, auto_delete)
if durable
q.publish(msg, props: AMQ::Protocol::Properties.new(delivery_mode: 2))
diff --git a/src/lib/sched.cr b/src/lib/sched.cr
index 9528f54..ac677de 100644
--- a/src/lib/sched.cr
+++ b/src/lib/sched.cr
@@ -219,9 +219,9 @@ class Sched
return nil
end
- def mq_pushlish_confirm(queue, msg)
+ def mq_publish_confirm(queue, msg)
3.times do
- @mq.pushlish_confirm(queue, msg)
+ @mq.publish_confirm(queue, msg)
break
rescue e
res = @mq.reconnect
diff --git a/src/scheduler/close_job.cr b/src/scheduler/close_job.cr
index e014361..a57b233 100644
--- a/src/scheduler/close_job.cr
+++ b/src/scheduler/close_job.cr
@@ -45,7 +45,7 @@ class Sched
"job_state" => "close",
"time" => get_time
}
- spawn mq_pushlish_confirm(JOB_MQ, mq_msg.to_json)
+ spawn mq_publish_confirm(JOB_MQ, mq_msg.to_json)
end
end
end
diff --git a/src/scheduler/find_job_boot.cr b/src/scheduler/find_job_boot.cr
index 4a8ea8a..416f8f4 100644
--- a/src/scheduler/find_job_boot.cr
+++ b/src/scheduler/find_job_boot.cr
@@ -32,7 +32,7 @@ class Sched
"time" => get_time,
"job_state" => "boot"
}
- spawn mq_pushlish_confirm(JOB_MQ, mq_msg.to_json)
+ spawn mq_publish_confirm(JOB_MQ, mq_msg.to_json)
end
# auto submit a job to collect the host information.
diff --git a/src/scheduler/update_job_parameter.cr b/src/scheduler/update_job_parameter.cr
index d81f28b..92b905e 100644
--- a/src/scheduler/update_job_parameter.cr
+++ b/src/scheduler/update_job_parameter.cr
@@ -44,6 +44,6 @@ class Sched
"job_state" => (@env.get?("job_state") || "update").to_s,
"time" => @env.get?("time").to_s
}
- spawn mq_pushlish_confirm(JOB_MQ, mq_msg.to_json)
+ spawn mq_publish_confirm(JOB_MQ, mq_msg.to_json)
end
end
--
2.23.0