From dc782e9bc46a4b720e7c36ed0a8c5576baeb944b Mon Sep 17 00:00:00 2001 From: sdelamo Date: Thu, 9 Nov 2023 09:04:58 +0000 Subject: [PATCH] Deploying to gh-pages - 09:04:58 --- snapshot/api/allclasses-index.html | 16 ++ snapshot/api/allpackages-index.html | 32 ++-- snapshot/api/constant-values.html | 13 ++ snapshot/api/element-list | 1 + snapshot/api/index-all.html | 40 ++++ snapshot/api/index.html | 32 ++-- .../rabbitmq/connect/package-summary.html | 13 +- ...lyDownConnection.EventuallyUpListener.html | 144 ++++++++++++++ .../recovery/TemporarilyDownConnection.html | 177 +++++++++++++++++ .../TemporarilyDownConnectionManager.html | 178 +++++++++++++++++ .../recovery/TemporarilyDownException.html | 180 ++++++++++++++++++ .../connect/recovery/package-summary.html | 115 +++++++++++ .../connect/recovery/package-tree.html | 100 ++++++++++ snapshot/api/member-search-index.js | 2 +- snapshot/api/overview-tree.html | 26 +++ snapshot/api/package-search-index.js | 2 +- snapshot/api/type-search-index.js | 2 +- snapshot/guide/configurationreference.html | 106 +++++------ 18 files changed, 1092 insertions(+), 87 deletions(-) create mode 100644 snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.EventuallyUpListener.html create mode 100644 snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.html create mode 100644 snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnectionManager.html create mode 100644 snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownException.html create mode 100644 snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-summary.html create mode 100644 snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-tree.html diff --git a/snapshot/api/allclasses-index.html b/snapshot/api/allclasses-index.html index 64bdf512e..5c8e88222 100644 --- a/snapshot/api/allclasses-index.html +++ b/snapshot/api/allclasses-index.html @@ -329,6 +329,22 @@

All Classes and Interfaces<
 
SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration
 
+
TemporarilyDownConnection
+
+
Represents a connection to RabbitMQ that is temporarily down.
+
+
TemporarilyDownConnection.EventuallyUpListener
+
+
Callback interface to perform any action when the connection is eventually up.
+
+
TemporarilyDownConnectionManager
+
+
Creates temporarily down RabbitMQ connections and checks periodically if they are eventually up.
+
+
TemporarilyDownException
+
+
Indicates that the connection is still down.
+
diff --git a/snapshot/api/allpackages-index.html b/snapshot/api/allpackages-index.html index 621404fb0..4dd3d01c6 100644 --- a/snapshot/api/allpackages-index.html +++ b/snapshot/api/allpackages-index.html @@ -66,36 +66,38 @@

All Packages

Classes handling the connection RabbitMQ.
-
io.micronaut.rabbitmq.event
+
io.micronaut.rabbitmq.connect.recovery
 
-
io.micronaut.rabbitmq.exception
-
+
io.micronaut.rabbitmq.event
+
 
+
io.micronaut.rabbitmq.exception
+
RabbitMQ specific exceptions.
-
io.micronaut.rabbitmq.executor
-
+
io.micronaut.rabbitmq.executor
+
Classes related to configuring the thread pool to run RabbitMQ consumers.
-
io.micronaut.rabbitmq.health
-
+
io.micronaut.rabbitmq.health
+
Classes related to performing health checks for RabbitMQ.
-
io.micronaut.rabbitmq.intercept
-
+
io.micronaut.rabbitmq.intercept
+
Contains the implementations of the Around advices for RabbitMQ consumer and producer methods.
-
io.micronaut.rabbitmq.metrics
-
+
io.micronaut.rabbitmq.metrics
+
Contains classes specific to capturing RabbitMQ metrics.
-
io.micronaut.rabbitmq.reactive
-
+
io.micronaut.rabbitmq.reactive
+
Contains classes specific to converting the RabbitMQ java client API to a reactive API.
-
io.micronaut.rabbitmq.serdes
-
+
io.micronaut.rabbitmq.serdes
+
Classes for serializing and deserializing RabbitMQ message bodies.
diff --git a/snapshot/api/constant-values.html b/snapshot/api/constant-values.html index d2f5f1783..5beda11a8 100644 --- a/snapshot/api/constant-values.html +++ b/snapshot/api/constant-values.html @@ -117,6 +117,19 @@

io.micronaut.*

+
diff --git a/snapshot/api/element-list b/snapshot/api/element-list index 245fe4960..2637617ab 100644 --- a/snapshot/api/element-list +++ b/snapshot/api/element-list @@ -1,6 +1,7 @@ io.micronaut.rabbitmq.annotation io.micronaut.rabbitmq.bind io.micronaut.rabbitmq.connect +io.micronaut.rabbitmq.connect.recovery io.micronaut.rabbitmq.event io.micronaut.rabbitmq.exception io.micronaut.rabbitmq.executor diff --git a/snapshot/api/index-all.html b/snapshot/api/index-all.html index 31e2b7f42..d45b9d8ad 100644 --- a/snapshot/api/index-all.html +++ b/snapshot/api/index-all.html @@ -91,6 +91,8 @@

A

Represents options for controlling the acknowledgment actions.
+
addEventuallyUpListener(TemporarilyDownConnection.EventuallyUpListener) - Method in interface io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnection
+
 
AddressTypeConverter - Class in io.micronaut.rabbitmq.connect
Converts a CharSequence to an Address.
@@ -159,6 +161,8 @@

C

ChannelPoolConfiguration() - Constructor for class io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig.ChannelPoolConfiguration
 
+
check() - Method in interface io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnection
+
 
close() - Method in class io.micronaut.rabbitmq.bind.RabbitMessageCloseable
 
close() - Method in class io.micronaut.rabbitmq.connect.DefaultChannelPool
@@ -263,6 +267,8 @@

D

E

+
ERROR_MESSAGE - Static variable in interface io.micronaut.rabbitmq.connect.recovery.TemporarilyDownException
+
 
exclusive() - Element in annotation interface io.micronaut.rabbitmq.annotation.Queue
 
executor() - Element in annotation interface io.micronaut.rabbitmq.annotation.Queue
@@ -343,6 +349,10 @@

G

 
getConfirmTimeout() - Method in class io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig
 
+
getConnection() - Method in interface io.micronaut.rabbitmq.connect.recovery.TemporarilyDownException
+
+
Returns the temporarily down connection that caused this exception.
+
getConsumerExecutor() - Method in class io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig
 
getContentEncoding() - Method in class io.micronaut.rabbitmq.intercept.MutableBasicProperties
@@ -473,6 +483,8 @@

I

Classes handling the connection RabbitMQ.
+
io.micronaut.rabbitmq.connect.recovery - package io.micronaut.rabbitmq.connect.recovery
+
 
io.micronaut.rabbitmq.event - package io.micronaut.rabbitmq.event
 
io.micronaut.rabbitmq.exception - package io.micronaut.rabbitmq.exception
@@ -505,6 +517,8 @@

I

Classes for serializing and deserializing RabbitMQ message bodies.
+
isStillDown() - Method in interface io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnection
+
 
isTopologyRecoveryEnabled() - Method in interface io.micronaut.rabbitmq.connect.ChannelPool
Returns whether topology recovery @@ -567,6 +581,10 @@

N

names() - Method in class io.micronaut.rabbitmq.bind.RabbitHeaderConvertibleValues
 
+
newConnection(RabbitConnectionFactoryConfig, ExecutorService) - Method in class io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnectionManager
+
+
Creates a new temporarily down RabbitMQ connection.
+
NONE - Enum constant in enum class io.micronaut.rabbitmq.bind.AcknowledgmentAction
The acknowledgment action is going to be skipped.
@@ -580,6 +598,10 @@

N

O

+
onConnectionInitialized(TemporarilyDownConnection) - Method in interface io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnection.EventuallyUpListener
+
+
Reacts to a connection that is eventually up.
+
onCreated(BeanCreatedEvent<ConnectionFactory>) - Method in class io.micronaut.rabbitmq.metrics.RabbitMetricsInterceptor
 
onCreated(BeanCreatedEvent<ChannelPool>) - Method in class io.micronaut.rabbitmq.connect.ChannelInitializer
@@ -1107,6 +1129,24 @@

S

T

+
TemporarilyDownConnection - Interface in io.micronaut.rabbitmq.connect.recovery
+
+
Represents a connection to RabbitMQ that is temporarily down.
+
+
TemporarilyDownConnection.EventuallyUpListener - Interface in io.micronaut.rabbitmq.connect.recovery
+
+
Callback interface to perform any action when the connection is eventually up.
+
+
TemporarilyDownConnectionManager - Class in io.micronaut.rabbitmq.connect.recovery
+
+
Creates temporarily down RabbitMQ connections and checks periodically if they are eventually up.
+
+
TemporarilyDownConnectionManager() - Constructor for class io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnectionManager
+
 
