# File lib/stomp/connection.rb, line 167 def begin(name, headers = {}) raise Stomp::Error::NoCurrentConnection if @closed_check && closed? headers = headers.symbolize_keys headers[:transaction] = name _headerCheck(headers) if @logger && @logger.respond_to?(:on_begin) @logger.on_begin(log_params, headers) end transmit(Stomp::CMD_BEGIN, headers) end