Class: VertxAmqpClient::AmqpMessage

Inherits:
Object
  • Object
show all
Defined in:
/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb

Overview

Represents an AMQP message.

Reference about the different metadata can be found on AMQP message properties.

Note that the body is retrieved using body* method depending on the expected type.

Constant Summary

@@j_api_type =
Object.new

Class Method Summary (collapse)

Instance Method Summary (collapse)

Class Method Details

+ (Boolean) accept?(obj)

Returns:

  • (Boolean)

24
25
26
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 24

def @@j_api_type.accept?(obj)
  obj.class == AmqpMessage
end

+ (::VertxAmqpClient::AmqpMessageBuilder) create(existing = nil)

Creates a builder to create a new VertxAmqpClient::AmqpMessage copying the metadata from the passed message.

Parameters:

Returns:

Raises:

  • (ArgumentError)

42
43
44
45
46
47
48
49
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 42

def self.create(existing=nil)
  if !block_given? && existing == nil
    return ::Vertx::Util::Utils.safe_create(Java::IoVertxAmqp::AmqpMessage.java_method(:create, []).call(),::VertxAmqpClient::AmqpMessageBuilder)
  elsif existing.class.method_defined?(:j_del) && !block_given?
    return ::Vertx::Util::Utils.safe_create(Java::IoVertxAmqp::AmqpMessage.java_method(:create, [Java::IoVertxAmqp::AmqpMessage.java_class]).call(existing.j_del),::VertxAmqpClient::AmqpMessageBuilder)
  end
  raise ArgumentError, "Invalid arguments when calling create(#{existing})"
end

+ (Object) j_api_type


33
34
35
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 33

def self.j_api_type
  @@j_api_type
end

+ (Object) j_class


36
37
38
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 36

def self.j_class
  Java::IoVertxAmqp::AmqpMessage.java_class
end

+ (Object) unwrap(obj)


30
31
32
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 30

def @@j_api_type.unwrap(obj)
  obj.j_del
end

+ (Object) wrap(obj)


27
28
29
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 27

def @@j_api_type.wrap(obj)
  AmqpMessage.new(obj)
end

Instance Method Details

- (self) accepted

When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message. It marks the message as delivered with the accepted status.

Returns:

  • (self)

Raises:

  • (ArgumentError)

284
285
286
287
288
289
290
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 284

def accepted
  if !block_given?
    @j_del.java_method(:accepted, []).call()
    return self
  end
  raise ArgumentError, "Invalid arguments when calling accepted()"
end

- (String) address

Returns the message address, also named to field

Returns:

  • (String)
    the message address, also named to field

Raises:

  • (ArgumentError)

93
94
95
96
97
98
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 93

