diff options
Diffstat (limited to 'src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java')
| -rw-r--r-- | src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java b/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java index abf3736..8936bea 100644 --- a/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java +++ b/src/main/java/org/onap/dmaap/mr/client/MRClientBuilders.java @@ -163,7 +163,11 @@ public class MRClientBuilders if ( sfConsumerMock != null ) return sfConsumerMock; try { - return new MRConsumerImpl ( fHosts, fTopic, fGroup, fId, fTimeoutMs, fLimit, fFilter, fApiKey, fApiSecret ); + return new MRConsumerImpl.MRConsumerImplBuilder().setHostPart(fHosts) + .setTopic(fTopic).setConsumerGroup(fGroup).setConsumerId(fId) + .setTimeoutMs(fTimeoutMs).setLimit(fLimit).setFilter(fFilter) + .setApiKey_username(fApiKey).setApiSecret_password(fApiSecret) + .createMRConsumerImpl(); } catch (MalformedURLException e) { throw new IllegalArgumentException(e); } |