|
@@ -30,6 +30,7 @@ import org.slf4j.LoggerFactory;
|
30
|
30
|
import net.engio.mbassy.bus.MBassador;
|
31
|
31
|
import net.engio.mbassy.bus.config.BusConfiguration;
|
32
|
32
|
import net.engio.mbassy.bus.config.Feature;
|
|
33
|
+import net.engio.mbassy.bus.config.IBusConfiguration;
|
33
|
34
|
|
34
|
35
|
import static com.dmdirc.util.LogUtils.APP_ERROR;
|
35
|
36
|
|
|
@@ -41,21 +42,18 @@ public class DMDircMBassador extends MBassador<DMDircEvent> {
|
41
|
42
|
private static final Logger LOG = LoggerFactory.getLogger(DMDircMBassador.class);
|
42
|
43
|
|
43
|
44
|
public DMDircMBassador() {
|
44
|
|
- super(new BusConfiguration().addFeature(Feature.SyncPubSub.Default())
|
45
|
|
- .addFeature(Feature.AsynchronousHandlerInvocation.Default(1, 1)).addFeature(
|
|
45
|
+ this(new BusConfiguration()
|
|
46
|
+ .addFeature(Feature.SyncPubSub.Default())
|
|
47
|
+ .addFeature(Feature.AsynchronousHandlerInvocation.Default(1, 1))
|
|
48
|
+ .addFeature(
|
46
|
49
|
Feature.AsynchronousMessageDispatch.Default()
|
47
|
50
|
.setNumberOfMessageDispatchers(1)));
|
48
|
|
- setupErrorHandler();
|
49
|
51
|
}
|
50
|
52
|
|
51
|
53
|
@SuppressWarnings("TypeMayBeWeakened")
|
52
|
|
- public DMDircMBassador(final BusConfiguration configuration) {
|
53
|
|
- super(configuration);
|
54
|
|
- setupErrorHandler();
|
|
54
|
+ public DMDircMBassador(final IBusConfiguration configuration) {
|
|
55
|
+ super(configuration.addPublicationErrorHandler(
|
|
56
|
+ e -> LOG.error(APP_ERROR, "Error caused by event bus handler", e.getCause())));
|
55
|
57
|
}
|
56
|
58
|
|
57
|
|
- private void setupErrorHandler() {
|
58
|
|
- addErrorHandler(e ->
|
59
|
|
- LOG.error(APP_ERROR, "Error caused by event bus handler", e.getCause()));
|
60
|
|
- }
|
61
|
59
|
}
|