class Qpid::Proton::Message

# File lib/qpid_proton/message.rb, line 108
def initialize
  @impl = Cproton.pn_message
  ObjectSpace.define_finalizer(self, self.class.finalize!(@impl))
  @properties = {}
  @instructions = {}
  @annotations = {}
  @body = nil
end

# File lib/qpid_proton/message.rb, line 554
def [](name)
  @properties[name]
end

# File lib/qpid_proton/message.rb, line 547
def []=(name, value)
  @properties[name] = value
end

# File lib/qpid_proton/message.rb, line 319
def address
  Cproton.pn_message_get_address(@impl)
end

# File lib/qpid_proton/message.rb, line 313
def address=(address)
  Cproton.pn_message_set_address(@impl, address)
end

# File lib/qpid_proton/message.rb, line 578
def annotations
  @annotations
end

# File lib/qpid_proton/message.rb, line 584
def annotations=(annotations)
  @annotations = annotations
end

# File lib/qpid_proton/message.rb, line 590
def body
  @body
end

# File lib/qpid_proton/message.rb, line 596
def body=(body)
  @body = body
end

# File lib/qpid_proton/message.rb, line 141
def clear
  Cproton.pn_message_clear(@impl)
  @properties.clear unless @properties.nil?
  @instructions.clear unless @instructions.nil?
  @annotations.clear unless @annotations.nil?
  @body = nil
end

# File lib/qpid_proton/message.rb, line 418
def content
  Cproton.pn_message_save(@impl, 1024)[1]
end

# File lib/qpid_proton/message.rb, line 412
def content=(content)
  Cproton.pn_message_load(@impl, content)
end

# File lib/qpid_proton/message.rb, line 434
def content_encoding
  Cproton.pn_message_get_content_encoding(@impl)
end

# File lib/qpid_proton/message.rb, line 428
def content_encoding=(encoding)
  Cproton.pn_message_set_content_encoding(@impl, encoding)
end

# File lib/qpid_proton/message.rb, line 402
def content_type
  Cproton.pn_message_get_content_type(@impl)
end

# File lib/qpid_proton/message.rb, line 396
def content_type=(content_type)
  Cproton.pn_message_set_content_type(@impl, content_type)
end

# File lib/qpid_proton/message.rb, line 367
def correlation_id
  Cproton.pn_message_get_correlation_id(@impl)
end

# File lib/qpid_proton/message.rb, line 361
def correlation_id=(id)
  Cproton.pn_message_set_correlation_id(@impl, id)
end

# File lib/qpid_proton/message.rb, line 470
def creation_time
  Cproton.pn_message_get_creation_time(@impl)
end

# File lib/qpid_proton/message.rb, line 462
def creation_time=(time)
  raise TypeError.new("invalid time: #{time}") if time.nil?
  raise ArgumentError.new("time cannot be negative") if time < 0
  Cproton.pn_message_set_creation_time(@impl, time)
end

# File lib/qpid_proton/message.rb, line 37
def decode(encoded)
  check(Cproton.pn_message_decode(@impl, encoded, encoded.length))

  post_decode
end

# File lib/qpid_proton/message.rb, line 560
def delete_property(name)
  @properties.delete(name)
end

# File lib/qpid_proton/message.rb, line 264
def delivery_count
  Cproton.pn_message_get_delivery_count(@impl)
end

# File lib/qpid_proton/message.rb, line 253
def delivery_count=(count)
  raise ArgumentError.new("invalid count: #{count}") if count.nil? || !([Float, Fixnum].include?(count.class))
  raise RangeError.new("count out of range: #{count}") if count < 0

  Cproton.pn_message_set_delivery_count(@impl, count.floor)
end

# File lib/qpid_proton/message.rb, line 190
def durable
  Cproton.pn_message_is_durable(@impl)
end

# File lib/qpid_proton/message.rb, line 175
def durable=(state)
  raise TypeError.new("state cannot be nil") if state.nil?
  Cproton.pn_message_set_durable(@impl, state)
end

# File lib/qpid_proton/message.rb, line 68
def encode
  pre_encode
  size = 16
  loop do
    error, data = Cproton::pn_message_encode(@impl, size)
    if error == Qpid::Proton::Error::OVERFLOW
      size *= 2
    else
      check(error)
      return data
    end
  end
end

# File lib/qpid_proton/message.rb, line 151
def errno
  Cproton.pn_message_errno(@impl)
end

# File lib/qpid_proton/message.rb, line 157
def error
  Cproton.pn_error_text(Cproton.pn_message_error(@impl))
end

# File lib/qpid_proton/message.rb, line 163
def error?
  !Cproton.pn_message_errno(@impl).zero?
end

# File lib/qpid_proton/message.rb, line 452
def expires
  Cproton.pn_message_get_expiry_time(@impl)
