AmqpConnection (Vert.x Stack - Docs 4.5.11 API)

java.lang.Object
- io.vertx.rxjava3.amqp.AmqpConnection

```
public class AmqpConnection
extends Object
```
Once connected to the broker or router, you get a connection. This connection is automatically opened.
NOTE: This class has been automatically generated from the original non RX-ified interface using Vert.x codegen.

Field Summary

Fields
Modifier and Type Field and Description

static io.vertx.lang.rx.TypeArg<AmqpConnection> __TYPE_ARG

Fields
Modifier and Type	Field and Description
`static io.vertx.lang.rx.TypeArg<AmqpConnection>`	`__TYPE_ARG`

Constructor Summary

Constructors
Constructor and Description

AmqpConnection(AmqpConnection delegate)

AmqpConnection(Object delegate)

Constructors
Constructor and Description
`AmqpConnection(AmqpConnection delegate)`
`AmqpConnection(Object delegate)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`Completable`	`close()` Closes the AMQP connection, i.e.
`Future<Void>`	`closeFuture()`
`Single<AmqpSender>`	`createAnonymousSender()` Creates an anonymous sender.
`Single<AmqpReceiver>`	`createDynamicReceiver()` Creates a dynamic receiver.
`Single<AmqpReceiver>`	`createReceiver(String address)` Creates a receiver used to consume messages from the given address.
`Single<AmqpReceiver>`	`createReceiver(String address, AmqpReceiverOptions receiverOptions)` Creates a receiver used to consumer messages from the given address.
`Single<AmqpSender>`	`createSender(String address)` Creates a sender used to send messages to the given address.
`Single<AmqpSender>`	`createSender(String address, AmqpSenderOptions options)` Creates a sender used to send messages to the given address.
`boolean`	`equals(Object o)`
`AmqpConnection`	`exceptionHandler(Handler<Throwable> handler)` Registers a handler called on disconnection.
`AmqpConnection`	`getDelegate()`
`int`	`hashCode()`
`boolean`	`isDisconnected()`
`static AmqpConnection`	`newInstance(AmqpConnection arg)`
`Completable`	`rxClose()` Closes the AMQP connection, i.e.
`Single<AmqpSender>`	`rxCreateAnonymousSender()` Creates an anonymous sender.
`Single<AmqpReceiver>`	`rxCreateDynamicReceiver()` Creates a dynamic receiver.
`Single<AmqpReceiver>`	`rxCreateReceiver(String address)` Creates a receiver used to consume messages from the given address.
`Single<AmqpReceiver>`	`rxCreateReceiver(String address, AmqpReceiverOptions receiverOptions)` Creates a receiver used to consumer messages from the given address.
`Single<AmqpSender>`	`rxCreateSender(String address)` Creates a sender used to send messages to the given address.
`Single<AmqpSender>`	`rxCreateSender(String address, AmqpSenderOptions options)` Creates a sender used to send messages to the given address.
`String`	`toString()`
`io.vertx.proton.ProtonConnection`	`unwrap()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

- Field Detail
  - __TYPE_ARG
```
public static final io.vertx.lang.rx.TypeArg<AmqpConnection> __TYPE_ARG
```
- Constructor Detail
  - AmqpConnection
```
public AmqpConnection(AmqpConnection delegate)
```
  - AmqpConnection
```
public AmqpConnection(Object delegate)
```
- Method Detail
  - toString
```
public String toString()
```
    Overrides:
    
    toString in class Object
  - equals
```
public boolean equals(Object o)
```
    Overrides:
    
    equals in class Object
  - hashCode
```
public int hashCode()
```
    Overrides:
    
    hashCode in class Object
  - getDelegate
```
public AmqpConnection getDelegate()
```
  - exceptionHandler
```
public AmqpConnection exceptionHandler(Handler<Throwable> handler)
```
    Registers a handler called on disconnection.
    
    Parameters:
    
    handler - the exception handler.
    
    Returns:
    
    the connection
  - close
```
public Completable close()
```
    Closes the AMQP connection, i.e. allows the Close frame to be emitted.
    
    Returns:
    
    the connection
  - rxClose
```
public Completable rxClose()
```
    Closes the AMQP connection, i.e. allows the Close frame to be emitted.
    
    Returns:
    
    the connection
  - createReceiver
```
public Single<AmqpReceiver> createReceiver(String address)
```
    Creates a receiver used to consume messages from the given address. The receiver has no handler and won't start receiving messages until a handler is explicitly configured.
    
    Parameters:
    
    address - The source address to attach the consumer to, must not be null
    
    Returns:
    
    the connection.
  - rxCreateReceiver
