Merge branch 'feature/27616-mappings-extraction' of github.com:hivemq…

…/hivemq-edge into feature/27616-mappings-extraction
hivemq · Nov 26, 2024 · 405357e · 405357e
2 parents 47e9b5c + 86acaba
commit 405357e
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/hivemq-edge/src/test/java/com/hivemq/protocols/ProtocolAdapterManagerTest.java b/hivemq-edge/src/test/java/com/hivemq/protocols/ProtocolAdapterManagerTest.java
@@ -122,7 +122,7 @@ void test_startWritingAdapterSucceeded_eventsFired() throws Exception {
                 any())).thenReturn(CompletableFuture.completedFuture(null));
         when(eventService.createAdapterEvent(anyString(), anyString())).thenReturn(eventBuilder);
 
-        final ProtocolAdapterWrapper<TestWritingAdapter> adapterWrapper = new ProtocolAdapterWrapper<>(mock(),
+        final ProtocolAdapterWrapper adapterWrapper = new ProtocolAdapterWrapper(mock(),
                 new TestWritingAdapter(true),
                 mock(),
                 mock(),
@@ -147,7 +147,7 @@ void test_startWritingNotEnabled_notStarted() throws Exception {
         when(protocolAdapterWritingService.writingEnabled()).thenReturn(false);
         when(eventService.createAdapterEvent(anyString(), anyString())).thenReturn(eventBuilder);
 
-        final ProtocolAdapterWrapper<TestWritingAdapter> adapterWrapper = new ProtocolAdapterWrapper<>(mock(),
+        final ProtocolAdapterWrapper adapterWrapper = new ProtocolAdapterWrapper(mock(),
                 new TestWritingAdapter(true),
                 mock(),
                 mock(),
@@ -176,7 +176,7 @@ void test_startWriting_adapterFailedStart_resourcesCleanedUp() {
                 any())).thenReturn(CompletableFuture.completedFuture(null));
         when(eventService.createAdapterEvent(anyString(), anyString())).thenReturn(eventBuilder);
 
-        final ProtocolAdapterWrapper<TestWritingAdapter> adapterWrapper = new ProtocolAdapterWrapper<>(mock(),
+        final ProtocolAdapterWrapper adapterWrapper = new ProtocolAdapterWrapper(mock(),
                 new TestWritingAdapter(false),
                 mock(),
                 mock(),
@@ -191,7 +191,7 @@ void test_startWriting_adapterFailedStart_resourcesCleanedUp() {
 
         assertEquals(ProtocolAdapterState.RuntimeStatus.STOPPED, adapterWrapper.getRuntimeStatus());
         verify(remoteService).fireUsageEvent(any());
-        verify(protocolAdapterWritingService).stopWriting(adapterWrapper.getAdapter());
+        verify(protocolAdapterWritingService).stopWriting((WritingProtocolAdapter<WritingContext>) adapterWrapper.getAdapter());
     }
 
     @Test
@@ -204,7 +204,7 @@ void test_startWriting_eventServiceFailedStart_resourcesCleanedUp() {
         when(eventService.createAdapterEvent(anyString(),
                 anyString())).thenThrow(new RuntimeException("we failed start"));
 
-        final ProtocolAdapterWrapper<TestWritingAdapter> adapterWrapper = new ProtocolAdapterWrapper<>(mock(),
+        final ProtocolAdapterWrapper adapterWrapper = new ProtocolAdapterWrapper(mock(),
                 new TestWritingAdapter(false),
                 mock(),
                 mock(),
@@ -219,7 +219,7 @@ void test_startWriting_eventServiceFailedStart_resourcesCleanedUp() {
 
         assertEquals(ProtocolAdapterState.RuntimeStatus.STOPPED, adapterWrapper.getRuntimeStatus());
         verify(remoteService, never()).fireUsageEvent(any());
-        verify(protocolAdapterWritingService).stopWriting(adapterWrapper.getAdapter());
+        verify(protocolAdapterWritingService).stopWriting((WritingProtocolAdapter<WritingContext>) adapterWrapper.getAdapter());
     }
 
     @Test
@@ -231,7 +231,7 @@ void test_stopWritingAdapterSucceeded_eventsFired() throws Exception {
         when(protocolAdapterWritingService.stopWriting(any())).thenReturn(CompletableFuture.completedFuture(null));
         when(eventService.createAdapterEvent(anyString(), anyString())).thenReturn(eventBuilder);
 
-        final ProtocolAdapterWrapper<TestWritingAdapter> adapterWrapper = new ProtocolAdapterWrapper<>(mock(),
+        final ProtocolAdapterWrapper adapterWrapper = new ProtocolAdapterWrapper(mock(),
                 new TestWritingAdapter(true),
                 mock(),
                 mock(),
@@ -258,7 +258,7 @@ void test_stopWritingAdapterFailed_eventsFired() throws Exception {
         when(protocolAdapterWritingService.stopWriting(any())).thenReturn(CompletableFuture.completedFuture(null));
         when(eventService.createAdapterEvent(anyString(), anyString())).thenReturn(eventBuilder);
 
-        final ProtocolAdapterWrapper<TestWritingAdapter> adapterWrapper = new ProtocolAdapterWrapper<>(mock(),
+        final ProtocolAdapterWrapper adapterWrapper = new ProtocolAdapterWrapper(mock(),
                 new TestWritingAdapter(false),
                 mock(),
                 mock(),