+
TemporarilyDownException - Interface in io.micronaut.rabbitmq.connect.recovery
+
+
Indicates that the connection is still down.
+
toBasicProperties() - Method in class io.micronaut.rabbitmq.intercept.MutableBasicProperties
Converts the mutable properties to the RabbitMQ properties.
diff --git a/snapshot/api/index.html b/snapshot/api/index.html index cc10705c0..34720c653 100644 --- a/snapshot/api/index.html +++ b/snapshot/api/index.html @@ -67,36 +67,38 @@

rabbitmq-parent 4.2.0-SNAPSHOT API

Classes handling the connection RabbitMQ.
-
io.micronaut.rabbitmq.event
+
io.micronaut.rabbitmq.connect.recovery
 
-
io.micronaut.rabbitmq.exception
-
+
io.micronaut.rabbitmq.event
+
 
+
io.micronaut.rabbitmq.exception
+
RabbitMQ specific exceptions.
-
io.micronaut.rabbitmq.executor
-
+
io.micronaut.rabbitmq.executor
+
Classes related to configuring the thread pool to run RabbitMQ consumers.
-
io.micronaut.rabbitmq.health
-
+
io.micronaut.rabbitmq.health
+
Classes related to performing health checks for RabbitMQ.
-
io.micronaut.rabbitmq.intercept
-
+
io.micronaut.rabbitmq.intercept
+
Contains the implementations of the Around advices for RabbitMQ consumer and producer methods.
-
io.micronaut.rabbitmq.metrics
-
+
io.micronaut.rabbitmq.metrics
+
Contains classes specific to capturing RabbitMQ metrics.
-
io.micronaut.rabbitmq.reactive
-
+
io.micronaut.rabbitmq.reactive
+
Contains classes specific to converting the RabbitMQ java client API to a reactive API.
-
io.micronaut.rabbitmq.serdes
-
+
io.micronaut.rabbitmq.serdes
+
Classes for serializing and deserializing RabbitMQ message bodies.
diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/package-summary.html b/snapshot/api/io/micronaut/rabbitmq/connect/package-summary.html index 18fd57293..60af63e23 100644 --- a/snapshot/api/io/micronaut/rabbitmq/connect/package-summary.html +++ b/snapshot/api/io/micronaut/rabbitmq/connect/package-summary.html @@ -45,7 +45,7 @@
@@ -76,6 +76,17 @@

