Skip to content

Commit

Permalink
removed duplicate copyright header;
Browse files Browse the repository at this point in the history
  • Loading branch information
Stefan Maute committed Oct 21, 2020
1 parent af38975 commit bead292
Show file tree
Hide file tree
Showing 3 changed files with 1 addition and 28 deletions.
Expand Up @@ -11,19 +11,6 @@
* SPDX-License-Identifier: EPL-2.0
*/

/*
* Copyright Bosch.IO GmbH 2020
*
* All rights reserved, also regarding any disposal, exploitation,
* reproduction, editing, distribution, as well as in the event of
* applications for industrial property rights.
*
* This software is the confidential and proprietary information
* of Bosch.IO GmbH. You shall not disclose
* such Confidential Information and shall use it only in
* accordance with the terms of the license agreement you
* entered into with Bosch.IO GmbH.
*/
package org.eclipse.ditto.services.connectivity.config;

import java.util.concurrent.CompletionStage;
Expand Down
Expand Up @@ -11,20 +11,6 @@
* SPDX-License-Identifier: EPL-2.0
*/

/*
* Copyright Bosch.IO GmbH 2020
*
* All rights reserved, also regarding any disposal, exploitation,
* reproduction, editing, distribution, as well as in the event of
* applications for industrial property rights.
*
* This software is the confidential and proprietary information
* of Bosch.IO GmbH. You shall not disclose
* such Confidential Information and shall use it only in
* accordance with the terms of the license agreement you
* entered into with Bosch.IO GmbH.
*/

package org.eclipse.ditto.services.connectivity.config;

import java.util.Collections;
Expand Down
Expand Up @@ -437,7 +437,7 @@ public ConnectivityConfigProvider getConnectivityConfigProvider() {
public void configModified(final ConnectivityConfig connectivityConfig) {
this.connectivityConfig = connectivityConfig;
final Amqp10Config amqp10Config = connectivityConfig.getConnectionConfig().getAmqp10Config();
messageRateLimiter.getRedeliveryExpectationTimeout();

if (messageRateLimiter != null
&& (messageRateLimiter.getMaxPerPeriod() != amqp10Config.getConsumerThrottlingLimit()
|| messageRateLimiter.getMaxInFlight() != amqp10Config.getConsumerMaxInFlight()
Expand Down

0 comments on commit bead292

Please sign in to comment.