Spring publisher confirmation when channel is closed

PubSub+ Event Broker
, ,
5

Hi @marc.dipasquale ,
Thanks for your reply. I’d like to reiterate that the error seems to occur when the Solace connection is reestablished in the application.

  1. The message queuing service connection was interrupted in the “consumer” app, using the Chaos Monkey service.
  2. A message was successfully published to the queue.
  3. The queue API GET request showed messageCount = 1 while the connection is out .
  4. The message queuing service is reestablished and the queue API GET request shows messageCount = 0.
  5. However, the message was not consumed by the “consumer” app .
    It seems that all messages in the queue are discarded when the connection is reestablished .

Is this possible?
Properties:
spring.cloud.stream.bindings.govConnSolaceInput.binder=solace
spring.cloud.stream.bindings.govConnSolaceInput.destination=gov-connector.v1.send-to-gov
spring.cloud.stream.bindings.govConnSolaceInput.group=gov-connector
spring.cloud.stream.bindings.govConnSolaceInput.consumer.concurrency=50
spring.cloud.stream.solace.bindings.govConnSolaceInput.consumer.queueNameExpression=destination.trim()
spring.cloud.stream.solace.bindings.govConnSolaceInput.consumer.errorQueueNameExpression=destination.trim() + ‘.error-queue’
spring.cloud.stream.solace.bindings.govConnSolaceInput.consumer.autoBindErrorQueue=false
spring.cloud.stream.solace.bindings.govConnSolaceInput.consumer.provisionDurableQueue=false
spring.cloud.stream.solace.bindings.govConnSolaceInput.consumer.addDestinationAsSubscriptionToQueue=false

Consumer code:

===================================================================================
@EnableBinding(MessageInputProcessor.class)
public class GovConnInputChannel {
private static final Logger LOGGER = LoggerFactory.getLogger(GovConnInputChannel.class);
@StreamListener(ChannelConstants.GOV_CONNECTOR_SOLACE_INPUT)
public void consumeSolace(@Payload GovernmentCommunicationRequest request) {
LOGGER.info(“Received message via Solace: {}.”, request);
}
}

Thanks for your suggestion, we have official Solace support and we are accessing them as well. ?