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)


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

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

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

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

Overloads:

Returns:



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

def self.create(*args)
  if !block_given? && args[0] == nil
    return ::Vertx::Util::Utils.safe_create(Java::IoVertxAmqp::AmqpMessage.java_method(:create, []).call(),::VertxAmqpClient::AmqpMessageBuilder)
  elsif args[0].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(args[0].j_del),::VertxAmqpClient::AmqpMessageBuilder)
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling create(#{args[0]})"
  end
end

+ (Object) j_api_type



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

def self.j_api_type
  @@j_api_type
end

+ (Object) j_class



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

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

+ (Object) unwrap(obj)



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

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

+ (Object) wrap(obj)



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

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)


396
397
398
399
400
401
402
403
404
405
406
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 396

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

- (String) address

Returns the message address, also named to field

Returns:

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


346
347
348
349
350
351
352
353
354
355
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 346

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

- (Hash{String => Object}) applicationProperties

Returns the message properties as JSON object.

Returns:

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


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

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
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling application_properties()"
  end
end

- (::Vertx::Buffer) bodyAsBinary

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.


481
482
483
484
485
486
487
488
489
490
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 481

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

- (true, false) bodyAsBoolean

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.


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

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

- (Fixnum) bodyAsByte

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.


433
434
435
436
437
438
439
440
441
442
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 433

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

- (Fixnum) bodyAsChar

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.


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

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

- (Float) bodyAsDouble

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.


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

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

- (Float) bodyAsFloat

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.


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

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

- (Fixnum) bodyAsInteger

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.


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

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

- (Array<String,Object>) bodyAsJsonArray

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.


310
311
312
313
314
315
316
317
318
319
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 310

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
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling body_as_json_array()"
  end
end

- (Hash{String => Object}) bodyAsJsonObject

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.


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

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
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling body_as_json_object()"
  end
end

- (Array<Object>) bodyAsList

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.


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

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
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling body_as_list()"
  end
end

- (Fixnum) bodyAsLong

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.


358
359
360
361
362
363
364
365
366
367
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 358

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

- (Fixnum) bodyAsShort

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.


409
410
411
412
413
414
415
416
417
418
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 409

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

- (String) bodyAsString

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.


334
335
336
337
338
339
340
341
342
343
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 334

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

- (String) bodyAsSymbol

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.


370
371
372
373
374
375
376
377
378
379
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 370

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

- (true, false) isBodyNull

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.


322
323
324
325
326
327
328
329
330
331
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 322

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

- (String) contentEncoding

Returns:

  • (String)


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

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

- (String) contentType

Returns:

  • (String)


271
272
273
274
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 271

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

- (String) correlationId

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.


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

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

- (Fixnum) creationTime

Returns:

  • (Fixnum)


54
55
56
57
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 54

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

- (Fixnum) deliveryCount

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.


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

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

- (true, false) isDurable

Returns whether or not the message is durable.

Returns:

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


421
422
423
424
425
426
427
428
429
430
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 421

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

- (Fixnum) expiryTime

Returns:

  • (Fixnum)


493
494
495
496
497
498
499
500
501
502
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 493

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

- (true, false) isFirstAcquirer

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.


469
470
471
472
473
474
475
476
477
478
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 469

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

- (String) groupId

Returns:

  • (String)


117
118
119
120
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 117

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

- (Fixnum) groupSequence

Returns:

  • (Fixnum)


382
383
384
385
386
387
388
389
390
391
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 382

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

- (String) id

Returns the message id

Returns:

  • (String)
    the message id


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

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

- (self) modified(didItFail, wasItDeliveredHere)

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)
    pass true to increase the failed delivery count
  • wasItDeliveredHere (true, false)
    pass true to prevent the re-delivery of the message

Returns:

  • (self)


157
158
159
160
161
162
163
164
165
166
167
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 157

def modified(*args)
  if (args[0].class == TrueClass || args[0].class == FalseClass) && (args[1].class == TrueClass || args[1].class == FalseClass) && !block_given?
    @j_del.java_method(:modified, [Java::boolean.java_class,Java::boolean.java_class]).call(args[0],args[1])
    return self
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling modified(#{args[0]},#{args[1]})"
  end
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.


445
446
447
448
449
450
451
452
453
454
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 445

def priority
  if !block_given?
    return @j_del.java_method(:priority, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling priority()"
  end
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)


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

def rejected
  if !block_given?
    @j_del.java_method(:rejected, []).call()
    return self
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling rejected()"
  end
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)


297
298
299
300
301
302
303
304
305
306
307
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 297

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

- (String) replyTo

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.


505
506
507
508
509
510
511
512
513
514
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 505

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

- (String) replyToGroupId

Returns:

  • (String)


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

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

- (String) subject

Returns:

  • (String)


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

def subject
  if !block_given?
    return @j_del.java_method(:subject, []).call()
  end
  if defined?(super)
    super
  else
    raise ArgumentError, "Invalid arguments when calling subject()"
  end
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".


457
458
459
460
461
462
463
464
465
466
# File '/Users/julien/java/vertx-aggregator/modules/vertx-lang-ruby/vertx-lang-ruby/target/classes/vertx-amqp-client/amqp_message.rb', line 457

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