def address
  if !block_given?
    return @j_del.java_method(:address, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling address()"
end

- (Hash{String => Object}) application_properties

Returns the message properties as JSON object.

Returns:

  • (Hash{String => Object})
    the message properties as JSON object.

Raises:

  • (ArgumentError)

275
276
277
278
279
280
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 275

def application_properties
  if !block_given?
    return @j_del.java_method(:applicationProperties, []).call() != nil ? JSON.parse(@j_del.java_method(:applicationProperties, []).call().encode) : nil
  end
  raise ArgumentError, "Invalid arguments when calling application_properties()"
end

- (::Vertx::Buffer) body_as_binary

Returns the bytes contained in the body. The value must be passed as AMQP data.

Returns:

  • (::Vertx::Buffer)
    the bytes contained in the body. The value must be passed as AMQP data.

Raises:

  • (ArgumentError)

177
178
179
180
181
182
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 177

def body_as_binary
  if !block_given?
    return ::Vertx::Util::Utils.safe_create(@j_del.java_method(:bodyAsBinary, []).call(),::Vertx::Buffer)
  end
  raise ArgumentError, "Invalid arguments when calling body_as_binary()"
end

- (true, false) body_as_boolean?

Returns the boolean value contained in the body. The value must be passed as AMQP value.

Returns:

  • (true, false)
    the boolean value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

121
122
123
124
125
126
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 121

def body_as_boolean?
  if !block_given?
    return @j_del.java_method(:bodyAsBoolean, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_boolean?()"
end

- (Fixnum) body_as_byte

Returns the byte value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Fixnum)
    the byte value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

128
129
130
131
132
133
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 128

def body_as_byte
  if !block_given?
    return @j_del.java_method(:bodyAsByte, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_byte()"
end

- (Fixnum) body_as_char

Returns the character value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Fixnum)
    the character value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

170
171
172
173
174
175
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 170

def body_as_char
  if !block_given?
    return @j_del.java_method(:bodyAsChar, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_char()"
end

- (Float) body_as_double

Returns the double value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Float)
    the double value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

163
164
165
166
167
168
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 163

def body_as_double
  if !block_given?
    return @j_del.java_method(:bodyAsDouble, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_double()"
end

- (Float) body_as_float

Returns the float value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Float)
    the float value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

156
157
158
159
160
161
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 156

def body_as_float
  if !block_given?
    return @j_del.java_method(:bodyAsFloat, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_float()"
end

- (Fixnum) body_as_integer

Returns the integer value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Fixnum)
    the integer value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

142
143
144
145
146
147
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 142

def body_as_integer
  if !block_given?
    return @j_del.java_method(:bodyAsInteger, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_integer()"
end

- (Array<String,Object>) body_as_json_array

Returns the JSON array contained in the body. The value must be passed as AMQP data.

Returns:

  • (Array<String,Object>)
    the JSON array contained in the body. The value must be passed as AMQP data.

Raises:

  • (ArgumentError)

212
213
214
215
216
217
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 212

def body_as_json_array
  if !block_given?
    return @j_del.java_method(:bodyAsJsonArray, []).call() != nil ? JSON.parse(@j_del.java_method(:bodyAsJsonArray, []).call().encode) : nil
  end
  raise ArgumentError, "Invalid arguments when calling body_as_json_array()"
end

- (Hash{String => Object}) body_as_json_object

Returns the JSON object contained in the body. The value must be passed as AMQP data.

Returns:

  • (Hash{String => Object})
    the JSON object contained in the body. The value must be passed as AMQP data.

Raises:

  • (ArgumentError)

205
206
207
208
209
210
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 205

def body_as_json_object
  if !block_given?
    return @j_del.java_method(:bodyAsJsonObject, []).call() != nil ? JSON.parse(@j_del.java_method(:bodyAsJsonObject, []).call().encode) : nil
  end
  raise ArgumentError, "Invalid arguments when calling body_as_json_object()"
end

- (Array<Object>) body_as_list

Returns the list of values contained in the body. The value must be passed as AMQP value.

Returns:

  • (Array<Object>)
    the list of values contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

198
199
200
201
202
203
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 198

def body_as_list
  if !block_given?
    return @j_del.java_method(:bodyAsList, []).call().to_a.map { |elt| ::Vertx::Util::Utils.from_object(elt) }
  end
  raise ArgumentError, "Invalid arguments when calling body_as_list()"
end

- (Fixnum) body_as_long

Returns the long value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Fixnum)
    the long value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

149
150
151
152
153
154
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 149

def body_as_long
  if !block_given?
    return @j_del.java_method(:bodyAsLong, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_long()"
end

- (Fixnum) body_as_short

Returns the short value contained in the body. The value must be passed as AMQP value.

Returns:

  • (Fixnum)
    the short value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

135
136
137
138
139
140
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 135

def body_as_short
  if !block_given?
    return @j_del.java_method(:bodyAsShort, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_short()"
end

- (String) body_as_string

Returns the string value contained in the body. The value must be passed as AMQP value.

Returns:

  • (String)
    the string value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

184
185
186
187
188
189
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 184

def body_as_string
  if !block_given?
    return @j_del.java_method(:bodyAsString, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_string()"
end

- (String) body_as_symbol

Returns the symbol value contained in the body. The value must be passed as AMQP value.

Returns:

  • (String)
    the symbol value contained in the body. The value must be passed as AMQP value.

Raises:

  • (ArgumentError)

191
192
193
194
195
196
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 191

def body_as_symbol
  if !block_given?
    return @j_del.java_method(:bodyAsSymbol, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_as_symbol()"
end

- (true, false) body_null?

Returns whether the body is null. This method returns true is the message does not contain a body or if the message contain a null AMQP value as body.

Returns:

  • (true, false)
    whether the body is null. This method returns true is the message does not contain a body or if the message contain a null AMQP value as body.

Raises:

  • (ArgumentError)

114
115
116
117
118
119
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 114

def body_null?
  if !block_given?
    return @j_del.java_method(:isBodyNull, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling body_null?()"
end

- (String) content_encoding

Returns:

  • (String)

Raises:

  • (ArgumentError)

233
234
235
236
237
238
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 233

def content_encoding
  if !block_given?
    return @j_del.java_method(:contentEncoding, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling content_encoding()"
end

- (String) content_type

Returns:

  • (String)

Raises:

  • (ArgumentError)

226
227
228
229
230
231
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 226

def content_type
  if !block_given?
    return @j_del.java_method(:contentType, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling content_type()"
end

- (String) correlation_id

Returns The client-specific id that can be used to mark or identify messages between clients.

Returns:

  • (String)
    The client-specific id that can be used to mark or identify messages between clients.

Raises:

  • (ArgumentError)

107
108
109
110
111
112
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 107

def correlation_id
  if !block_given?
    return @j_del.java_method(:correlationId, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling correlation_id()"
end

- (Fixnum) creation_time

Returns:

  • (Fixnum)

Raises:

  • (ArgumentError)

247
248
249
250
251
252
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 247

def creation_time
  if !block_given?
    return @j_del.java_method(:creationTime, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling creation_time()"
end

- (Fixnum) delivery_count

Returns the number of unsuccessful previous attempts to deliver this message. If this value is non-zero it can be taken as an indication that the delivery might be a duplicate. On first delivery, the value is zero. It is incremented upon an outcome being settled at the sender, according to rules defined for each outcome.

Returns:

  • (Fixnum)
    the number of unsuccessful previous attempts to deliver this message. If this value is non-zero it can be taken as an indication that the delivery might be a duplicate. On first delivery, the value is zero. It is incremented upon an outcome being settled at the sender, according to rules defined for each outcome.

Raises:

  • (ArgumentError)

72
73
74
75
76
77
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 72

def delivery_count
  if !block_given?
    return @j_del.java_method(:deliveryCount, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling delivery_count()"
end

- (true, false) durable?

Returns whether or not the message is durable.

Returns:

  • (true, false)
    whether or not the message is durable.

Raises:

  • (ArgumentError)

51
52
53
54
55
56
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 51

def durable?
  if !block_given?
    return @j_del.java_method(:isDurable, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling durable?()"
end

- (Fixnum) expiry_time

Returns:

  • (Fixnum)

Raises:

  • (ArgumentError)

240
241
242
243
244
245
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 240

def expiry_time
  if !block_given?
    return @j_del.java_method(:expiryTime, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling expiry_time()"
end

- (true, false) first_acquirer?

Returns if true, then this message has not been acquired by any other link. If false, then this message MAY have previously been acquired by another link or links.

Returns:

  • (true, false)
    if true, then this message has not been acquired by any other link. If false, then this message MAY have previously been acquired by another link or links.

Raises:

  • (ArgumentError)

58
59
60
61
62
63
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 58

def first_acquirer?
  if !block_given?
    return @j_del.java_method(:isFirstAcquirer, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling first_acquirer?()"
end

- (String) group_id

Returns:

  • (String)

Raises:

  • (ArgumentError)

254
255
256
257
258
259
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 254

def group_id
  if !block_given?
    return @j_del.java_method(:groupId, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling group_id()"
end

- (Fixnum) group_sequence

Returns:

  • (Fixnum)

Raises:

  • (ArgumentError)

268
269
270
271
272
273
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 268

def group_sequence
  if !block_given?
    return @j_del.java_method(:groupSequence, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling group_sequence()"
end

- (String) id

Returns the message id

Returns:

  • (String)
    the message id

Raises:

  • (ArgumentError)

86
87
88
89
90
91
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 86

def id
  if !block_given?
    return @j_del.java_method(:id, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling id()"
end

- (self) modified(didItFail = nil, wasItDeliveredHere = nil)

When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as modified.

Parameters:

  • didItFail (true, false) (defaults to: nil)
    pass true to increase the failed delivery count
  • wasItDeliveredHere (true, false) (defaults to: nil)
    pass true to prevent the re-delivery of the message

Returns:

  • (self)

Raises:

  • (ArgumentError)

316
317
318
319
320
321
322
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 316

def modified(didItFail=nil,wasItDeliveredHere=nil)
  if (didItFail.class == TrueClass || didItFail.class == FalseClass) && (wasItDeliveredHere.class == TrueClass || wasItDeliveredHere.class == FalseClass) && !block_given?
    @j_del.java_method(:modified, [Java::boolean.java_class,Java::boolean.java_class]).call(didItFail,wasItDeliveredHere)
    return self
  end
  raise ArgumentError, "Invalid arguments when calling modified(#{didItFail},#{wasItDeliveredHere})"
end

- (Fixnum) priority

Returns the relative message priority. Higher numbers indicate higher priority messages. Messages with higher priorities MAY be delivered before those with lower priorities.

Returns:

  • (Fixnum)
    the relative message priority. Higher numbers indicate higher priority messages. Messages with higher priorities MAY be delivered before those with lower priorities.

Raises:

  • (ArgumentError)

65
66
67
68
69
70
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 65

def priority
  if !block_given?
    return @j_del.java_method(:priority, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling priority()"
end

- (self) rejected

When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as rejected.

Returns:

  • (self)

Raises:

  • (ArgumentError)

294
295
296
297
298
299
300
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 294

def rejected
  if !block_given?
    @j_del.java_method(:rejected, []).call()
    return self
  end
  raise ArgumentError, "Invalid arguments when calling rejected()"
end

- (self) released

When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge the incoming message as released.

Returns:

  • (self)

Raises:

  • (ArgumentError)

304
305
306
307
308
309
310
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 304

def released
  if !block_given?
    @j_del.java_method(:released, []).call()
    return self
  end
  raise ArgumentError, "Invalid arguments when calling released()"
end

- (String) reply_to

Returns The address of the node to send replies to, if any.

Returns:

  • (String)
    The address of the node to send replies to, if any.

Raises:

  • (ArgumentError)

100
101
102
103
104
105
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 100

def reply_to
  if !block_given?
    return @j_del.java_method(:replyTo, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling reply_to()"
end

- (String) reply_to_group_id

Returns:

  • (String)

Raises:

  • (ArgumentError)

261
262
263
264
265
266
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 261

def reply_to_group_id
  if !block_given?
    return @j_del.java_method(:replyToGroupId, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling reply_to_group_id()"
end

- (String) subject

Returns:

  • (String)

Raises:

  • (ArgumentError)

219
220
221
222
223
224
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 219

def subject
  if !block_given?
    return @j_del.java_method(:subject, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling subject()"
end

- (Fixnum) ttl

Returns the duration in milliseconds for which the message is to be considered "live".

Returns:

  • (Fixnum)
    the duration in milliseconds for which the message is to be considered "live".

Raises:

  • (ArgumentError)

79
80
81
82
83
84
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 79

def ttl
  if !block_given?
    return @j_del.java_method(:ttl, []).call()
  end
  raise ArgumentError, "Invalid arguments when calling ttl()"
end