getHeaders().put(HEADER_X_RETRIES_COUNT, ++retriesCnt) įailedMessage.getMessageProperties(). Public static final String EXCHANGE_MESSAGES = messagesQueue() time", retriesCnt) Now, let’s define a simple queue and exchange configuration to start: public static final String QUEUE_MESSAGES = "baeldung-messages-queue" In the next sections, we’ll mostly focus on application-specific and high-level errors and then cover global error handling strategies. Additionally, most of the failures and faults are converted into an AmqpException or one of its subclasses. We should note that Spring AMQP handles connection-related and low-level issues out of the box, for example by applying retry or requeue policies. Application- and message-related – exceptions that usually indicate a violation of some business or application rulesĬertainly, this list of failures is not exhaustive but contains the most common type of errors. For instance, reaching defined limits or threshold, authentication or invalid policies configuration
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |