@@ -107,49 +107,20 @@ public void testPost() throws InterruptedException, IOException {
107
107
final JsonNode actual = OBJECT_MAPPER .readTree (_wireMock .find (requestPattern ).get (0 ).getBody ());
108
108
final JsonNode expected = OBJECT_MAPPER .readTree (getClass ().getResource (getClass ().getSimpleName () + ".testPost.expected.json" ));
109
109
Assert .assertEquals (expected , actual );
110
-
111
- // Verify that metrics has been recorded.
112
- Mockito .verify (_mockMetricsFactory , Mockito .times (3 )).create ();
113
- Mockito .verify (_mockMetrics , Mockito .times (1 )).incrementCounter ("sinks/http_post/kairosdb_sink_test/success" , 1 );
114
- Mockito .verify (_mockMetrics , Mockito .times (1 )).incrementCounter ("sinks/http_post/kairosdb_sink_test/status/2xx" , 1 );
115
- Mockito .verify (_mockMetrics , Mockito .times (1 )).incrementCounter ("sinks/http_post/kairosdb_sink_test/samples_sent" , 10 );
116
- Mockito .verify (_mockMetrics , Mockito .times (1 )).setTimer (
117
- Mockito .matches ("sinks/http_post/kairosdb_sink_test/queue_time" ),
118
- Mockito .anyLong (),
119
- Mockito .any (TimeUnit .class ));
120
- Mockito .verify (_mockMetrics , Mockito .times (1 )).setTimer (
121
- Mockito .matches ("sinks/http_post/kairosdb_sink_test/request_latency" ),
122
- Mockito .anyLong (),
123
- Mockito .any (TimeUnit .class ));
124
- Mockito .verify (_mockMetrics , Mockito .times (3 )).close ();
125
110
}
126
111
127
112
@ Test
128
113
public void testPostFailure () throws InterruptedException , IOException {
129
- // Fake a successful post to KairosDb
114
+ // Fake a failing post to KairosDb
130
115
_wireMock .register (WireMock .post (WireMock .urlEqualTo (PATH ))
131
116
.willReturn (WireMock .aResponse ()
132
117
.withStatus (502 )));
133
118
_kairosDbSinkBuilder .setMaximumAttempts (2 ).setBaseBackoff (Duration .ofMillis (1 )).build ()
134
119
.recordAggregateData (createPeriodicData (10L ));
135
120
136
- Awaitility .await ().atMost (2 , TimeUnit .SECONDS ).untilAsserted (
121
+ Awaitility .await ().atMost (5 , TimeUnit .SECONDS ).untilAsserted (
137
122
() -> _wireMock .verifyThat (2 , WireMock .postRequestedFor (WireMock .urlEqualTo (PATH )))
138
123
);
139
-
140
- Mockito .verify (_mockMetricsFactory , Mockito .times (4 )).create ();
141
- Mockito .verify (_mockMetrics , Mockito .times (1 )).incrementCounter ("sinks/http_post/kairosdb_sink_test/status/5xx" , 1 );
142
- Mockito .verify (_mockMetrics , Mockito .times (1 )).incrementCounter ("sinks/http_post/kairosdb_sink_test/samples_dropped" , 10L );
143
- Mockito .verify (_mockMetrics , Mockito .times (1 )).setTimer (
144
- Mockito .matches ("sinks/http_post/kairosdb_sink_test/queue_time" ),
145
- Mockito .anyLong (),
146
- Mockito .any (TimeUnit .class ));
147
- Mockito .verify (_mockMetrics , Mockito .times (2 )).setTimer (
148
- Mockito .matches ("sinks/http_post/kairosdb_sink_test/request_latency" ),
149
- Mockito .anyLong (),
150
- Mockito .any (TimeUnit .class ));
151
- Mockito .verify (_mockMetrics , Mockito .times (1 )).incrementCounter ("sinks/http_post/kairosdb_sink_test/success" , 0 );
152
- Mockito .verify (_mockMetrics , Mockito .times (4 )).close ();
153
124
}
154
125
155
126
0 commit comments