This is an automated email from the ASF dual-hosted git repository. tabish pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/qpid-protonj2.git
The following commit(s) were added to refs/heads/main by this push: new 8885fbbd PROTON-2711 Add single value API for setting source or target properties 8885fbbd is described below commit 8885fbbde71b923a1a36fe7e2971b754e838e7fd Author: Timothy Bish <tabish...@gmail.com> AuthorDate: Thu Apr 13 17:43:48 2023 -0400 PROTON-2711 Add single value API for setting source or target properties Allows for simple test setup when setting a source or target property that doesn't require creating the map instance. --- .../test/driver/actions/AttachInjectAction.java | 39 ++++++++++++++++++++++ 1 file changed, 39 insertions(+) diff --git a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/actions/AttachInjectAction.java b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/actions/AttachInjectAction.java index 081fa8c6..2ced891c 100644 --- a/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/actions/AttachInjectAction.java +++ b/protonj2-test-driver/src/main/java/org/apache/qpid/protonj2/test/driver/actions/AttachInjectAction.java @@ -417,6 +417,19 @@ public class AttachInjectAction extends AbstractPerformativeInjectAction<Attach> return this; } + public SourceBuilder withDynamicNodeProperty(String key, Object value) { + return withDynamicNodeProperty(Symbol.valueOf(key), value); + } + + public SourceBuilder withDynamicNodeProperty(Symbol key, Object value) { + if (source.getDynamicNodeProperties() == null) { + source.setDynamicNodeProperties(new LinkedHashMap<>()); + } + + source.getDynamicNodeProperties().put(key, value); + return this; + } + public SourceBuilder withDistributionMode(String mode) { source.setDistributionMode(Symbol.valueOf(mode)); return this; @@ -437,6 +450,19 @@ public class AttachInjectAction extends AbstractPerformativeInjectAction<Attach> return this; } + public SourceBuilder withFilterMap(String key, Object value) { + return withFilterMap(Symbol.valueOf(key), value); + } + + public SourceBuilder withFilterMap(Symbol key, Object value) { + if (source.getFilter() == null) { + source.setFilter(new LinkedHashMap<>()); + } + + source.getFilter().put(key, value); + return this; + } + public SourceBuilder withDefaultOutcome(Outcome outcome) { source.setDefaultOutcome((DescribedType) outcome); return this; @@ -521,6 +547,19 @@ public class AttachInjectAction extends AbstractPerformativeInjectAction<Attach> return this; } + public TargetBuilder withDynamicNodeProperty(String key, Object value) { + return withDynamicNodeProperty(Symbol.valueOf(key), value); + } + + public TargetBuilder withDynamicNodeProperty(Symbol key, Object value) { + if (target.getDynamicNodeProperties() == null) { + target.setDynamicNodeProperties(new LinkedHashMap<>()); + } + + target.getDynamicNodeProperties().put(key, value); + return this; + } + public TargetBuilder withCapabilities(String... capabilities) { target.setCapabilities(TypeMapper.toSymbolArray(capabilities)); return this; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org