Class: QRubyDriver::QMessage

Inherits:
Object
  • Object
show all
Defined in:
lib/q-ruby-driver/q_message.rb

Overview

Provided for legacy compatibility with previous versions of q-ruby-driver Usage of this class is deprecated

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#exception ⇒ Object (readonly)

Returns the value of attribute exception.



8
9
10
 
# File 'lib/q-ruby-driver/q_message.rb', line 8

def exception
  @exception
end

#message ⇒ Object (readonly)

Returns the value of attribute message.



11
12
13
 
# File 'lib/q-ruby-driver/q_message.rb', line 11

def message
  @message
end

#message_type ⇒ Object (readonly)

Returns the value of attribute message_type.



7
8
9
 
# File 'lib/q-ruby-driver/q_message.rb', line 7

def message_type
  @message_type
end

#timing ⇒ Object (readonly)

Returns the value of attribute timing.



12
13
14
 
# File 'lib/q-ruby-driver/q_message.rb', line 12

def timing
  @timing
end

#value ⇒ Object (readonly)

Returns the value of attribute value.



9
10
11
 
# File 'lib/q-ruby-driver/q_message.rb', line 9

def value
  @value
end

Instance Method Details

#create(value, sync = false) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
# File 'lib/q-ruby-driver/q_message.rb', line 16

def create(value, sync = false)
  @value = value
  sync == true ? @message_type = :sync : @message_type = :async

  start_time = Time.now

  qio = QIO.new
  qio.write_message(value, sync)
  qio.pos=0
  @message = qio.read
  puts [@message].inspect
  @length = @message.length
  @timing = Time.now - start_time

  self
end

#decode(message) ⇒ Object

Decodes a binary message into a QMessage



34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/q-ruby-driver/q_message.rb', line 34

def decode(message)
  start_time= Time.now
  @message = message
  qio = QIO.new(@message)
  begin
    @length, @message_type = qio.message_header()
    @value = qio.read_item()
  rescue QException => qe
    @exception = qe
  end
end

#to_s ⇒ Object 



46
47
48
49
50
51
52
53
54
 
# File 'lib/q-ruby-driver/q_message.rb', line 46

def to_s
  if @message.nil?
    "QMessage [None]"
  elsif !@exception.nil?
    "QException [#{@message.unpack("H*")}] Type[#{@message_type}] Length [#{@length}] Value[#{@value}]"
  else
    "QMessage [#{@message.unpack("H*")}] Type[#{@message_type}] Length [#{@length}] Value[#{@value}]"
  end
end