Package io.micro
  • + +
    • +
  • diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.EventuallyUpListener.html b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.EventuallyUpListener.html new file mode 100644 index 000000000..1546cc47e --- /dev/null +++ b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.EventuallyUpListener.html @@ -0,0 +1,144 @@ + + + + +TemporarilyDownConnection.EventuallyUpListener (rabbitmq-parent 4.2.0-SNAPSHOT API) + + + + + + + + + + + + + + +
    + +
    +
    + +
    +
    Package io.micronaut.rabbitmq.connect.recovery
    +

    Interface TemporarilyDownConnection.EventuallyUpListener

    +
    +
    +
    +
    Enclosing interface:
    +
    TemporarilyDownConnection
    +
    +
    +
    Functional Interface:
    +
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    +
    +
    +
    @FunctionalInterface +public static interface TemporarilyDownConnection.EventuallyUpListener
    +
    Callback interface to perform any action when the connection is eventually up.
    +
    +
    +
      + +
    • +
      +

      Method Summary

      +
      +
      +
      +
      +
      Modifier and Type
      +
      Method
      +
      Description
      +
      void
      +
      onConnectionInitialized(TemporarilyDownConnection connection)
      +
      +
      Reacts to a connection that is eventually up.
      +
      +
      +
      +
      +
      +
      • +
    +
    +
    +
      + +
    • +
      +

      Method Details

      +
        +
      • +
        +

        onConnectionInitialized

        +
        void onConnectionInitialized(TemporarilyDownConnection connection) + throws Exception
        +
        Reacts to a connection that is eventually up.
        +
        +
        Parameters:
        +
        connection - The connection that was temporarily down.
        +
        Throws:
        +
        Exception - if unable to perform the action (the exception will be ignored).
        +
        +
        +
        • +
      +
      +
      • +
    +
    + +
    +
    +
    + + diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.html b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.html new file mode 100644 index 000000000..c7f01cba1 --- /dev/null +++ b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnection.html @@ -0,0 +1,177 @@ + + + + +TemporarilyDownConnection (rabbitmq-parent 4.2.0-SNAPSHOT API) + + + + + + + + + + + + + + +
    + +
    +
    + +
    +
    Package io.micronaut.rabbitmq.connect.recovery
    +

    Interface TemporarilyDownConnection

    +
    +
    +
    +
    All Superinterfaces:
    +
    AutoCloseable, Closeable, com.rabbitmq.client.Connection, com.rabbitmq.client.ShutdownNotifier
    +
    +
    +
    public interface TemporarilyDownConnection +extends com.rabbitmq.client.Connection
    +
    Represents a connection to RabbitMQ that is temporarily down.
    +
    +
    Since:
    +
    4.1.0
    +
    Author:
    +
    Guillermo Calvo
    +
    +
    +
    +
      + +
    • +
      +

      Nested Class Summary

      +
      Nested Classes
      +
      +
      Modifier and Type
      +
      Interface
      +
      Description
      +
      static interface 
      +
      TemporarilyDownConnection.EventuallyUpListener
      +
      +
      Callback interface to perform any action when the connection is eventually up.
      +
      +
      +
      +
      • + +
    • +
      +

      Method Summary

      +
      +
      +
      +
      +
      Modifier and Type
      +
      Method
      +
      Description
      +
      void
      +
      addEventuallyUpListener(TemporarilyDownConnection.EventuallyUpListener listener)
      +
       
      +
      boolean
      +
      check()
      +
       
      +
      boolean
      +
      isStillDown()
      +
       
      +
      +
      +
      +
      +

      Methods inherited from interface com.rabbitmq.client.Connection

      +abort, abort, abort, abort, addBlockedListener, addBlockedListener, clearBlockedListeners, close, close, close, close, createChannel, createChannel, getAddress, getChannelMax, getClientProperties, getClientProvidedName, getExceptionHandler, getFrameMax, getHeartbeat, getId, getPort, getServerProperties, openChannel, openChannel, removeBlockedListener, setId
      +
      +

      Methods inherited from interface com.rabbitmq.client.ShutdownNotifier

      +addShutdownListener, getCloseReason, isOpen, notifyListeners, removeShutdownListener
      +
      +
      • +
    +
    +
    +
      + +
    • +
      +

      Method Details

      + +
      +
      • +
    +
    + +
    +
    +
    + + diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnectionManager.html b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnectionManager.html new file mode 100644 index 000000000..9463edda9 --- /dev/null +++ b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownConnectionManager.html @@ -0,0 +1,178 @@ + + + + +TemporarilyDownConnectionManager (rabbitmq-parent 4.2.0-SNAPSHOT API) + + + + + + + + + + + + + + +
    + +
    +
    + +
    +
    Package io.micronaut.rabbitmq.connect.recovery
    +

    Class TemporarilyDownConnectionManager

    +
    +
    java.lang.Object +
    io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnectionManager
    +
    +
    +
    +
    @Singleton +public class TemporarilyDownConnectionManager +extends Object
    +
    Creates temporarily down RabbitMQ connections and checks periodically if they are eventually up.
    +
    +
    Since:
    +
    4.1.0
    +
    Author:
    +
    Guillermo Calvo
    +
    +
    +
    + +
    +
    +
      + +
    • +
      +

      Constructor Details

      +
        +
      • +
        +

        TemporarilyDownConnectionManager

        +
        public TemporarilyDownConnectionManager()
        +
        +
        • +
      +
      +
      • + +
    • +
      +

      Method Details

      + +
      +
      • +
    +
    + +
    +
    +
    + + diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownException.html b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownException.html new file mode 100644 index 000000000..8e2cbba2d --- /dev/null +++ b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/TemporarilyDownException.html @@ -0,0 +1,180 @@ + + + + +TemporarilyDownException (rabbitmq-parent 4.2.0-SNAPSHOT API) + + + + + + + + + + + + + + +
    + +
    +
    + +
    +
    Package io.micronaut.rabbitmq.connect.recovery
    +

    Interface TemporarilyDownException

    +
    +
    +
    +
    Functional Interface:
    +
    This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
    +
    +
    +
    @FunctionalInterface +public interface TemporarilyDownException
    +
    Indicates that the connection is still down.
    +
    +
    Since:
    +
    4.1.0
    +
    Author:
    +
    Guillermo Calvo
    +
    +
    +
    +
      + +
    • +
      +

      Field Summary

      +
      Fields
      +
      +
      Modifier and Type
      +
      Field
      +
      Description
      +
      static final String
      +
      ERROR_MESSAGE
      +
       
      +
      +
      +
      • + +
    • +
      +

      Method Summary

      +
      +
      +
      +
      +
      Modifier and Type
      +
      Method
      +
      Description
      +
      TemporarilyDownConnection
      +
      getConnection()
      +
      +
      Returns the temporarily down connection that caused this exception.
      +
      +
      +
      +
      +
      +
      • +
    +
    +
    +
      + +
    • +
      +

      Field Details

      + +
      +
      • + +
    • +
      +

      Method Details

      +
        +
      • +
        +

        getConnection

        +
        TemporarilyDownConnection getConnection()
        +
        Returns the temporarily down connection that caused this exception.
        +
        +
        Returns:
        +
        the temporarily down connection that caused this exception.
        +
        +
        +
        • +
      +
      +
      • +
    +
    + +
    +
    +
    + + diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-summary.html b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-summary.html new file mode 100644 index 000000000..55c8817c9 --- /dev/null +++ b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-summary.html @@ -0,0 +1,115 @@ + + + + +io.micronaut.rabbitmq.connect.recovery (rabbitmq-parent 4.2.0-SNAPSHOT API) + + + + + + + + + + + + + + +
    + +
    +
    +
    +

    Package io.micronaut.rabbitmq.connect.recovery

    +
    +
    +
    package io.micronaut.rabbitmq.connect.recovery
    +
    + +
    +
    +
    +
    + + diff --git a/snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-tree.html b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-tree.html new file mode 100644 index 000000000..c66044e26 --- /dev/null +++ b/snapshot/api/io/micronaut/rabbitmq/connect/recovery/package-tree.html @@ -0,0 +1,100 @@ + + + + +io.micronaut.rabbitmq.connect.recovery Class Hierarchy (rabbitmq-parent 4.2.0-SNAPSHOT API) + + + + + + + + + + + + + + +
    + +
    +
    +
    +

    Hierarchy For Package io.micronaut.rabbitmq.connect.recovery

    +Package Hierarchies: + +
    +
    +

    Class Hierarchy

    + +
    +
    +

    Interface Hierarchy

    + +
    +
    +
    +
    + + diff --git a/snapshot/api/member-search-index.js b/snapshot/api/member-search-index.js index 0b5277f81..bb7a9d6d1 100644 --- a/snapshot/api/member-search-index.js +++ b/snapshot/api/member-search-index.js @@ -1 +1 @@ -memberSearchIndex = [{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitConsumerEvent","l":"AbstractRabbitConsumerEvent(Object, String, String)","u":"%3Cinit%3E(java.lang.Object,java.lang.String,java.lang.String)"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitEvent","l":"AbstractRabbitEvent(T)","u":"%3Cinit%3E(T)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"ACK"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"ACK"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"ack()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"ack(boolean)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgementBinder","l":"AcknowledgementBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"AddressTypeConverter","l":"AddressTypeConverter()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgementBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgementBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBasicPropertiesBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitChannelBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitEnvelopeBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"autoAcknowledgment()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBasicPropertiesBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitChannelBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitEnvelopeBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBodyBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitDefaultBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeadersBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgementBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelInitializer","l":"ChannelInitializer()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration","l":"ChannelPoolConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"close()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"close()"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"close()"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"ClusterRabbitConnectionFactoryConfig(String)","u":"%3Cinit%3E(java.lang.String)"},{"p":"io.micronaut.rabbitmq.annotation","c":"Binding","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitClient","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitConnection","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitListener","l":"connection()"},{"p":"io.micronaut.rabbitmq.connect","c":"AddressTypeConverter","l":"convert(CharSequence, Class
    , ConversionContext)","u":"convert(java.lang.CharSequence,java.lang.Class,io.micronaut.core.convert.ConversionContext)"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"createChannel()"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"createConsumer(Channel, RabbitPublishState, String, MonoSink)","u":"createConsumer(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState,java.lang.String,reactor.core.publisher.MonoSink)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"createListener(Channel, MonoSink, RabbitPublishState)","u":"createListener(com.rabbitmq.client.Channel,reactor.core.publisher.MonoSink,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitConnection","l":"DEFAULT_CONNECTION"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"DEFAULT_NAME"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"DEFAULT_RECOVERY_DELAY"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"DEFAULT_TIMEOUT_SECONDS"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"DefaultChannelPool(String, Connection, RabbitConnectionFactoryConfig)","u":"%3Cinit%3E(java.lang.String,com.rabbitmq.client.Connection,io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration","l":"DefaultChannelPoolConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration","l":"DefaultChannelPoolConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.exception","c":"DefaultRabbitListenerExceptionHandler","l":"DefaultRabbitListenerExceptionHandler()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"DefaultRabbitMessageSerDesRegistry","l":"DefaultRabbitMessageSerDesRegistry(RabbitMessageSerDes...)","u":"%3Cinit%3E(io.micronaut.rabbitmq.serdes.RabbitMessageSerDes...)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration","l":"DefaultRpcConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration","l":"DefaultRpcConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"deserialize(RabbitConsumerState, Argument)","u":"deserialize(io.micronaut.rabbitmq.bind.RabbitConsumerState,io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"deserialize(RabbitConsumerState, Argument)","u":"deserialize(io.micronaut.rabbitmq.bind.RabbitConsumerState,io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDes","l":"deserialize(RabbitConsumerState, Argument)","u":"deserialize(io.micronaut.rabbitmq.bind.RabbitConsumerState,io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"exclusive()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"executor()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitConnection","l":"executor()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitListener","l":"executor()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBinderRegistry","l":"findArgumentBinder(Argument)","u":"findArgumentBinder(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"findSerDes(Argument)","u":"findSerDes(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"DefaultRabbitMessageSerDesRegistry","l":"findSerdes(Argument)","u":"findSerdes(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDesRegistry","l":"findSerdes(Argument)","u":"findSerdes(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"get(CharSequence, ArgumentConversionContext)","u":"get(java.lang.CharSequence,io.micronaut.core.convert.ArgumentConversionContext)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getAddresses()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBodyBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeadersBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getAppId()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getBody()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getBody()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getBooleanSerDes()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getByteArraySerDes()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getByteBufferSerDes()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getChannelPool()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"getChannelWithRecoveringDelay(int)"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"getChannelWithRecoveringDelay(int)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getClusterId()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getConfirmTimeout()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getConsumerExecutor()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getContentEncoding()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getContentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"getConversionErrors()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getCorrelationId()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getDeliveryMode()"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"getDetails(Connection)","u":"getDetails(com.rabbitmq.client.Connection)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getDoubleSerDes()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getEnvelope()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getExchange()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getExpiration()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"getFailures()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getFloatSerDes()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getHeaders()"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"getHealthInformation()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getIntegerSerDes()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"getListener()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getLongSerDes()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getMandatory()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration","l":"getMaxIdleChannels()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getMessageId()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"getMessageState()"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitConsumerEvent","l":"getMethod()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"getName()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getName()"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"getName()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getOrder()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"getOrder()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getPriority()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getProperties()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getProperties()"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitConsumerEvent","l":"getQueue()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getReplyTo()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getRoutingKey()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getRpc()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getShortSerDes()"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitEvent","l":"getSource()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getStringSerDes()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"getTimeout()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getTimestamp()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getType()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getUserId()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getUUIDSerDes()"},{"p":"io.micronaut.rabbitmq.exception","c":"DefaultRabbitListenerExceptionHandler","l":"handle(RabbitListenerException)","u":"handle(io.micronaut.rabbitmq.exception.RabbitListenerException)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleCancel(String)","u":"handleCancel(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleCancelOk(String)","u":"handleCancelOk(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleConsumeOk(String)","u":"handleConsumeOk(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleRecoverOk(String)","u":"handleRecoverOk(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleShutdownSignal(String, ShutdownSignalException)","u":"handleShutdownSignal(java.lang.String,com.rabbitmq.client.ShutdownSignalException)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleTerminate(String)","u":"handleTerminate(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelInitializer","l":"initialize(Channel, String)","u":"initialize(com.rabbitmq.client.Channel,java.lang.String)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"initializePublish(Channel)","u":"initializePublish(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQIntroductionAdvice","l":"intercept(MethodInvocationContext)","u":"intercept(io.micronaut.aop.MethodInvocationContext)"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"isTopologyRecoveryEnabled()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"isTopologyRecoveryEnabled()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"JavaLangRabbitMessageSerDes()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"javaSerDes"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"JsonRabbitMessageSerDes(JsonMapper)","u":"%3Cinit%3E(io.micronaut.json.JsonMapper)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"MutableBasicProperties()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"NACK"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"NACK"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"nack()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"nack(boolean, boolean)","u":"nack(boolean,boolean)"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperty","l":"name()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"names()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"NONE"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"NONE"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"numberOfConsumers()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"numberOfConsumersValue()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelInitializer","l":"onCreated(BeanCreatedEvent)","u":"onCreated(io.micronaut.context.event.BeanCreatedEvent)"},{"p":"io.micronaut.rabbitmq.metrics","c":"RabbitMetricsInterceptor","l":"onCreated(BeanCreatedEvent)","u":"onCreated(io.micronaut.context.event.BeanCreatedEvent)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactory","l":"onPreDestroy(BeanPreDestroyEvent)","u":"onPreDestroy(io.micronaut.context.event.BeanPreDestroyEvent)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"ORDER"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"ORDER"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"prefetch()"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"PREFIX"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"process(BeanDefinition, ExecutableMethod)","u":"process(io.micronaut.inject.BeanDefinition,io.micronaut.inject.ExecutableMethod)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactivePublisher","l":"publish(RabbitPublishState)","u":"publish(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publish(RabbitPublishState)","u":"publish(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactivePublisher","l":"publishAndConfirm(RabbitPublishState)","u":"publishAndConfirm(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishAndConfirm(RabbitPublishState)","u":"publishAndConfirm(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactivePublisher","l":"publishAndReply(RabbitPublishState)","u":"publishAndReply(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishAndReply(RabbitPublishState)","u":"publishAndReply(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishInternal(Channel, RabbitPublishState)","u":"publishInternal(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishInternalNoConfirm(Channel, RabbitPublishState)","u":"publishInternalNoConfirm(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishRpcInternal(Channel, RabbitPublishState)","u":"publishRpcInternal(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgementBinder","l":"RabbitAcknowledgementBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBasicPropertiesBinder","l":"RabbitBasicPropertiesBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBinderRegistry","l":"RabbitBinderRegistry(RabbitDefaultBinder, RabbitArgumentBinder...)","u":"%3Cinit%3E(io.micronaut.rabbitmq.bind.RabbitDefaultBinder,io.micronaut.rabbitmq.bind.RabbitArgumentBinder...)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBodyBinder","l":"RabbitBodyBinder(RabbitMessageSerDesRegistry)","u":"%3Cinit%3E(io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitChannelBinder","l":"RabbitChannelBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String)","u":"%3Cinit%3E(java.lang.String)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String, List)","u":"%3Cinit%3E(java.lang.String,java.util.List)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String, Throwable)","u":"%3Cinit%3E(java.lang.String,java.lang.Throwable)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String, Throwable, List)","u":"%3Cinit%3E(java.lang.String,java.lang.Throwable,java.util.List)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactory","l":"RabbitConnectionFactory()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"RabbitConnectionFactoryConfig(String)","u":"%3Cinit%3E(java.lang.String)"},{"p":"io.micronaut.rabbitmq.executor","c":"RabbitConsumerExecutorFactory","l":"RabbitConsumerExecutorFactory()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.event","c":"RabbitConsumerStarted","l":"RabbitConsumerStarted(Object, String, String)","u":"%3Cinit%3E(java.lang.Object,java.lang.String,java.lang.String)"},{"p":"io.micronaut.rabbitmq.event","c":"RabbitConsumerStarting","l":"RabbitConsumerStarting(Object, String, String)","u":"%3Cinit%3E(java.lang.Object,java.lang.String,java.lang.String)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"RabbitConsumerState(Envelope, AMQP.BasicProperties, byte[], Channel)","u":"%3Cinit%3E(com.rabbitmq.client.Envelope,com.rabbitmq.client.AMQP.BasicProperties,byte[],com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitDefaultBinder","l":"RabbitDefaultBinder(RabbitPropertyBinder, RabbitBodyBinder)","u":"%3Cinit%3E(io.micronaut.rabbitmq.bind.RabbitPropertyBinder,io.micronaut.rabbitmq.bind.RabbitBodyBinder)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitEnvelopeBinder","l":"RabbitEnvelopeBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderBinder","l":"RabbitHeaderBinder(ConversionService)","u":"%3Cinit%3E(io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"RabbitHeaderConvertibleValues(Map, ConversionService)","u":"%3Cinit%3E(java.util.Map,io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeadersBinder","l":"RabbitHeadersBinder(ConversionService)","u":"%3Cinit%3E(io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"RabbitListenerException(String, Object, RabbitConsumerState)","u":"%3Cinit%3E(java.lang.String,java.lang.Object,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"RabbitListenerException(String, Throwable, Object, RabbitConsumerState)","u":"%3Cinit%3E(java.lang.String,java.lang.Throwable,java.lang.Object,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"RabbitListenerException(Throwable, Object, RabbitConsumerState)","u":"%3Cinit%3E(java.lang.Throwable,java.lang.Object,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"RabbitMessageCloseable(RabbitConsumerState, boolean, boolean)","u":"%3Cinit%3E(io.micronaut.rabbitmq.bind.RabbitConsumerState,boolean,boolean)"},{"p":"io.micronaut.rabbitmq.metrics","c":"RabbitMetricsInterceptor","l":"RabbitMetricsInterceptor(BeanProvider, String, Map)","u":"%3Cinit%3E(io.micronaut.context.BeanProvider,java.lang.String,java.util.Map)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"RabbitMQConsumerAdvice(BeanContext, ApplicationEventPublisher, ApplicationEventPublisher, RabbitBinderRegistry, RabbitListenerExceptionHandler, RabbitMessageSerDesRegistry, ConversionService, List)","u":"%3Cinit%3E(io.micronaut.context.BeanContext,io.micronaut.context.event.ApplicationEventPublisher,io.micronaut.context.event.ApplicationEventPublisher,io.micronaut.rabbitmq.bind.RabbitBinderRegistry,io.micronaut.rabbitmq.exception.RabbitListenerExceptionHandler,io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry,io.micronaut.core.convert.ConversionService,java.util.List)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"RabbitMQConsumerAdvice(BeanContext, RabbitBinderRegistry, RabbitListenerExceptionHandler, RabbitMessageSerDesRegistry, ConversionService, List)","u":"%3Cinit%3E(io.micronaut.context.BeanContext,io.micronaut.rabbitmq.bind.RabbitBinderRegistry,io.micronaut.rabbitmq.exception.RabbitListenerExceptionHandler,io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry,io.micronaut.core.convert.ConversionService,java.util.List)"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"RabbitMQHealthIndicator(Connection)","u":"%3Cinit%3E(com.rabbitmq.client.Connection)"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"RabbitMQHealthIndicator(List)","u":"%3Cinit%3E(java.util.List)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQIntroductionAdvice","l":"RabbitMQIntroductionAdvice(BeanContext, ConversionService, RabbitMessageSerDesRegistry, ExecutorService)","u":"%3Cinit%3E(io.micronaut.context.BeanContext,io.micronaut.core.convert.ConversionService,io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry,java.util.concurrent.ExecutorService)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"RabbitPropertyBinder(ConversionService)","u":"%3Cinit%3E(io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"RabbitPublishState(String, String, AMQP.BasicProperties, byte[])","u":"%3Cinit%3E(java.lang.String,java.lang.String,com.rabbitmq.client.AMQP.BasicProperties,byte[])"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"RabbitPublishState(String, String, boolean, AMQP.BasicProperties, byte[])","u":"%3Cinit%3E(java.lang.String,java.lang.String,boolean,com.rabbitmq.client.AMQP.BasicProperties,byte[])"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"ReactorReactivePublisher(ChannelPool, RabbitConnectionFactoryConfig)","u":"%3Cinit%3E(io.micronaut.rabbitmq.connect.ChannelPool,io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig)"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"reQueue()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"returnChannel(Channel)","u":"returnChannel(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"returnChannel(Channel)","u":"returnChannel(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"returnChannel(Channel)","u":"returnChannel(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"RpcConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"serialize(Object, MutableBasicProperties)","u":"serialize(java.lang.Object,io.micronaut.rabbitmq.intercept.MutableBasicProperties)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"serialize(Object, MutableBasicProperties)","u":"serialize(java.lang.Object,io.micronaut.rabbitmq.intercept.MutableBasicProperties)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDes","l":"serialize(T, MutableBasicProperties)","u":"serialize(T,io.micronaut.rabbitmq.intercept.MutableBasicProperties)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setAddresses(List
    )","u":"setAddresses(java.util.List)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setAppId(String)","u":"setAppId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"setChannelPool(ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)","u":"setChannelPool(io.micronaut.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setChannelPool(RabbitConnectionFactoryConfig.ChannelPoolConfiguration)","u":"setChannelPool(io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig.ChannelPoolConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"setChannelPool(SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)","u":"setChannelPool(io.micronaut.rabbitmq.connect.SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setClusterId(String)","u":"setClusterId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setConfirmTimeout(Duration)","u":"setConfirmTimeout(java.time.Duration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setConsumerExecutor(String)","u":"setConsumerExecutor(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setContentEncoding(String)","u":"setContentEncoding(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setContentType(String)","u":"setContentType(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setCorrelationId(String)","u":"setCorrelationId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setDeliveryMode(Integer)","u":"setDeliveryMode(java.lang.Integer)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setExpiration(String)","u":"setExpiration(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setHeaders(Map)","u":"setHeaders(java.util.Map)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration","l":"setMaxIdleChannels(Integer)","u":"setMaxIdleChannels(java.lang.Integer)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setMessageId(String)","u":"setMessageId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setPriority(Integer)","u":"setPriority(java.lang.Integer)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setReplyTo(String)","u":"setReplyTo(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"setRpc(ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration)","u":"setRpc(io.micronaut.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setRpc(RabbitConnectionFactoryConfig.RpcConfiguration)","u":"setRpc(io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"setRpc(SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration)","u":"setRpc(io.micronaut.rabbitmq.connect.SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"setTimeout(Duration)","u":"setTimeout(java.time.Duration)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setTimestamp(Date)","u":"setTimestamp(java.util.Date)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setType(String)","u":"setType(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setUserId(String)","u":"setUserId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"SingleRabbitConnectionFactoryConfig()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"supports(Argument)","u":"supports(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"supports(Argument)","u":"supports(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDes","l":"supports(Argument)","u":"supports(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"supports(ArgumentConversionContext)","u":"supports(io.micronaut.core.convert.ArgumentConversionContext)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"toBasicProperties()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperty","l":"type()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Binding","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Mandatory","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitClient","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperties","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperty","l":"value()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"valueOf(String)","u":"valueOf(java.lang.String)"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"valueOf(String)","u":"valueOf(java.lang.String)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"values()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"values()"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"values()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"withAcknowledge(Boolean)","u":"withAcknowledge(java.lang.Boolean)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"withAcknowledgmentAction(AcknowledgmentAction)","u":"withAcknowledgmentAction(io.micronaut.rabbitmq.bind.AcknowledgmentAction)"}];updateSearchResults(); \ No newline at end of file +memberSearchIndex = [{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitConsumerEvent","l":"AbstractRabbitConsumerEvent(Object, String, String)","u":"%3Cinit%3E(java.lang.Object,java.lang.String,java.lang.String)"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitEvent","l":"AbstractRabbitEvent(T)","u":"%3Cinit%3E(T)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"ACK"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"ACK"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"ack()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"ack(boolean)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgementBinder","l":"AcknowledgementBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownConnection","l":"addEventuallyUpListener(TemporarilyDownConnection.EventuallyUpListener)","u":"addEventuallyUpListener(io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnection.EventuallyUpListener)"},{"p":"io.micronaut.rabbitmq.connect","c":"AddressTypeConverter","l":"AddressTypeConverter()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgementBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgementBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBasicPropertiesBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitChannelBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitEnvelopeBinder","l":"argumentType()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"autoAcknowledgment()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBasicPropertiesBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitChannelBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitEnvelopeBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBodyBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitDefaultBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeadersBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgementBinder","l":"bind(ArgumentConversionContext, RabbitConsumerState)","u":"bind(io.micronaut.core.convert.ArgumentConversionContext,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelInitializer","l":"ChannelInitializer()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration","l":"ChannelPoolConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownConnection","l":"check()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"close()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"close()"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"close()"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"ClusterRabbitConnectionFactoryConfig(String)","u":"%3Cinit%3E(java.lang.String)"},{"p":"io.micronaut.rabbitmq.annotation","c":"Binding","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitClient","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitConnection","l":"connection()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitListener","l":"connection()"},{"p":"io.micronaut.rabbitmq.connect","c":"AddressTypeConverter","l":"convert(CharSequence, Class
    , ConversionContext)","u":"convert(java.lang.CharSequence,java.lang.Class,io.micronaut.core.convert.ConversionContext)"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"createChannel()"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"createConsumer(Channel, RabbitPublishState, String, MonoSink)","u":"createConsumer(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState,java.lang.String,reactor.core.publisher.MonoSink)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"createListener(Channel, MonoSink, RabbitPublishState)","u":"createListener(com.rabbitmq.client.Channel,reactor.core.publisher.MonoSink,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitConnection","l":"DEFAULT_CONNECTION"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"DEFAULT_NAME"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"DEFAULT_RECOVERY_DELAY"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"DEFAULT_TIMEOUT_SECONDS"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"DefaultChannelPool(String, Connection, RabbitConnectionFactoryConfig)","u":"%3Cinit%3E(java.lang.String,com.rabbitmq.client.Connection,io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration","l":"DefaultChannelPoolConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration","l":"DefaultChannelPoolConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.exception","c":"DefaultRabbitListenerExceptionHandler","l":"DefaultRabbitListenerExceptionHandler()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"DefaultRabbitMessageSerDesRegistry","l":"DefaultRabbitMessageSerDesRegistry(RabbitMessageSerDes...)","u":"%3Cinit%3E(io.micronaut.rabbitmq.serdes.RabbitMessageSerDes...)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration","l":"DefaultRpcConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration","l":"DefaultRpcConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"deserialize(RabbitConsumerState, Argument)","u":"deserialize(io.micronaut.rabbitmq.bind.RabbitConsumerState,io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"deserialize(RabbitConsumerState, Argument)","u":"deserialize(io.micronaut.rabbitmq.bind.RabbitConsumerState,io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDes","l":"deserialize(RabbitConsumerState, Argument)","u":"deserialize(io.micronaut.rabbitmq.bind.RabbitConsumerState,io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownException","l":"ERROR_MESSAGE"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"exclusive()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"executor()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitConnection","l":"executor()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitListener","l":"executor()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBinderRegistry","l":"findArgumentBinder(Argument)","u":"findArgumentBinder(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"findSerDes(Argument)","u":"findSerDes(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"DefaultRabbitMessageSerDesRegistry","l":"findSerdes(Argument)","u":"findSerdes(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDesRegistry","l":"findSerdes(Argument)","u":"findSerdes(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"get(CharSequence, ArgumentConversionContext)","u":"get(java.lang.CharSequence,io.micronaut.core.convert.ArgumentConversionContext)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getAddresses()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBodyBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeadersBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"getAnnotationType()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getAppId()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getBody()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getBody()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getBooleanSerDes()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getByteArraySerDes()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getByteBufferSerDes()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"getChannel()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getChannelPool()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"getChannelWithRecoveringDelay(int)"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"getChannelWithRecoveringDelay(int)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getClusterId()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getConfirmTimeout()"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownException","l":"getConnection()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getConsumerExecutor()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getContentEncoding()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getContentType()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"getConversionErrors()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getCorrelationId()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getDeliveryMode()"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"getDetails(Connection)","u":"getDetails(com.rabbitmq.client.Connection)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getDoubleSerDes()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getEnvelope()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getExchange()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getExpiration()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"getFailures()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getFloatSerDes()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getHeaders()"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"getHealthInformation()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getIntegerSerDes()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"getListener()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getLongSerDes()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getMandatory()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration","l":"getMaxIdleChannels()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getMessageId()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"getMessageState()"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitConsumerEvent","l":"getMethod()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"getName()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getName()"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"getName()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getOrder()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"getOrder()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getPriority()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"getProperties()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getProperties()"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitConsumerEvent","l":"getQueue()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getReplyTo()"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"getRoutingKey()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"getRpc()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getShortSerDes()"},{"p":"io.micronaut.rabbitmq.event","c":"AbstractRabbitEvent","l":"getSource()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getStringSerDes()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"getTimeout()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getTimestamp()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getType()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"getUserId()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"getUUIDSerDes()"},{"p":"io.micronaut.rabbitmq.exception","c":"DefaultRabbitListenerExceptionHandler","l":"handle(RabbitListenerException)","u":"handle(io.micronaut.rabbitmq.exception.RabbitListenerException)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleCancel(String)","u":"handleCancel(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleCancelOk(String)","u":"handleCancelOk(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleConsumeOk(String)","u":"handleConsumeOk(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleRecoverOk(String)","u":"handleRecoverOk(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleShutdownSignal(String, ShutdownSignalException)","u":"handleShutdownSignal(java.lang.String,com.rabbitmq.client.ShutdownSignalException)"},{"p":"io.micronaut.rabbitmq.intercept","c":"DefaultConsumer","l":"handleTerminate(String)","u":"handleTerminate(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelInitializer","l":"initialize(Channel, String)","u":"initialize(com.rabbitmq.client.Channel,java.lang.String)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"initializePublish(Channel)","u":"initializePublish(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQIntroductionAdvice","l":"intercept(MethodInvocationContext)","u":"intercept(io.micronaut.aop.MethodInvocationContext)"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownConnection","l":"isStillDown()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"isTopologyRecoveryEnabled()"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"isTopologyRecoveryEnabled()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"JavaLangRabbitMessageSerDes()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"javaSerDes"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"JsonRabbitMessageSerDes(JsonMapper)","u":"%3Cinit%3E(io.micronaut.json.JsonMapper)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"MutableBasicProperties()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"NACK"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"NACK"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"nack()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgement","l":"nack(boolean, boolean)","u":"nack(boolean,boolean)"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperty","l":"name()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"names()"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownConnectionManager","l":"newConnection(RabbitConnectionFactoryConfig, ExecutorService)","u":"newConnection(io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig,java.util.concurrent.ExecutorService)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"NONE"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"NONE"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"numberOfConsumers()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"numberOfConsumersValue()"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownConnection.EventuallyUpListener","l":"onConnectionInitialized(TemporarilyDownConnection)","u":"onConnectionInitialized(io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnection)"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelInitializer","l":"onCreated(BeanCreatedEvent)","u":"onCreated(io.micronaut.context.event.BeanCreatedEvent)"},{"p":"io.micronaut.rabbitmq.metrics","c":"RabbitMetricsInterceptor","l":"onCreated(BeanCreatedEvent)","u":"onCreated(io.micronaut.context.event.BeanCreatedEvent)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactory","l":"onPreDestroy(BeanPreDestroyEvent)","u":"onPreDestroy(io.micronaut.context.event.BeanPreDestroyEvent)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"ORDER"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"ORDER"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"prefetch()"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"PREFIX"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"process(BeanDefinition, ExecutableMethod)","u":"process(io.micronaut.inject.BeanDefinition,io.micronaut.inject.ExecutableMethod)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactivePublisher","l":"publish(RabbitPublishState)","u":"publish(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publish(RabbitPublishState)","u":"publish(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactivePublisher","l":"publishAndConfirm(RabbitPublishState)","u":"publishAndConfirm(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishAndConfirm(RabbitPublishState)","u":"publishAndConfirm(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactivePublisher","l":"publishAndReply(RabbitPublishState)","u":"publishAndReply(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishAndReply(RabbitPublishState)","u":"publishAndReply(io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishInternal(Channel, RabbitPublishState)","u":"publishInternal(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishInternalNoConfirm(Channel, RabbitPublishState)","u":"publishInternalNoConfirm(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"publishRpcInternal(Channel, RabbitPublishState)","u":"publishRpcInternal(com.rabbitmq.client.Channel,io.micronaut.rabbitmq.reactive.RabbitPublishState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitAcknowledgementBinder","l":"RabbitAcknowledgementBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBasicPropertiesBinder","l":"RabbitBasicPropertiesBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBinderRegistry","l":"RabbitBinderRegistry(RabbitDefaultBinder, RabbitArgumentBinder...)","u":"%3Cinit%3E(io.micronaut.rabbitmq.bind.RabbitDefaultBinder,io.micronaut.rabbitmq.bind.RabbitArgumentBinder...)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitBodyBinder","l":"RabbitBodyBinder(RabbitMessageSerDesRegistry)","u":"%3Cinit%3E(io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitChannelBinder","l":"RabbitChannelBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String)","u":"%3Cinit%3E(java.lang.String)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String, List)","u":"%3Cinit%3E(java.lang.String,java.util.List)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String, Throwable)","u":"%3Cinit%3E(java.lang.String,java.lang.Throwable)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitClientException","l":"RabbitClientException(String, Throwable, List)","u":"%3Cinit%3E(java.lang.String,java.lang.Throwable,java.util.List)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactory","l":"RabbitConnectionFactory()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"RabbitConnectionFactoryConfig(String)","u":"%3Cinit%3E(java.lang.String)"},{"p":"io.micronaut.rabbitmq.executor","c":"RabbitConsumerExecutorFactory","l":"RabbitConsumerExecutorFactory()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.event","c":"RabbitConsumerStarted","l":"RabbitConsumerStarted(Object, String, String)","u":"%3Cinit%3E(java.lang.Object,java.lang.String,java.lang.String)"},{"p":"io.micronaut.rabbitmq.event","c":"RabbitConsumerStarting","l":"RabbitConsumerStarting(Object, String, String)","u":"%3Cinit%3E(java.lang.Object,java.lang.String,java.lang.String)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitConsumerState","l":"RabbitConsumerState(Envelope, AMQP.BasicProperties, byte[], Channel)","u":"%3Cinit%3E(com.rabbitmq.client.Envelope,com.rabbitmq.client.AMQP.BasicProperties,byte[],com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitDefaultBinder","l":"RabbitDefaultBinder(RabbitPropertyBinder, RabbitBodyBinder)","u":"%3Cinit%3E(io.micronaut.rabbitmq.bind.RabbitPropertyBinder,io.micronaut.rabbitmq.bind.RabbitBodyBinder)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitEnvelopeBinder","l":"RabbitEnvelopeBinder()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderBinder","l":"RabbitHeaderBinder(ConversionService)","u":"%3Cinit%3E(io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"RabbitHeaderConvertibleValues(Map, ConversionService)","u":"%3Cinit%3E(java.util.Map,io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeadersBinder","l":"RabbitHeadersBinder(ConversionService)","u":"%3Cinit%3E(io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"RabbitListenerException(String, Object, RabbitConsumerState)","u":"%3Cinit%3E(java.lang.String,java.lang.Object,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"RabbitListenerException(String, Throwable, Object, RabbitConsumerState)","u":"%3Cinit%3E(java.lang.String,java.lang.Throwable,java.lang.Object,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.exception","c":"RabbitListenerException","l":"RabbitListenerException(Throwable, Object, RabbitConsumerState)","u":"%3Cinit%3E(java.lang.Throwable,java.lang.Object,io.micronaut.rabbitmq.bind.RabbitConsumerState)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"RabbitMessageCloseable(RabbitConsumerState, boolean, boolean)","u":"%3Cinit%3E(io.micronaut.rabbitmq.bind.RabbitConsumerState,boolean,boolean)"},{"p":"io.micronaut.rabbitmq.metrics","c":"RabbitMetricsInterceptor","l":"RabbitMetricsInterceptor(BeanProvider, String, Map)","u":"%3Cinit%3E(io.micronaut.context.BeanProvider,java.lang.String,java.util.Map)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"RabbitMQConsumerAdvice(BeanContext, ApplicationEventPublisher, ApplicationEventPublisher, RabbitBinderRegistry, RabbitListenerExceptionHandler, RabbitMessageSerDesRegistry, ConversionService, List)","u":"%3Cinit%3E(io.micronaut.context.BeanContext,io.micronaut.context.event.ApplicationEventPublisher,io.micronaut.context.event.ApplicationEventPublisher,io.micronaut.rabbitmq.bind.RabbitBinderRegistry,io.micronaut.rabbitmq.exception.RabbitListenerExceptionHandler,io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry,io.micronaut.core.convert.ConversionService,java.util.List)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQConsumerAdvice","l":"RabbitMQConsumerAdvice(BeanContext, RabbitBinderRegistry, RabbitListenerExceptionHandler, RabbitMessageSerDesRegistry, ConversionService, List)","u":"%3Cinit%3E(io.micronaut.context.BeanContext,io.micronaut.rabbitmq.bind.RabbitBinderRegistry,io.micronaut.rabbitmq.exception.RabbitListenerExceptionHandler,io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry,io.micronaut.core.convert.ConversionService,java.util.List)"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"RabbitMQHealthIndicator(Connection)","u":"%3Cinit%3E(com.rabbitmq.client.Connection)"},{"p":"io.micronaut.rabbitmq.health","c":"RabbitMQHealthIndicator","l":"RabbitMQHealthIndicator(List)","u":"%3Cinit%3E(java.util.List)"},{"p":"io.micronaut.rabbitmq.intercept","c":"RabbitMQIntroductionAdvice","l":"RabbitMQIntroductionAdvice(BeanContext, ConversionService, RabbitMessageSerDesRegistry, ExecutorService)","u":"%3Cinit%3E(io.micronaut.context.BeanContext,io.micronaut.core.convert.ConversionService,io.micronaut.rabbitmq.serdes.RabbitMessageSerDesRegistry,java.util.concurrent.ExecutorService)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"RabbitPropertyBinder(ConversionService)","u":"%3Cinit%3E(io.micronaut.core.convert.ConversionService)"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"RabbitPublishState(String, String, AMQP.BasicProperties, byte[])","u":"%3Cinit%3E(java.lang.String,java.lang.String,com.rabbitmq.client.AMQP.BasicProperties,byte[])"},{"p":"io.micronaut.rabbitmq.reactive","c":"RabbitPublishState","l":"RabbitPublishState(String, String, boolean, AMQP.BasicProperties, byte[])","u":"%3Cinit%3E(java.lang.String,java.lang.String,boolean,com.rabbitmq.client.AMQP.BasicProperties,byte[])"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"ReactorReactivePublisher(ChannelPool, RabbitConnectionFactoryConfig)","u":"%3Cinit%3E(io.micronaut.rabbitmq.connect.ChannelPool,io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig)"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"reQueue()"},{"p":"io.micronaut.rabbitmq.connect","c":"ChannelPool","l":"returnChannel(Channel)","u":"returnChannel(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.connect","c":"DefaultChannelPool","l":"returnChannel(Channel)","u":"returnChannel(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.reactive","c":"ReactorReactivePublisher","l":"returnChannel(Channel)","u":"returnChannel(com.rabbitmq.client.Channel)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"RpcConfiguration()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"serialize(Object, MutableBasicProperties)","u":"serialize(java.lang.Object,io.micronaut.rabbitmq.intercept.MutableBasicProperties)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"serialize(Object, MutableBasicProperties)","u":"serialize(java.lang.Object,io.micronaut.rabbitmq.intercept.MutableBasicProperties)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDes","l":"serialize(T, MutableBasicProperties)","u":"serialize(T,io.micronaut.rabbitmq.intercept.MutableBasicProperties)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setAddresses(List
    )","u":"setAddresses(java.util.List)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setAppId(String)","u":"setAppId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"setChannelPool(ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)","u":"setChannelPool(io.micronaut.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setChannelPool(RabbitConnectionFactoryConfig.ChannelPoolConfiguration)","u":"setChannelPool(io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig.ChannelPoolConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"setChannelPool(SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)","u":"setChannelPool(io.micronaut.rabbitmq.connect.SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setClusterId(String)","u":"setClusterId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setConfirmTimeout(Duration)","u":"setConfirmTimeout(java.time.Duration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setConsumerExecutor(String)","u":"setConsumerExecutor(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setContentEncoding(String)","u":"setContentEncoding(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setContentType(String)","u":"setContentType(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setCorrelationId(String)","u":"setCorrelationId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setDeliveryMode(Integer)","u":"setDeliveryMode(java.lang.Integer)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setExpiration(String)","u":"setExpiration(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setHeaders(Map)","u":"setHeaders(java.util.Map)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration","l":"setMaxIdleChannels(Integer)","u":"setMaxIdleChannels(java.lang.Integer)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setMessageId(String)","u":"setMessageId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setPriority(Integer)","u":"setPriority(java.lang.Integer)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setReplyTo(String)","u":"setReplyTo(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"ClusterRabbitConnectionFactoryConfig","l":"setRpc(ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration)","u":"setRpc(io.micronaut.rabbitmq.connect.ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig","l":"setRpc(RabbitConnectionFactoryConfig.RpcConfiguration)","u":"setRpc(io.micronaut.rabbitmq.connect.RabbitConnectionFactoryConfig.RpcConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"setRpc(SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration)","u":"setRpc(io.micronaut.rabbitmq.connect.SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration)"},{"p":"io.micronaut.rabbitmq.connect","c":"RabbitConnectionFactoryConfig.RpcConfiguration","l":"setTimeout(Duration)","u":"setTimeout(java.time.Duration)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setTimestamp(Date)","u":"setTimestamp(java.util.Date)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setType(String)","u":"setType(java.lang.String)"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"setUserId(String)","u":"setUserId(java.lang.String)"},{"p":"io.micronaut.rabbitmq.connect","c":"SingleRabbitConnectionFactoryConfig","l":"SingleRabbitConnectionFactoryConfig()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.serdes","c":"JavaLangRabbitMessageSerDes","l":"supports(Argument)","u":"supports(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"JsonRabbitMessageSerDes","l":"supports(Argument)","u":"supports(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.serdes","c":"RabbitMessageSerDes","l":"supports(Argument)","u":"supports(io.micronaut.core.type.Argument)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitPropertyBinder","l":"supports(ArgumentConversionContext)","u":"supports(io.micronaut.core.convert.ArgumentConversionContext)"},{"p":"io.micronaut.rabbitmq.connect.recovery","c":"TemporarilyDownConnectionManager","l":"TemporarilyDownConnectionManager()","u":"%3Cinit%3E()"},{"p":"io.micronaut.rabbitmq.intercept","c":"MutableBasicProperties","l":"toBasicProperties()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperty","l":"type()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Binding","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Mandatory","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"Queue","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitClient","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperties","l":"value()"},{"p":"io.micronaut.rabbitmq.annotation","c":"RabbitProperty","l":"value()"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"valueOf(String)","u":"valueOf(java.lang.String)"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"valueOf(String)","u":"valueOf(java.lang.String)"},{"p":"io.micronaut.rabbitmq.bind","c":"AcknowledgmentAction","l":"values()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitHeaderConvertibleValues","l":"values()"},{"p":"io.micronaut.rabbitmq.reactive","c":"BrokerResponse","l":"values()"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"withAcknowledge(Boolean)","u":"withAcknowledge(java.lang.Boolean)"},{"p":"io.micronaut.rabbitmq.bind","c":"RabbitMessageCloseable","l":"withAcknowledgmentAction(AcknowledgmentAction)","u":"withAcknowledgmentAction(io.micronaut.rabbitmq.bind.AcknowledgmentAction)"}];updateSearchResults(); \ No newline at end of file diff --git a/snapshot/api/overview-tree.html b/snapshot/api/overview-tree.html index d4b79edc5..d780763be 100644 --- a/snapshot/api/overview-tree.html +++ b/snapshot/api/overview-tree.html @@ -54,6 +54,7 @@

    Hierarchy For All Packages

  • io.micronaut.rabbitmq.annotation,
  • io.micronaut.rabbitmq.bind,
  • io.micronaut.rabbitmq.connect,
    • +
  • io.micronaut.rabbitmq.connect.recovery,
  • io.micronaut.rabbitmq.event,
  • io.micronaut.rabbitmq.exception,
  • io.micronaut.rabbitmq.executor,
    • @@ -146,6 +147,7 @@

    Class Hierarchy

  • io.micronaut.rabbitmq.bind.RabbitPropertyBinder (implements io.micronaut.rabbitmq.bind.RabbitAnnotatedArgumentBinder<A>)
  • io.micronaut.rabbitmq.reactive.RabbitPublishState
  • io.micronaut.rabbitmq.reactive.ReactorReactivePublisher (implements io.micronaut.rabbitmq.reactive.ReactivePublisher)
    • +
  • io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnectionManager
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception @@ -204,6 +206,19 @@

      Interface Hierarchy

    • +
  • java.lang.AutoCloseable +
      +
    • java.io.Closeable +
        +
      • com.rabbitmq.client.Connection (also extends com.rabbitmq.client.ShutdownNotifier) + +
        • +
      +
      • +
    +
  • com.rabbitmq.client.Consumer
    diff --git a/snapshot/api/package-search-index.js b/snapshot/api/package-search-index.js index fe995a296..cfbe94bb0 100644 --- a/snapshot/api/package-search-index.js +++ b/snapshot/api/package-search-index.js @@ -1 +1 @@ -packageSearchIndex = [{"l":"All Packages","u":"allpackages-index.html"},{"l":"io.micronaut.rabbitmq.annotation"},{"l":"io.micronaut.rabbitmq.bind"},{"l":"io.micronaut.rabbitmq.connect"},{"l":"io.micronaut.rabbitmq.event"},{"l":"io.micronaut.rabbitmq.exception"},{"l":"io.micronaut.rabbitmq.executor"},{"l":"io.micronaut.rabbitmq.health"},{"l":"io.micronaut.rabbitmq.intercept"},{"l":"io.micronaut.rabbitmq.metrics"},{"l":"io.micronaut.rabbitmq.reactive"},{"l":"io.micronaut.rabbitmq.serdes"}];updateSearchResults(); \ No newline at end of file +packageSearchIndex = [{"l":"All Packages","u":"allpackages-index.html"},{"l":"io.micronaut.rabbitmq.annotation"},{"l":"io.micronaut.rabbitmq.bind"},{"l":"io.micronaut.rabbitmq.connect"},{"l":"io.micronaut.rabbitmq.connect.recovery"},{"l":"io.micronaut.rabbitmq.event"},{"l":"io.micronaut.rabbitmq.exception"},{"l":"io.micronaut.rabbitmq.executor"},{"l":"io.micronaut.rabbitmq.health"},{"l":"io.micronaut.rabbitmq.intercept"},{"l":"io.micronaut.rabbitmq.metrics"},{"l":"io.micronaut.rabbitmq.reactive"},{"l":"io.micronaut.rabbitmq.serdes"}];updateSearchResults(); \ No newline at end of file diff --git a/snapshot/api/type-search-index.js b/snapshot/api/type-search-index.js index 316c6224b..00d8d6888 100644 --- a/snapshot/api/type-search-index.js +++ b/snapshot/api/type-search-index.js @@ -1 +1 @@ -typeSearchIndex = [{"p":"io.micronaut.rabbitmq.event","l":"AbstractRabbitConsumerEvent"},{"p":"io.micronaut.rabbitmq.event","l":"AbstractRabbitEvent"},{"p":"io.micronaut.rabbitmq.bind","l":"AcknowledgementBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"AcknowledgmentAction"},{"p":"io.micronaut.rabbitmq.connect","l":"AddressTypeConverter"},{"l":"All Classes and Interfaces","u":"allclasses-index.html"},{"p":"io.micronaut.rabbitmq.annotation","l":"Binding"},{"p":"io.micronaut.rabbitmq.reactive","l":"BrokerResponse"},{"p":"io.micronaut.rabbitmq.connect","l":"ChannelInitializer"},{"p":"io.micronaut.rabbitmq.connect","l":"ChannelPool"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"ClusterRabbitConnectionFactoryConfig"},{"p":"io.micronaut.rabbitmq.connect","l":"DefaultChannelPool"},{"p":"io.micronaut.rabbitmq.connect","l":"ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration"},{"p":"io.micronaut.rabbitmq.intercept","l":"DefaultConsumer"},{"p":"io.micronaut.rabbitmq.exception","l":"DefaultRabbitListenerExceptionHandler"},{"p":"io.micronaut.rabbitmq.serdes","l":"DefaultRabbitMessageSerDesRegistry"},{"p":"io.micronaut.rabbitmq.connect","l":"ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration"},{"p":"io.micronaut.rabbitmq.serdes","l":"JavaLangRabbitMessageSerDes"},{"p":"io.micronaut.rabbitmq.serdes","l":"JsonRabbitMessageSerDes"},{"p":"io.micronaut.rabbitmq.annotation","l":"Mandatory"},{"p":"io.micronaut.rabbitmq.intercept","l":"MutableBasicProperties"},{"p":"io.micronaut.rabbitmq.annotation","l":"Queue"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitAcknowledgement"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitAcknowledgementBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitAnnotatedArgumentBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitArgumentBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitBasicPropertiesBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitBinderRegistry"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitBodyBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitChannelBinder"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitClient"},{"p":"io.micronaut.rabbitmq.exception","l":"RabbitClientException"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitConnection"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactory"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactoryConfig"},{"p":"io.micronaut.rabbitmq.executor","l":"RabbitConsumerExecutorFactory"},{"p":"io.micronaut.rabbitmq.event","l":"RabbitConsumerStarted"},{"p":"io.micronaut.rabbitmq.event","l":"RabbitConsumerStarting"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitConsumerState"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitDefaultBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitEnvelopeBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitHeaderBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitHeaderConvertibleValues"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitHeaders"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitHeadersBinder"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitListener"},{"p":"io.micronaut.rabbitmq.exception","l":"RabbitListenerException"},{"p":"io.micronaut.rabbitmq.exception","l":"RabbitListenerExceptionHandler"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitMessageCloseable"},{"p":"io.micronaut.rabbitmq.serdes","l":"RabbitMessageSerDes"},{"p":"io.micronaut.rabbitmq.serdes","l":"RabbitMessageSerDesRegistry"},{"p":"io.micronaut.rabbitmq.metrics","l":"RabbitMetricsInterceptor"},{"p":"io.micronaut.rabbitmq.intercept","l":"RabbitMQConsumerAdvice"},{"p":"io.micronaut.rabbitmq.health","l":"RabbitMQHealthIndicator"},{"p":"io.micronaut.rabbitmq.intercept","l":"RabbitMQIntroductionAdvice"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitProperties"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitProperty"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitPropertyBinder"},{"p":"io.micronaut.rabbitmq.reactive","l":"RabbitPublishState"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitTypeArgumentBinder"},{"p":"io.micronaut.rabbitmq.reactive","l":"ReactivePublisher"},{"p":"io.micronaut.rabbitmq.reactive","l":"ReactorReactivePublisher"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactoryConfig.RpcConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"SingleRabbitConnectionFactoryConfig"}];updateSearchResults(); \ No newline at end of file +typeSearchIndex = [{"p":"io.micronaut.rabbitmq.event","l":"AbstractRabbitConsumerEvent"},{"p":"io.micronaut.rabbitmq.event","l":"AbstractRabbitEvent"},{"p":"io.micronaut.rabbitmq.bind","l":"AcknowledgementBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"AcknowledgmentAction"},{"p":"io.micronaut.rabbitmq.connect","l":"AddressTypeConverter"},{"l":"All Classes and Interfaces","u":"allclasses-index.html"},{"p":"io.micronaut.rabbitmq.annotation","l":"Binding"},{"p":"io.micronaut.rabbitmq.reactive","l":"BrokerResponse"},{"p":"io.micronaut.rabbitmq.connect","l":"ChannelInitializer"},{"p":"io.micronaut.rabbitmq.connect","l":"ChannelPool"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactoryConfig.ChannelPoolConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"ClusterRabbitConnectionFactoryConfig"},{"p":"io.micronaut.rabbitmq.connect","l":"DefaultChannelPool"},{"p":"io.micronaut.rabbitmq.connect","l":"ClusterRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"SingleRabbitConnectionFactoryConfig.DefaultChannelPoolConfiguration"},{"p":"io.micronaut.rabbitmq.intercept","l":"DefaultConsumer"},{"p":"io.micronaut.rabbitmq.exception","l":"DefaultRabbitListenerExceptionHandler"},{"p":"io.micronaut.rabbitmq.serdes","l":"DefaultRabbitMessageSerDesRegistry"},{"p":"io.micronaut.rabbitmq.connect","l":"ClusterRabbitConnectionFactoryConfig.DefaultRpcConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"SingleRabbitConnectionFactoryConfig.DefaultRpcConfiguration"},{"p":"io.micronaut.rabbitmq.connect.recovery","l":"TemporarilyDownConnection.EventuallyUpListener"},{"p":"io.micronaut.rabbitmq.serdes","l":"JavaLangRabbitMessageSerDes"},{"p":"io.micronaut.rabbitmq.serdes","l":"JsonRabbitMessageSerDes"},{"p":"io.micronaut.rabbitmq.annotation","l":"Mandatory"},{"p":"io.micronaut.rabbitmq.intercept","l":"MutableBasicProperties"},{"p":"io.micronaut.rabbitmq.annotation","l":"Queue"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitAcknowledgement"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitAcknowledgementBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitAnnotatedArgumentBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitArgumentBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitBasicPropertiesBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitBinderRegistry"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitBodyBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitChannelBinder"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitClient"},{"p":"io.micronaut.rabbitmq.exception","l":"RabbitClientException"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitConnection"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactory"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactoryConfig"},{"p":"io.micronaut.rabbitmq.executor","l":"RabbitConsumerExecutorFactory"},{"p":"io.micronaut.rabbitmq.event","l":"RabbitConsumerStarted"},{"p":"io.micronaut.rabbitmq.event","l":"RabbitConsumerStarting"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitConsumerState"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitDefaultBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitEnvelopeBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitHeaderBinder"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitHeaderConvertibleValues"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitHeaders"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitHeadersBinder"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitListener"},{"p":"io.micronaut.rabbitmq.exception","l":"RabbitListenerException"},{"p":"io.micronaut.rabbitmq.exception","l":"RabbitListenerExceptionHandler"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitMessageCloseable"},{"p":"io.micronaut.rabbitmq.serdes","l":"RabbitMessageSerDes"},{"p":"io.micronaut.rabbitmq.serdes","l":"RabbitMessageSerDesRegistry"},{"p":"io.micronaut.rabbitmq.metrics","l":"RabbitMetricsInterceptor"},{"p":"io.micronaut.rabbitmq.intercept","l":"RabbitMQConsumerAdvice"},{"p":"io.micronaut.rabbitmq.health","l":"RabbitMQHealthIndicator"},{"p":"io.micronaut.rabbitmq.intercept","l":"RabbitMQIntroductionAdvice"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitProperties"},{"p":"io.micronaut.rabbitmq.annotation","l":"RabbitProperty"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitPropertyBinder"},{"p":"io.micronaut.rabbitmq.reactive","l":"RabbitPublishState"},{"p":"io.micronaut.rabbitmq.bind","l":"RabbitTypeArgumentBinder"},{"p":"io.micronaut.rabbitmq.reactive","l":"ReactivePublisher"},{"p":"io.micronaut.rabbitmq.reactive","l":"ReactorReactivePublisher"},{"p":"io.micronaut.rabbitmq.connect","l":"RabbitConnectionFactoryConfig.RpcConfiguration"},{"p":"io.micronaut.rabbitmq.connect","l":"SingleRabbitConnectionFactoryConfig"},{"p":"io.micronaut.rabbitmq.connect.recovery","l":"TemporarilyDownConnection"},{"p":"io.micronaut.rabbitmq.connect.recovery","l":"TemporarilyDownConnectionManager"},{"p":"io.micronaut.rabbitmq.connect.recovery","l":"TemporarilyDownException"}];updateSearchResults(); \ No newline at end of file diff --git a/snapshot/guide/configurationreference.html b/snapshot/guide/configurationreference.html index 3664dd05b..d76cfcb94 100644 --- a/snapshot/guide/configurationreference.html +++ b/snapshot/guide/configurationreference.html @@ -51,9 +51,9 @@

    Configuration Reference

    Micronaut Rabbitmq Config Properties

    -🔗 +🔗 - +@@ -68,7 +68,7 @@

    Micronaut Rabbitmq Config Propert

    - + @@ -319,57 +319,9 @@

    Micronaut Rabbitmq Config Propert

    Table 1. Configuration Properties for SingleRabbitConnectionFactoryConfig$DefaultRpcConfigurationTable 1. Configuration Properties for ClusterRabbitConnectionFactoryConfig$DefaultRpcConfiguration

    rabbitmq.rpc.timeout

    rabbitmq.servers.*.rpc.timeout

    java.time.Duration
    -🔗 - - ----- - - - - - - - - - - - - - - -
    Table 3. Configuration Properties for ClusterRabbitConnectionFactoryConfig$DefaultRpcConfiguration
    PropertyTypeDescription

    rabbitmq.servers.*.rpc.timeout

    java.time.Duration

    -
    -🔗 - - ----- - - - - - - - - - - - - - - -
    Table 4. Configuration Properties for SingleRabbitConnectionFactoryConfig$DefaultChannelPoolConfiguration
    PropertyTypeDescription

    rabbitmq.channel-pool.max-idle-channels

    java.lang.Integer

    -
    🔗 - +@@ -611,9 +563,33 @@

    Micronaut Rabbitmq Config Propert

    Table 5. Configuration Properties for SingleRabbitConnectionFactoryConfigTable 3. Configuration Properties for SingleRabbitConnectionFactoryConfig
    +🔗 + + +++++ + + + + + + + + + + + + + + +
    Table 4. Configuration Properties for SingleRabbitConnectionFactoryConfig$DefaultChannelPoolConfiguration
    PropertyTypeDescription

    rabbitmq.channel-pool.max-idle-channels

    java.lang.Integer

    +
    🔗 - +@@ -635,6 +611,30 @@

    Micronaut Rabbitmq Config Propert

    Table 6. Configuration Properties for ClusterRabbitConnectionFactoryConfig$DefaultChannelPoolConfigurationTable 5. Configuration Properties for ClusterRabbitConnectionFactoryConfig$DefaultChannelPoolConfiguration
    +🔗 + + +++++ + + + + + + + + + + + + + + +
    Table 6. Configuration Properties for SingleRabbitConnectionFactoryConfig$DefaultRpcConfiguration
    PropertyTypeDescription

    rabbitmq.rpc.timeout

    java.time.Duration

    +