Adding equals/hashcode and toString to SpringMongoSubscriptionModel, …

…this is useful in certain debug logging scenarios

changelog.md

@@ -1,6 +1,7 @@
 ### Changelog next version
 * Converted `org.occurrent.subscription.OccurrentSubscriptionFilter` from a Java class to a record. This means that the `public final` filter instance field is now a record property. So if you ever used `occurrentSubscriptionFilter.filter` to access the underlying filter, you now need to do `occurrentSubscriptionFilter.filter()` instead.
 * Fixed a bug in MongoLeaseCompetingConsumerStrategySupport in which it was not marked a running on start. This could affect retries of certain competing consumer errors.
+* Adding equals/hashcode and toString to SpringMongoSubscriptionModel, this is useful in certain debug logging scenarios 
 
 ### 0.19.7 (2024-11-01)
 * Implemented "in" conditions so you can now do e.g. `subscriptionModel.subscribe("id", OccurrentSubscriptionFilter.filter(Filter.streamVersion(Condition.in(12L, 14L))`. There's also a Kotlin extension function, `isIn`, which can be imported from `org.occurrent.condition.isIn`.

subscription/mongodb/spring/blocking/src/main/java/org/occurrent/subscription/mongodb/spring/blocking/SpringMongoSubscriptionModel.java

@@ -444,4 +444,31 @@ private static void logDebug(String message, Object... params) {
             log.debug(message, params);
         }
     }
+
+
+    @Override
+    public boolean equals(Object o) {
+        if (!(o instanceof SpringMongoSubscriptionModel that)) return false;
+        return restartSubscriptionsOnChangeStreamHistoryLost == that.restartSubscriptionsOnChangeStreamHistoryLost && shutdown == that.shutdown && Objects.equals(eventCollection, that.eventCollection) && Objects.equals(messageListenerContainer, that.messageListenerContainer) && Objects.equals(runningSubscriptions, that.runningSubscriptions) && Objects.equals(pausedSubscriptions, that.pausedSubscriptions) && timeRepresentation == that.timeRepresentation && Objects.equals(mongoOperations, that.mongoOperations) && Objects.equals(retryStrategy, that.retryStrategy);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(eventCollection, messageListenerContainer, runningSubscriptions, pausedSubscriptions, timeRepresentation, mongoOperations, retryStrategy, restartSubscriptionsOnChangeStreamHistoryLost, shutdown);
+    }
+
+    @Override
+    public String toString() {
+        return new StringJoiner(", ", SpringMongoSubscriptionModel.class.getSimpleName() + "[", "]")
+                .add("eventCollection='" + eventCollection + "'")
+                .add("messageListenerContainer=" + messageListenerContainer)
+                .add("runningSubscriptions=" + runningSubscriptions)
+                .add("pausedSubscriptions=" + pausedSubscriptions)
+                .add("timeRepresentation=" + timeRepresentation)
+                .add("mongoOperations=" + mongoOperations)
+                .add("retryStrategy=" + retryStrategy)
+                .add("restartSubscriptionsOnChangeStreamHistoryLost=" + restartSubscriptionsOnChangeStreamHistoryLost)
+                .add("shutdown=" + shutdown)
+                .toString();
+    }
 }

subscription/util/blocking/competing-consumer-subscription/src/main/java/org/occurrent/subscription/blocking/competingconsumers/CompetingConsumerSubscriptionModel.java

@@ -192,6 +192,7 @@ public boolean isPaused(String subscriptionId) {
     public synchronized Subscription resumeSubscription(String subscriptionId) {
         logDebug("Trying to resume CompetingConsumer subscription (subscriptionId={})", subscriptionId);
         if (isRunning(subscriptionId)) {
+            logDebug("Subscription already is running, cannot resume (subscriptionId={}, delegate={})", subscriptionId, delegate.toString());
             throw new IllegalArgumentException("Subscription " + subscriptionId + " is not paused");
         }