Skip to content

Commit cea1f5a

Browse files
committed
chore: remove deprecated methods in persistent subscriptions and recorded event
1 parent 82934af commit cea1f5a

File tree

2 files changed

+0
-50
lines changed

2 files changed

+0
-50
lines changed

src/main/java/io/kurrent/dbclient/AbstractPersistentSubscriptionSettingsBuilder.java

-41
Original file line numberDiff line numberDiff line change
@@ -9,31 +9,6 @@ public AbstractPersistentSubscriptionSettingsBuilder(TSettings settings) {
99
this.settings = settings;
1010
}
1111

12-
/**
13-
* @deprecated prefer {@link AbstractPersistentSubscriptionSettingsBuilder#resolveLinkTos()}
14-
*/
15-
@Deprecated
16-
public T enableLinkResolution() {
17-
return resolveLinks(true);
18-
}
19-
20-
/**
21-
* @deprecated prefer {@link AbstractPersistentSubscriptionSettingsBuilder#notResolveLinkTos()}
22-
*/
23-
@Deprecated
24-
public T disableLinkResolution() {
25-
return resolveLinks(false);
26-
}
27-
28-
/**
29-
* @deprecated prefer {@link AbstractPersistentSubscriptionSettingsBuilder#resolveLinkTos(boolean value)}
30-
*/
31-
@Deprecated
32-
@SuppressWarnings("unchecked")
33-
public T resolveLinks(boolean value) {
34-
return (T) resolveLinkTos(value);
35-
}
36-
3712
/**
3813
* Whether the subscription should resolve linkTo events to their linked events. Default: false.
3914
*/
@@ -116,14 +91,6 @@ public T liveBufferSize(int value) {
11691
return (T) this;
11792
}
11893

119-
/**
120-
* @deprecated prefer {@link AbstractPersistentSubscriptionSettingsBuilder#checkpointUpperBound(int value)}
121-
*/
122-
@Deprecated
123-
public T maxCheckpointCount(int value) {
124-
return checkpointUpperBound(value);
125-
}
126-
12794
/**
12895
* The maximum number of messages not checkpointed before forcing a checkpoint. Default: 1000.
12996
*/
@@ -133,14 +100,6 @@ public T checkpointUpperBound(int value) {
133100
return (T) this;
134101
}
135102

136-
/**
137-
* @deprecated prefer {@link AbstractPersistentSubscriptionSettingsBuilder#checkpointLowerBound(int value)}
138-
*/
139-
@Deprecated
140-
public T minCheckpointCount(int value) {
141-
return this.checkpointLowerBound(value);
142-
}
143-
144103
/**
145104
* The minimum number of messages to process before a checkpoint may be written. Default: 10.
146105
*/

src/main/java/io/kurrent/dbclient/RecordedEvent.java

-9
Original file line numberDiff line numberDiff line change
@@ -107,15 +107,6 @@ public byte[] getEventData() {
107107
return eventData;
108108
}
109109

110-
/**
111-
* Deserialized representation of the event's payload. In this case, the payload is supposed to be JSON.
112-
*/
113-
@Deprecated
114-
public <A> A getEventDataAs(Class<A> clazz) throws IOException {
115-
JsonMapper mapper = new JsonMapper();
116-
return mapper.readValue(this.getEventData(), clazz);
117-
}
118-
119110
/**
120111
* The event's metadata.
121112
*/

0 commit comments

Comments
 (0)