Package net.engio.mbassy.bus.config

Examples of net.engio.mbassy.bus.config.BusConfiguration.addFeature()

19
20
21
22
23
24
25
26
27
28
29
     *
     * @return
     */
    public static SyncMessageBus SynchronousOnly(){
        BusConfiguration syncPubSubCfg = new BusConfiguration();
        syncPubSubCfg.addFeature(Feature.SyncPubSub.Default());
        return new SyncMessageBus(syncPubSubCfg);
    }

    /**
     * Create a message bus supporting synchronous and asynchronous message publication.
View Full Code Here
33
34
35
36
37
38
39
40
41
42
43
     *
     * @return
     */
    public static IMessageBus AsynchronousSequentialFIFO(){
        BusConfiguration asyncFIFOConfig = new BusConfiguration();
        asyncFIFOConfig.addFeature(Feature.SyncPubSub.Default());
        asyncFIFOConfig.addFeature(Feature.AsynchronousHandlerInvocation.Default(1, 1));
        asyncFIFOConfig.addFeature(Feature.AsynchronousMessageDispatch.Default().setNumberOfMessageDispatchers(1));
        return new MBassador(asyncFIFOConfig);
    }
}
View Full Code Here
34
35
36
37
38
39
40
41
42
43
     * @return
     */
    public static IMessageBus AsynchronousSequentialFIFO(){
        BusConfiguration asyncFIFOConfig = new BusConfiguration();
        asyncFIFOConfig.addFeature(Feature.SyncPubSub.Default());
        asyncFIFOConfig.addFeature(Feature.AsynchronousHandlerInvocation.Default(1, 1));
        asyncFIFOConfig.addFeature(Feature.AsynchronousMessageDispatch.Default().setNumberOfMessageDispatchers(1));
        return new MBassador(asyncFIFOConfig);
    }
}
View Full Code Here
35
36
37
38
39
40
41
42
43
     */
    public static IMessageBus AsynchronousSequentialFIFO(){
        BusConfiguration asyncFIFOConfig = new BusConfiguration();
        asyncFIFOConfig.addFeature(Feature.SyncPubSub.Default());
        asyncFIFOConfig.addFeature(Feature.AsynchronousHandlerInvocation.Default(1, 1));
        asyncFIFOConfig.addFeature(Feature.AsynchronousMessageDispatch.Default().setNumberOfMessageDispatchers(1));
        return new MBassador(asyncFIFOConfig);
    }
}
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.