@@ -122,7 +122,7 @@ private void pollAllAndProcess(PollAll pollAll) {
122
122
Arrays .stream (messages ).forEach (message -> this .processMail ((IMAPMessage ) message , pollAll ));
123
123
} catch (Exception e ) {
124
124
this .connectorContext .log (
125
- Activity .level (Severity .ERROR ).tag ("mail-polling" ).message (e .getMessage ()));
125
+ Activity .level (Severity .ERROR ).tag ("mail-polling" ).message (e .getMessage ()));
126
126
this .connectorContext .cancel (new ConnectorException (e .getMessage (), e ));
127
127
}
128
128
}
@@ -135,20 +135,18 @@ private void pollUnseenAndProcess(PollUnseen pollUnseen) {
135
135
.forEach (message -> this .processMail ((IMAPMessage ) message , pollUnseen ));
136
136
} catch (Exception e ) {
137
137
this .connectorContext .log (
138
- Activity .level (Severity .ERROR ).tag ("mail-polling" ).message (e .getMessage ()));
138
+ Activity .level (Severity .ERROR ).tag ("mail-polling" ).message (e .getMessage ()));
139
139
this .connectorContext .cancel (
140
- ConnectorRetryException .builder ()
141
- .cause (e )
142
- .message (e .getMessage ())
143
- .retries (2 )
144
- .backoffDuration (Duration .of (3 , ChronoUnit .SECONDS ))
145
- .build ());
140
+ ConnectorRetryException .builder ()
141
+ .cause (e )
142
+ .message (e .getMessage ())
143
+ .retries (2 )
144
+ .backoffDuration (Duration .of (3 , ChronoUnit .SECONDS ))
145
+ .build ());
146
146
}
147
147
}
148
148
149
- private void manageException (Exception e ) {
150
-
151
- }
149
+ private void manageException (Exception e ) {}
152
150
153
151
private void processMail (IMAPMessage message , PollingConfig pollingConfig ) {
154
152
// Setting `peek` to true prevents the library to trigger any side effects when reading the
0 commit comments