You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/08/14 13:20:35 UTC
[camel] 04/04: Fix merge conflicts
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 3a82e8f6fea7b3ba1d6009524626a2fac78561b2
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Aug 14 15:20:00 2019 +0200
Fix merge conflicts
---
.../pulsar/PulsarConsumerAcknowledgementTest.java | 2 +-
.../pulsar/PulsarConsumerNoAcknowledgementTest.java | 2 +-
.../pulsar/PulsarCustomMessageReceiptTest.java | 17 +++++++++--------
.../pulsar/PulsarNegativeAcknowledgementTest.java | 4 ++--
4 files changed, 13 insertions(+), 12 deletions(-)
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerAcknowledgementTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerAcknowledgementTest.java
index 5f45684..0ce2dcc 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerAcknowledgementTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerAcknowledgementTest.java
@@ -53,7 +53,7 @@ public class PulsarConsumerAcknowledgementTest extends PulsarTestSupport {
@EndpointInject(uri = "mock:result")
private MockEndpoint to;
- Producer<String> producer;
+ private Producer<String> producer;
@Before
public void setup() throws Exception {
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java
index 6f68fc1..1cb5527 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerNoAcknowledgementTest.java
@@ -17,7 +17,7 @@
package org.apache.camel.component.pulsar;
import java.util.concurrent.TimeUnit;
-import org.apache.camel.CamelContext;
+
import org.apache.camel.Endpoint;
import org.apache.camel.EndpointInject;
import org.apache.camel.builder.RouteBuilder;
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java
index e579b59..24a9132 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarCustomMessageReceiptTest.java
@@ -16,14 +16,8 @@
*/
package org.apache.camel.component.pulsar;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.atLeast;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.verifyNoMoreInteractions;
-import static org.mockito.Mockito.when;
-
import java.util.concurrent.TimeUnit;
+
import org.apache.camel.Endpoint;
import org.apache.camel.EndpointInject;
import org.apache.camel.builder.RouteBuilder;
@@ -41,6 +35,13 @@ import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.atLeast;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.verifyNoMoreInteractions;
+import static org.mockito.Mockito.when;
+
public class PulsarCustomMessageReceiptTest extends PulsarTestSupport {
private static final Logger LOGGER = LoggerFactory.getLogger(PulsarCustomMessageReceiptTest.class);
@@ -63,7 +64,7 @@ public class PulsarCustomMessageReceiptTest extends PulsarTestSupport {
@EndpointInject(uri = "mock:result")
private MockEndpoint to;
- Producer<String> producer;
+ private Producer<String> producer;
@Before
public void setup() throws Exception {
diff --git a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarNegativeAcknowledgementTest.java b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarNegativeAcknowledgementTest.java
index ebee09e..abb76a0 100644
--- a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarNegativeAcknowledgementTest.java
+++ b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarNegativeAcknowledgementTest.java
@@ -16,12 +16,12 @@
*/
package org.apache.camel.component.pulsar;
-import static org.mockito.Mockito.mock;
-
import org.apache.pulsar.client.api.Consumer;
import org.apache.pulsar.client.api.MessageId;
import org.junit.Test;
+import static org.mockito.Mockito.mock;
+
public class PulsarNegativeAcknowledgementTest {
@Test(expected = UnsupportedOperationException.class)