def connection_headers
headers = {"accept-version""accept-version" => "1.0"}
heartbeat_interval = Integer(get_option("rabbitmq.heartbeat_interval", 0))
stomp_1_0_fallback = get_bool_option("rabbitmq.stomp_1_0_fallback", true)
headers[:host] = get_option("rabbitmq.vhost", "/")
if heartbeat_interval > 0
unless stomp_version_supports_heartbeat?
raise("Setting STOMP 1.1 properties like heartbeat intervals require at least version 1.2.10 of the STOMP gem")
end
if heartbeat_interval < 30
Log.warn("Connection heartbeat is set to %d, forcing to minimum value of 30s")
heartbeat_interval = 30
end
heartbeat_interval = heartbeat_interval * 1000
headers["heart-beat""heart-beat"] = "%d,%d" % [heartbeat_interval + 500, heartbeat_interval - 500]
if stomp_1_0_fallback
headers["accept-version""accept-version"] = "1.1,1.0"
else
headers["accept-version""accept-version"] = "1.1"
end
else
if stomp_version_supports_heartbeat?
Log.info("Connecting without STOMP 1.1 heartbeats, consider setting plugin.rabbitmq.heartbeat_interval")
end
end
headers
end