[BUG] `servicebus` binder response with `status=DOWN` if it can't process the event due to message payload size #44158

microarchitecture · 2025-02-11T20:54:06Z

Describe the bug
servicebus binder response with status=DOWN for the liveness probe if it can't process the event due to message payload size. Because of the servicebus binder status as DOWN, the status of the liveness probe is DOWN as well (despite the application itself being up and running). liveness probe is used in the K8S cluster for the application health cheks. Its incorrect status makes the pod to recreate the container, although the application itself is healthy.

Exception or Stack Trace
The binder throws the exception with the message Size of the payload exceeded maximum message size: 256 kb.
The stack trace is also available in the liveness probe response (please find it below in the actuator livenerr probe response section).

To Reproduce
Service Bus standard tier has a limitation for the payload of 256kb. If the single event has a payload that exceeds this limit, the binder throws ServiceBusException and binder status is considered down.

Expected behavior
servicebinder probe should report UP in the case the message payload can't be processed due to its size.

Setup

Library/Libraries: reproduced on both spring-cloud-azure-stream-binder-servicebus's 5.6.0 and 5.14.0
Java version: 21
App Server/Environment: Tomcat
Frameworks: Spring Boot

Actuator liveness probe response

{
  "status": "DOWN",
  "components": {
    "binders": {
      "status": "DOWN",
      "components": {
        "servicebus": {
          "status": "DOWN",
          "details": {
            "PRODUCER:com.event...": {
              "cause": {
                "stackTrace": [
                  {
                    "classLoaderName": "app",
                    "methodName": "tryAddMessage",
                    "fileName": "ServiceBusMessageBatch.java",
                    "lineNumber": 104,
                    "className": "com.azure.messaging.servicebus.ServiceBusMessageBatch",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "lambda$accumulator$0",
                    "fileName": "ServiceBusSenderAsyncClient.java",
                    "lineNumber": 988,
                    "className": "com.azure.messaging.servicebus.ServiceBusSenderAsyncClient$AmqpMessageCollector",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "MonoStreamCollector.java",
                    "lineNumber": 117,
                    "className": "reactor.core.publisher.MonoStreamCollector$StreamCollectorSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "request",
                    "fileName": "Operators.java",
                    "lineNumber": 2571,
                    "className": "reactor.core.publisher.Operators$ScalarSubscription",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "request",
                    "fileName": "Operators.java",
                    "lineNumber": 2067,
                    "className": "reactor.core.publisher.Operators$BaseFluxToMonoOperator",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onSubscribe",
                    "fileName": "MonoFlatMap.java",
                    "lineNumber": 291,
                    "className": "reactor.core.publisher.MonoFlatMap$FlatMapInner",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onSubscribe",
                    "fileName": "Operators.java",
                    "lineNumber": 2051,
                    "className": "reactor.core.publisher.Operators$BaseFluxToMonoOperator",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "subscribe",
                    "fileName": "FluxJust.java",
                    "lineNumber": 68,
                    "className": "reactor.core.publisher.FluxJust",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "subscribe",
                    "fileName": "MonoFromFluxOperator.java",
                    "lineNumber": 83,
                    "className": "reactor.core.publisher.MonoFromFluxOperator",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "MonoFlatMap.java",
                    "lineNumber": 165,
                    "className": "reactor.core.publisher.MonoFlatMap$FlatMapMain",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "complete",
                    "fileName": "MonoIgnoreThen.java",
                    "lineNumber": 294,
                    "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "MonoIgnoreThen.java",
                    "lineNumber": 188,
                    "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "subscribeNext",
                    "fileName": "MonoIgnoreThen.java",
                    "lineNumber": 237,
                    "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "MonoIgnoreThen.java",
                    "lineNumber": 204,
                    "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "FluxPeek.java",
                    "lineNumber": 260,
                    "className": "reactor.core.publisher.FluxPeek$PeekSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "SerializedSubscriber.java",
                    "lineNumber": 146,
                    "className": "reactor.core.publisher.SerializedSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "FluxRetryWhen.java",
                    "lineNumber": 204,
                    "className": "reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "SerializedSubscriber.java",
                    "lineNumber": 146,
                    "className": "reactor.core.publisher.SerializedSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "FluxTimeout.java",
                    "lineNumber": 235,
                    "className": "reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onComplete",
                    "fileName": "FluxTakeUntil.java",
                    "lineNumber": 122,
                    "className": "reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "FluxTakeUntil.java",
                    "lineNumber": 100,
                    "className": "reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "replayNormal",
                    "fileName": "FluxReplay.java",
                    "lineNumber": 877,
                    "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "replay",
                    "fileName": "FluxReplay.java",
                    "lineNumber": 965,
                    "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "FluxReplay.java",
                    "lineNumber": 1345,
                    "className": "reactor.core.publisher.FluxReplay$ReplaySubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "FluxPeek.java",
                    "lineNumber": 200,
                    "className": "reactor.core.publisher.FluxPeek$PeekSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "FluxPeek.java",
                    "lineNumber": 200,
                    "className": "reactor.core.publisher.FluxPeek$PeekSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "FluxMap.java",
                    "lineNumber": 122,
                    "className": "reactor.core.publisher.FluxMap$MapSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "tryOnNext",
                    "fileName": "FluxDistinctUntilChanged.java",
                    "lineNumber": 149,
                    "className": "reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "FluxDistinctUntilChanged.java",
                    "lineNumber": 102,
                    "className": "reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "replayNormal",
                    "fileName": "FluxReplay.java",
                    "lineNumber": 877,
                    "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "replay",
                    "fileName": "FluxReplay.java",
                    "lineNumber": 965,
                    "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "tryEmitNext",
                    "fileName": "SinkManyReplayProcessor.java",
                    "lineNumber": 477,
                    "className": "reactor.core.publisher.SinkManyReplayProcessor",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "tryEmitNext",
                    "fileName": "SinkManySerialized.java",
                    "lineNumber": 100,
                    "className": "reactor.core.publisher.SinkManySerialized",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "emitNext",
                    "fileName": "InternalManySink.java",
                    "lineNumber": 27,
                    "className": "reactor.core.publisher.InternalManySink",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onNext",
                    "fileName": "Handler.java",
                    "lineNumber": 91,
                    "className": "com.azure.core.amqp.implementation.handler.Handler",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "onLinkRemoteOpen",
                    "fileName": "SendLinkHandler.java",
                    "lineNumber": 140,
                    "className": "com.azure.core.amqp.implementation.handler.SendLinkHandler",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "handle",
                    "fileName": "BaseHandler.java",
                    "lineNumber": 164,
                    "className": "org.apache.qpid.proton.engine.BaseHandler",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "dispatch",
                    "fileName": "EventImpl.java",
                    "lineNumber": 108,
                    "className": "org.apache.qpid.proton.engine.impl.EventImpl",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "dispatch",
                    "fileName": "ReactorImpl.java",
                    "lineNumber": 324,
                    "className": "org.apache.qpid.proton.reactor.impl.ReactorImpl",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "process",
                    "fileName": "ReactorImpl.java",
                    "lineNumber": 291,
                    "className": "org.apache.qpid.proton.reactor.impl.ReactorImpl",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "run",
                    "fileName": "ReactorExecutor.java",
                    "lineNumber": 91,
                    "className": "com.azure.core.amqp.implementation.ReactorExecutor",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "call",
                    "fileName": "SchedulerTask.java",
                    "lineNumber": 68,
                    "className": "reactor.core.scheduler.SchedulerTask",
                    "nativeMethod": false
                  },
                  {
                    "classLoaderName": "app",
                    "methodName": "call",
                    "fileName": "SchedulerTask.java",
                    "lineNumber": 28,
                    "className": "reactor.core.scheduler.SchedulerTask",
                    "nativeMethod": false
                  },
                  {
                    "moduleName": "java.base",
                    "moduleVersion": "21.0.4",
                    "methodName": "run",
                    "lineNumber": -1,
                    "className": "java.util.concurrent.FutureTask",
                    "nativeMethod": false
                  },
                  {
                    "moduleName": "java.base",
                    "moduleVersion": "21.0.4",
                    "methodName": "run",
                    "lineNumber": -1,
                    "className": "java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask",
                    "nativeMethod": false
                  },
                  {
                    "moduleName": "java.base",
                    "moduleVersion": "21.0.4",
                    "methodName": "runWorker",
                    "lineNumber": -1,
                    "className": "java.util.concurrent.ThreadPoolExecutor",
                    "nativeMethod": false
                  },
                  {
                    "moduleName": "java.base",
                    "moduleVersion": "21.0.4",
                    "methodName": "run",
                    "lineNumber": -1,
                    "className": "java.util.concurrent.ThreadPoolExecutor$Worker",
                    "nativeMethod": false
                  },
                  {
                    "moduleName": "java.base",
                    "moduleVersion": "21.0.4",
                    "methodName": "run",
                    "lineNumber": -1,
                    "className": "java.lang.Thread",
                    "nativeMethod": false
                  }
                ],
                "errorCondition": "LINK_PAYLOAD_SIZE_EXCEEDED",
                "message": "Size of the payload exceeded maximum message size: 256 kb, errorContext[NAMESPACE: ...]",
                "context": {
                  "namespace": "",
                  "errorInfo": {},
                  "entityPath": "com.event...",
                  "trackingId": "com.event...",
                  "linkCredit": 0
                },
                "transient": false,
                "suppressed": [],
                "localizedMessage": "Size of the payload exceeded maximum message size: 256 kb, errorContext[NAMESPACE: ...]"
              },
              "stackTrace": [
                {
                  "classLoaderName": "app",
                  "methodName": "tryAddMessage",
                  "fileName": "ServiceBusMessageBatch.java",
                  "lineNumber": 104,
                  "className": "com.azure.messaging.servicebus.ServiceBusMessageBatch",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "lambda$accumulator$0",
                  "fileName": "ServiceBusSenderAsyncClient.java",
                  "lineNumber": 988,
                  "className": "com.azure.messaging.servicebus.ServiceBusSenderAsyncClient$AmqpMessageCollector",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "MonoStreamCollector.java",
                  "lineNumber": 117,
                  "className": "reactor.core.publisher.MonoStreamCollector$StreamCollectorSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "request",
                  "fileName": "Operators.java",
                  "lineNumber": 2571,
                  "className": "reactor.core.publisher.Operators$ScalarSubscription",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "request",
                  "fileName": "Operators.java",
                  "lineNumber": 2067,
                  "className": "reactor.core.publisher.Operators$BaseFluxToMonoOperator",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onSubscribe",
                  "fileName": "MonoFlatMap.java",
                  "lineNumber": 291,
                  "className": "reactor.core.publisher.MonoFlatMap$FlatMapInner",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onSubscribe",
                  "fileName": "Operators.java",
                  "lineNumber": 2051,
                  "className": "reactor.core.publisher.Operators$BaseFluxToMonoOperator",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "subscribe",
                  "fileName": "FluxJust.java",
                  "lineNumber": 68,
                  "className": "reactor.core.publisher.FluxJust",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "subscribe",
                  "fileName": "MonoFromFluxOperator.java",
                  "lineNumber": 83,
                  "className": "reactor.core.publisher.MonoFromFluxOperator",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "MonoFlatMap.java",
                  "lineNumber": 165,
                  "className": "reactor.core.publisher.MonoFlatMap$FlatMapMain",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "complete",
                  "fileName": "MonoIgnoreThen.java",
                  "lineNumber": 294,
                  "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "MonoIgnoreThen.java",
                  "lineNumber": 188,
                  "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "subscribeNext",
                  "fileName": "MonoIgnoreThen.java",
                  "lineNumber": 237,
                  "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "MonoIgnoreThen.java",
                  "lineNumber": 204,
                  "className": "reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "FluxPeek.java",
                  "lineNumber": 260,
                  "className": "reactor.core.publisher.FluxPeek$PeekSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "SerializedSubscriber.java",
                  "lineNumber": 146,
                  "className": "reactor.core.publisher.SerializedSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "FluxRetryWhen.java",
                  "lineNumber": 204,
                  "className": "reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "SerializedSubscriber.java",
                  "lineNumber": 146,
                  "className": "reactor.core.publisher.SerializedSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "FluxTimeout.java",
                  "lineNumber": 235,
                  "className": "reactor.core.publisher.FluxTimeout$TimeoutMainSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onComplete",
                  "fileName": "FluxTakeUntil.java",
                  "lineNumber": 122,
                  "className": "reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "FluxTakeUntil.java",
                  "lineNumber": 100,
                  "className": "reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "replayNormal",
                  "fileName": "FluxReplay.java",
                  "lineNumber": 877,
                  "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "replay",
                  "fileName": "FluxReplay.java",
                  "lineNumber": 965,
                  "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "FluxReplay.java",
                  "lineNumber": 1345,
                  "className": "reactor.core.publisher.FluxReplay$ReplaySubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "FluxPeek.java",
                  "lineNumber": 200,
                  "className": "reactor.core.publisher.FluxPeek$PeekSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "FluxPeek.java",
                  "lineNumber": 200,
                  "className": "reactor.core.publisher.FluxPeek$PeekSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "FluxMap.java",
                  "lineNumber": 122,
                  "className": "reactor.core.publisher.FluxMap$MapSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "tryOnNext",
                  "fileName": "FluxDistinctUntilChanged.java",
                  "lineNumber": 149,
                  "className": "reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "FluxDistinctUntilChanged.java",
                  "lineNumber": 102,
                  "className": "reactor.core.publisher.FluxDistinctUntilChanged$DistinctUntilChangedSubscriber",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "replayNormal",
                  "fileName": "FluxReplay.java",
                  "lineNumber": 877,
                  "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "replay",
                  "fileName": "FluxReplay.java",
                  "lineNumber": 965,
                  "className": "reactor.core.publisher.FluxReplay$SizeBoundReplayBuffer",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "tryEmitNext",
                  "fileName": "SinkManyReplayProcessor.java",
                  "lineNumber": 477,
                  "className": "reactor.core.publisher.SinkManyReplayProcessor",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "tryEmitNext",
                  "fileName": "SinkManySerialized.java",
                  "lineNumber": 100,
                  "className": "reactor.core.publisher.SinkManySerialized",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "emitNext",
                  "fileName": "InternalManySink.java",
                  "lineNumber": 27,
                  "className": "reactor.core.publisher.InternalManySink",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onNext",
                  "fileName": "Handler.java",
                  "lineNumber": 91,
                  "className": "com.azure.core.amqp.implementation.handler.Handler",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "onLinkRemoteOpen",
                  "fileName": "SendLinkHandler.java",
                  "lineNumber": 140,
                  "className": "com.azure.core.amqp.implementation.handler.SendLinkHandler",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "handle",
                  "fileName": "BaseHandler.java",
                  "lineNumber": 164,
                  "className": "org.apache.qpid.proton.engine.BaseHandler",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "dispatch",
                  "fileName": "EventImpl.java",
                  "lineNumber": 108,
                  "className": "org.apache.qpid.proton.engine.impl.EventImpl",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "dispatch",
                  "fileName": "ReactorImpl.java",
                  "lineNumber": 324,
                  "className": "org.apache.qpid.proton.reactor.impl.ReactorImpl",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "process",
                  "fileName": "ReactorImpl.java",
                  "lineNumber": 291,
                  "className": "org.apache.qpid.proton.reactor.impl.ReactorImpl",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "run",
                  "fileName": "ReactorExecutor.java",
                  "lineNumber": 91,
                  "className": "com.azure.core.amqp.implementation.ReactorExecutor",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "call",
                  "fileName": "SchedulerTask.java",
                  "lineNumber": 68,
                  "className": "reactor.core.scheduler.SchedulerTask",
                  "nativeMethod": false
                },
                {
                  "classLoaderName": "app",
                  "methodName": "call",
                  "fileName": "SchedulerTask.java",
                  "lineNumber": 28,
                  "className": "reactor.core.scheduler.SchedulerTask",
                  "nativeMethod": false
                },
                {
                  "moduleName": "java.base",
                  "moduleVersion": "21.0.4",
                  "methodName": "run",
                  "lineNumber": -1,
                  "className": "java.util.concurrent.FutureTask",
                  "nativeMethod": false
                },
                {
                  "moduleName": "java.base",
                  "moduleVersion": "21.0.4",
                  "methodName": "run",
                  "lineNumber": -1,
                  "className": "java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask",
                  "nativeMethod": false
                },
                {
                  "moduleName": "java.base",
                  "moduleVersion": "21.0.4",
                  "methodName": "runWorker",
                  "lineNumber": -1,
                  "className": "java.util.concurrent.ThreadPoolExecutor",
                  "nativeMethod": false
                },
                {
                  "moduleName": "java.base",
                  "moduleVersion": "21.0.4",
                  "methodName": "run",
                  "lineNumber": -1,
                  "className": "java.util.concurrent.ThreadPoolExecutor$Worker",
                  "nativeMethod": false
                },
                {
                  "moduleName": "java.base",
                  "moduleVersion": "21.0.4",
                  "methodName": "run",
                  "lineNumber": -1,
                  "className": "java.lang.Thread",
                  "nativeMethod": false
                }
              ],
              "transient": false,
              "reason": "MESSAGE_SIZE_EXCEEDED",
              "message": "Size of the payload exceeded maximum message size: 256 kb, errorContext[NAMESPACE: ...]",
              "suppressed": [],
              "localizedMessage": "Size of the payload exceeded maximum message size: 256 kb, errorContext[NAMESPACE: ...]"
            }
          }
        }
      }
    },
    "db": {
      "status": "UP",
      "details": {
        "database": "Microsoft SQL Server",
        "validationQuery": "isValid()"
      }
    }
  },
  "groups": [
    "liveness",
    "readiness"
  ]
}

