Skip to content

Commit

Permalink
remove config getters as they are not used
Browse files Browse the repository at this point in the history
  • Loading branch information
grimmjo committed Oct 25, 2023
1 parent d86badc commit f73f1db
Show file tree
Hide file tree
Showing 10 changed files with 27 additions and 384 deletions.
16 changes: 0 additions & 16 deletions nats/src/main/java/io/micronaut/nats/connect/ConsumerLimits.java
Original file line number Diff line number Diff line change
Expand Up @@ -40,14 +40,6 @@ io.nats.client.api.ConsumerLimits build() {
.build();
}

/**
* Inactive threshold.
* @return duration
*/
public Duration getInactiveThreshold() {
return inactiveThreshold;
}

/**
* Inactive threshold.
* @param inactiveThreshold {@link Duration}
Expand All @@ -56,14 +48,6 @@ public void setInactiveThreshold(Duration inactiveThreshold) {
this.inactiveThreshold = inactiveThreshold;
}

/**
* Maximal acknowledgments pending.
* @return maxAckPending
*/
public Long getMaxAckPending() {
return maxAckPending;
}

/**
* Maximal acknowledgments pending.
* @param maxAckPending {@link Long}
Expand Down
14 changes: 7 additions & 7 deletions nats/src/main/java/io/micronaut/nats/connect/Mirror.java
Original file line number Diff line number Diff line change
Expand Up @@ -32,14 +32,14 @@ public abstract class Mirror<T extends SubjectTransformBase, E extends SourceBas
*/
public io.nats.client.api.Mirror build() {
io.nats.client.api.Mirror.Builder builder = io.nats.client.api.Mirror.builder()
.name(getName())
.filterSubject(getFilterSubject())
.startSeq(getStartSeq())
.startTime(getStartTime())
.subjectTransforms(getSubjectTransforms().stream().map(SubjectTransformBase::build)
.name(name)
.filterSubject(filterSubject)
.startSeq(startSeq)
.startTime(startTime)
.subjectTransforms(subjectTransforms.stream().map(SubjectTransformBase::build)
.toList());
if (getExternal() != null) {
builder = builder.external(getExternal().build());
if (external != null) {
builder = builder.external(external.build());
}
return builder.build();
}
Expand Down
Loading

0 comments on commit f73f1db

Please sign in to comment.