```
public Single<AmqpReceiver> rxCreateReceiver(String address)
```
    Creates a receiver used to consume messages from the given address. The receiver has no handler and won't start receiving messages until a handler is explicitly configured.
    
    Parameters:
    
    address - The source address to attach the consumer to, must not be null
    
    Returns:
    
    the connection.
  - createReceiver
```
public Single<AmqpReceiver> createReceiver(String address,
                                           AmqpReceiverOptions receiverOptions)
```
    Creates a receiver used to consumer messages from the given address.
    
    Parameters:
    
    address - The source address to attach the consumer to.
    
    receiverOptions - The options for this receiver.
    
    Returns:
    
    the connection.
  - rxCreateReceiver
```
public Single<AmqpReceiver> rxCreateReceiver(String address,
                                             AmqpReceiverOptions receiverOptions)
```
    Creates a receiver used to consumer messages from the given address.
    
    Parameters:
    
    address - The source address to attach the consumer to.
    
    receiverOptions - The options for this receiver.
    
    Returns:
    
    the connection.
  - createDynamicReceiver
```
public Single<AmqpReceiver> createDynamicReceiver()
```
    Creates a dynamic receiver. The address is provided by the broker and is available in the completionHandler, using the AmqpReceiver.address() method. this method is useful for request-reply to generate a unique reply address.
    
    Returns:
    
    the connection.
  - rxCreateDynamicReceiver
```
public Single<AmqpReceiver> rxCreateDynamicReceiver()
```
    Creates a dynamic receiver. The address is provided by the broker and is available in the completionHandler, using the AmqpReceiver.address() method. this method is useful for request-reply to generate a unique reply address.
    
    Returns:
    
    the connection.
  - createSender
```
public Single<AmqpSender> createSender(String address)
```
    Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
    
    Parameters:
    
    address - The target address to attach to, must not be null
    
    Returns:
    
    the connection.
  - rxCreateSender
```
public Single<AmqpSender> rxCreateSender(String address)
```
    Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
    
    Parameters:
    
    address - The target address to attach to, must not be null
    
    Returns:
    
    the connection.
  - createSender
```
public Single<AmqpSender> createSender(String address,
                                       AmqpSenderOptions options)
```
    Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
    
    Parameters:
    
    address - The target address to attach to, allowed to be null if the options configures the sender to be attached to a dynamic address (provided by the broker).
    
    options - The AMQP sender options
    
    Returns:
    
    the connection.
  - rxCreateSender
```
public Single<AmqpSender> rxCreateSender(String address,
                                         AmqpSenderOptions options)
```
    Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
    
    Parameters:
    
    address - The target address to attach to, allowed to be null if the options configures the sender to be attached to a dynamic address (provided by the broker).
    
    options - The AMQP sender options
    
    Returns:
    
    the connection.
  - createAnonymousSender
```
public Single<AmqpSender> createAnonymousSender()
```
    Creates an anonymous sender.
    Unlike "regular" sender, this sender is not associated to a specific address, and each message sent must provide an address. This method can be used in request-reply scenarios where you create a sender to send the reply, but you don't know the address, as the reply address is passed into the message you are going to receive.
    
    Returns:
    
    the connection.
  - rxCreateAnonymousSender
```
public Single<AmqpSender> rxCreateAnonymousSender()
```
    Creates an anonymous sender.
    Unlike "regular" sender, this sender is not associated to a specific address, and each message sent must provide an address. This method can be used in request-reply scenarios where you create a sender to send the reply, but you don't know the address, as the reply address is passed into the message you are going to receive.
    
    Returns:
    
    the connection.
  - isDisconnected
```
public boolean isDisconnected()
```
    Returns:
    
    whether the connection has been disconnected.
  - closeFuture
```
public Future<Void> closeFuture()
```
    Returns:
    
    a future completed when the connection is closed
  - unwrap
```
public io.vertx.proton.ProtonConnection unwrap()
```
    Returns:
    
    the underlying ProtonConnection.
  - newInstance
```
public static AmqpConnection newInstance(AmqpConnection arg)
```

Class AmqpConnection

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

__TYPE_ARG

Constructor Detail

AmqpConnection

AmqpConnection

Method Detail

toString

equals

hashCode

getDelegate

exceptionHandler

close

rxClose

createReceiver

rxCreateReceiver

createReceiver

rxCreateReceiver

createDynamicReceiver

rxCreateDynamicReceiver

createSender

rxCreateSender

createSender

rxCreateSender

createAnonymousSender

rxCreateAnonymousSender

isDisconnected

closeFuture

unwrap

newInstance