The text was updated successfully, but these errors were encountered:

joshfree · 2025-02-11T22:17:02Z

Someone from the Azure Spring team will follow up with you shortly.

/cc @saragluna @anuchandy

joshfree added azure-spring All azure-spring related issues azure-spring-servicebus Spring service bus related issues. labels Feb 11, 2025

github-project-automation bot added this to Spring Cloud Azure Feb 11, 2025

github-project-automation bot moved this to Todo in Spring Cloud Azure Feb 11, 2025

github-actions bot removed the needs-triage Workflow: This is a new issue that needs to be triaged to the appropriate team. label Feb 11, 2025

joshfree added the needs-team-triage Workflow: This issue needs the team to triage. label Feb 11, 2025

saragluna assigned moarychan Feb 12, 2025

saragluna added this to the 2025-03 milestone Feb 12, 2025

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[BUG] `servicebus` binder response with `status=DOWN` if it can't process the event due to message payload size #44158

[BUG] `servicebus` binder response with `status=DOWN` if it can't process the event due to message payload size #44158

microarchitecture commented Feb 11, 2025 •

edited

Loading

joshfree commented Feb 11, 2025

[BUG] servicebus binder response with status=DOWN if it can't process the event due to message payload size #44158

[BUG] servicebus binder response with status=DOWN if it can't process the event due to message payload size #44158

Comments

microarchitecture commented Feb 11, 2025 • edited Loading

joshfree commented Feb 11, 2025

[BUG] `servicebus` binder response with `status=DOWN` if it can't process the event due to message payload size #44158

[BUG] `servicebus` binder response with `status=DOWN` if it can't process the event due to message payload size #44158

microarchitecture commented Feb 11, 2025 •

edited

Loading