Package | Description |
---|---|
com.rabbitmq.client |
The client API proper: classes and interfaces representing the AMQP
connections, channels, and wire-protocol framing descriptors.
|
com.rabbitmq.client.impl |
Implementations of interfaces specified in the client API, and their supporting classes.
|
com.rabbitmq.client.impl.nio |
NIO network connector.
|
com.rabbitmq.client.impl.recovery |
Implementation of connection and topology recovery.
|
Modifier and Type | Class and Description |
---|---|
class |
ResolvedInetAddress |
Modifier and Type | Method and Description |
---|---|
static Address |
Address.parseAddress(String addressString)
Factory method: takes a formatted addressString string as construction parameter
|
static Address[] |
Address.parseAddresses(String addresses)
Array-based factory method: takes an array of formatted address strings as construction parameter
|
Modifier and Type | Method and Description |
---|---|
List<Address> |
AddressResolver.getAddresses()
Get the potential
Address es to connect to. |
List<Address> |
ListAddressResolver.getAddresses() |
List<Address> |
DnsRecordIpAddressResolver.getAddresses()
Get the IP addresses from a DNS query
|
List<Address> |
DnsSrvRecordAddressResolver.getAddresses() |
default List<Address> |
AddressResolver.maybeShuffle(List<Address> input)
Optionally shuffle the list of addresses returned by
AddressResolver.getAddresses() . |
Modifier and Type | Method and Description |
---|---|
Connection |
ConnectionFactory.newConnection(Address[] addrs)
Create a new broker connection, picking the first available address from
the list.
|
Connection |
ConnectionFactory.newConnection(Address[] addrs,
String clientProvidedName)
Create a new broker connection with a client-provided name, picking the first available address from
the list.
|
Connection |
ConnectionFactory.newConnection(ExecutorService executor,
Address[] addrs)
Create a new broker connection, picking the first available address from
the list.
|
Connection |
ConnectionFactory.newConnection(ExecutorService executor,
Address[] addrs,
String clientProvidedName)
Create a new broker connection with a client-provided name, picking the first available address from
the list.
|
Modifier and Type | Method and Description |
---|---|
protected AddressResolver |
ConnectionFactory.createAddressResolver(List<Address> addresses) |
default List<Address> |
AddressResolver.maybeShuffle(List<Address> input)
Optionally shuffle the list of addresses returned by
AddressResolver.getAddresses() . |
Connection |
ConnectionFactory.newConnection(ExecutorService executor,
List<Address> addrs)
Create a new broker connection, picking the first available address from
the list.
|
Connection |
ConnectionFactory.newConnection(ExecutorService executor,
List<Address> addrs,
String clientProvidedName)
Create a new broker connection with a client-provided name, picking the first available address from
the list.
|
Connection |
ConnectionFactory.newConnection(List<Address> addrs)
Create a new broker connection, picking the first available address from
the list.
|
Connection |
ConnectionFactory.newConnection(List<Address> addrs,
String clientProvidedName)
Create a new broker connection with a client-provided name, picking the first available address from
the list.
|
Constructor and Description |
---|
DnsRecordIpAddressResolver(Address address) |
DnsRecordIpAddressResolver(Address address,
boolean ssl) |
Constructor and Description |
---|
ListAddressResolver(List<Address> addresses) |
Modifier and Type | Method and Description |
---|---|
FrameHandler |
FrameHandlerFactory.create(Address addr,
String connectionName) |
FrameHandler |
SocketFrameHandlerFactory.create(Address addr,
String connectionName) |
Modifier and Type | Method and Description |
---|---|
FrameHandler |
SocketChannelFrameHandlerFactory.create(Address addr,
String connectionName) |
Constructor and Description |
---|
AutorecoveringConnection(ConnectionParams params,
FrameHandlerFactory f,
List<Address> addrs) |
RecoveryAwareAMQConnectionFactory(ConnectionParams params,
FrameHandlerFactory factory,
List<Address> addrs) |
Copyright © 2022 VMware, Inc. or its affiliates.. All rights reserved.