Skip to content

Commit

Permalink
feat: add large message support and remove deprecated features
Browse files Browse the repository at this point in the history
  • Loading branch information
helios57 committed Jul 31, 2024
1 parent 3c894eb commit 840880c
Show file tree
Hide file tree
Showing 64 changed files with 6,697 additions and 10,010 deletions.
5 changes: 0 additions & 5 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -208,11 +208,6 @@
<artifactId>gson-fire</artifactId>
<version>1.9.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
Expand Down

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@ public class BasicInboundXMLMessageListener extends InboundXMLMessageListener {
BasicInboundXMLMessageListener(FlowReceiverContainer flowReceiverContainer,
ConsumerDestination consumerDestination,
ExtendedConsumerProperties<SolaceConsumerProperties> consumerProperties,
@Nullable BatchCollector batchCollector,
Consumer<Message<?>> messageConsumer,
JCSMPAcknowledgementCallbackFactory ackCallbackFactory,
BiFunction<Message<?>, RuntimeException, Boolean> errorHandlerFunction,
Expand All @@ -38,7 +37,6 @@ public class BasicInboundXMLMessageListener extends InboundXMLMessageListener {
super(flowReceiverContainer,
consumerDestination,
consumerProperties,
batchCollector,
messageConsumer,
ackCallbackFactory,
solaceMeterAccessor,
Expand All @@ -51,7 +49,7 @@ public class BasicInboundXMLMessageListener extends InboundXMLMessageListener {

@Override
void handleMessage(Supplier<Message<?>> messageSupplier, Consumer<Message<?>> sendToConsumerHandler,
AcknowledgmentCallback acknowledgmentCallback, boolean isBatched)
AcknowledgmentCallback acknowledgmentCallback)
throws SolaceAcknowledgmentException {
Message<?> message;
try {
Expand All @@ -61,9 +59,8 @@ void handleMessage(Supplier<Message<?>> messageSupplier, Consumer<Message<?>> se
if (processedByErrorHandler) {
AckUtils.autoAck(acknowledgmentCallback);
} else {
log.warn(String.format("Failed to map %s to a Spring Message and no error channel " +
"was configured. Message will be rejected.", isBatched ? "a batch of XMLMessages" :
"an XMLMessage"), e);
log.warn("Failed to map %s to a Spring Message and no error channel " +
"was configured. Message will be rejected. an XMLMessage", e);
if (!SolaceAckUtil.republishToErrorQueue(acknowledgmentCallback)) {
AckUtils.requeue(acknowledgmentCallback);
}
Expand Down

This file was deleted.

Loading

0 comments on commit 840880c

Please sign in to comment.