Skip to content

Commit

Permalink
add since annotation to new methods in GenericTarget;
Browse files Browse the repository at this point in the history
Signed-off-by: Stefan Maute <stefan.maute@bosch.io>
  • Loading branch information
Stefan Maute committed Jul 21, 2021
1 parent 0fe4f38 commit 7c6d575
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -37,6 +37,7 @@ public interface GenericTarget {

/**
* @return the optional qos value of this target - only applicable for certain {@link ConnectionType}s.
* @since 2.1.0
*/
Optional<Integer> getQos();

Expand All @@ -45,6 +46,7 @@ public interface GenericTarget {
*
* @param newAddress new value for the address field.
* @return a copy of this object retaining the class and all other fields.
* @since 2.1.0
*/
GenericTarget withAddress(final String newAddress);
}
Original file line number Diff line number Diff line change
Expand Up @@ -358,4 +358,5 @@ public Target build() {
return new ImmutableTarget(this);
}
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -357,6 +357,7 @@ private AmqpMessageContext newContextWithoutProducer(final AmqpTarget publishTar
.dittoHeaders(message.getInternalHeaders())
.build();
resultFuture.completeExceptionally(sendFailedException);

return resultFuture;
};
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -272,6 +272,7 @@ private boolean isQuotaSufficient(final JsonField field) {
private boolean isDebugEnabled() {
final Map<String, String> specificConfig = connection.getSpecificConfig();
return Boolean.parseBoolean(specificConfig.getOrDefault("debugEnabled", Boolean.FALSE.toString()));

}

}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,4 +70,5 @@ public String toString() {
", qos=" + qos +
"]";
}

}

0 comments on commit 7c6d575

Please sign in to comment.