end

# File lib/qpid_proton/message.rb, line 444
def expires=(time)
  raise TypeError.new("invalid expiry time: #{time}") if time.nil?
  raise ArgumentError.new("expiry time cannot be negative: #{time}") if time < 0
  Cproton.pn_message_set_expiry_time(@impl, time)
end

# File lib/qpid_proton/message.rb, line 240
def first_acquirer=(state)
  raise TypeError.new("invalid state: #{state}") if state.nil? || !([TrueClass, FalseClass].include?(state.class))
  Cproton.pn_message_set_first_acquirer(@impl, state)
end

# File lib/qpid_proton/message.rb, line 271
def first_acquirer?
  Cproton.pn_message_is_first_acquirer(@impl)
end

# File lib/qpid_proton/message.rb, line 386
def format
  Qpid::Proton::MessageFormat.by_value(Cproton.pn_message_get_format(@impl))
end

# File lib/qpid_proton/message.rb, line 379
def format=(format)
  raise TypeError.new("invalid message format: #{format}") if (format.nil? || !format.kind_of?(Qpid::Proton::MessageFormat))
  Cproton.pn_message_set_format(@impl, format.value)
end

# File lib/qpid_proton/message.rb, line 486
def group_id
  Cproton.pn_message_get_group_id(@impl)
end

# File lib/qpid_proton/message.rb, line 480
def group_id=(id)
  Cproton.pn_message_set_group_id(@impl, id)
end

# File lib/qpid_proton/message.rb, line 503
def group_sequence
  Cproton.pn_message_get_group_sequence(@impl)
end

# File lib/qpid_proton/message.rb, line 496
def group_sequence=(seq)
  raise TypeError.new("invalid seq: #{seq}") if seq.nil?
  Cproton.pn_message_set_group_sequence(@impl, seq)
end

# File lib/qpid_proton/message.rb, line 287
def id
  Cproton.pn_message_get_id(@impl)
end

# File lib/qpid_proton/message.rb, line 281
def id=(id)
  Cproton.pn_message_set_id(@impl, id)
end

# File lib/qpid_proton/message.rb, line 566
def instructions
  @instructions
end

# File lib/qpid_proton/message.rb, line 572
def instructions=(instr)
  @instructions = instr
end

# File lib/qpid_proton/message.rb, line 210
def priority
  Cproton.pn_message_get_priority(@impl)
end

# File lib/qpid_proton/message.rb, line 202
def priority=(priority)
  raise TypeError.new("invalid priority: #{priority}") if priority.nil? || !([Float, Fixnum].include?(priority.class))
  raise RangeError.new("priority out of range: #{priority}") if ((priority > 255) || (priority < 0))
  Cproton.pn_message_set_priority(@impl, priority.floor)
end

# File lib/qpid_proton/message.rb, line 530
def properties
  @properties
end

# File lib/qpid_proton/message.rb, line 536
def properties=(properties)
  @properties = properties
end

# File lib/qpid_proton/message.rb, line 351
def reply_to
  Cproton.pn_message_get_reply_to(@impl)
end

# File lib/qpid_proton/message.rb, line 345
def reply_to=(address)
  Cproton.pn_message_set_reply_to(@impl, address)
end

# File lib/qpid_proton/message.rb, line 519
def reply_to_group_id
  Cproton.pn_message_get_reply_to_group_id(@impl)
end

# File lib/qpid_proton/message.rb, line 513
def reply_to_group_id=(id)
  Cproton.pn_message_set_reply_to_group_id(@impl, id)
end

# File lib/qpid_proton/message.rb, line 335
def subject
  Cproton.pn_message_get_subject(@impl)
end

# File lib/qpid_proton/message.rb, line 329
def subject=(subject)
  Cproton.pn_message_set_subject(@impl, subject)
end

# File lib/qpid_proton/message.rb, line 117
def to_s
  tmp = Cproton.pn_string("")
  Cproton.pn_inspect(@impl, tmp)
  result = Cproton.pn_string_get(tmp)
  Cproton.pn_free(tmp)
  return result
end

# File lib/qpid_proton/message.rb, line 228
def ttl
  Cproton.pn_message_get_ttl(@impl)
end

# File lib/qpid_proton/message.rb, line 220
def ttl=(time)
  raise TypeError.new("invalid ttl: #{time}") if time.nil? || !([Float, Fixnum].include?(time.class))
  raise RangeError.new("time out of range: #{time}") if ((time < 0))
  Cproton.pn_message_set_ttl(@impl, time.floor)
end

# File lib/qpid_proton/message.rb, line 303
def user_id
  Cproton.pn_message_get_user_id(@impl)
end

# File lib/qpid_proton/message.rb, line 297
def user_id=(id)
  Cproton.pn_message_set_user_id(@impl, id)
end