• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java UiMessageHandler类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.onosproject.ui.UiMessageHandler的典型用法代码示例。如果您正苦于以下问题:Java UiMessageHandler类的具体用法?Java UiMessageHandler怎么用?Java UiMessageHandler使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



UiMessageHandler类属于org.onosproject.ui包,在下文中一共展示了UiMessageHandler类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: onMessage

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
@Override
public void onMessage(String data) {
    log.debug("onMessage: {}", data);
    lastActive = System.currentTimeMillis();
    try {
        ObjectNode message = (ObjectNode) mapper.reader().readTree(data);
        String type = message.path(EVENT).asText(UNKNOWN);
        UiMessageHandler handler = handlers.get(type);
        if (handler != null) {
            handler.process(message);
        } else {
            log.warn("No GUI message handler for type {}", type);
        }
    } catch (Exception e) {
        log.warn("Unable to parse GUI message {} due to {}", data, e);
        log.debug("Boom!!!", e);
    }
}
 
开发者ID:shlee89,项目名称:athena,代码行数:19,代码来源:UiWebSocket.java


示例2: onMessage

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
@Override
public void onMessage(String data) {
    lastActive = System.currentTimeMillis();
    try {
        ObjectNode message = (ObjectNode) mapper.reader().readTree(data);
        String type = message.path("event").asText("unknown");
        UiMessageHandler handler = handlers.get(type);
        if (handler != null) {
            handler.process(message);
        } else {
            log.warn("No GUI message handler for type {}", type);
        }
    } catch (Exception e) {
        log.warn("Unable to parse GUI message {} due to {}", data, e);
        log.debug("Boom!!!", e);
    }
}
 
开发者ID:ravikumaran2015,项目名称:ravikumaran201504,代码行数:18,代码来源:UiWebSocket.java


示例3: onMessage

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
@Override
public void onMessage(String data) {
    lastActive = System.currentTimeMillis();
    try {
        ObjectNode message = (ObjectNode) mapper.reader().readTree(data);
        String type = message.path(EVENT).asText(UNKNOWN);

        if (sessionToken == null) {
            authenticate(type, message);

        } else {
            UiMessageHandler handler = handlers.get(type);
            if (handler != null) {
                log.debug("RX message: {}", message);
                handler.process(message);
            } else {
                log.warn("No GUI message handler for type {}", type);
            }
        }

    } catch (Exception e) {
        log.warn("Unable to parse GUI message {} due to {}", data, e);
        log.debug("Boom!!!", e);
    }
}
 
开发者ID:opennetworkinglab,项目名称:onos,代码行数:26,代码来源:UiWebSocket.java


示例4: handlerCrossConnects

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
private void handlerCrossConnects(Map<Class<?>, UiMessageHandler> handlers) {
    TopologyViewMessageHandler topomh = (TopologyViewMessageHandler)
            handlers.get(TopologyViewMessageHandler.class);
    if (topomh != null) {
        topomh.setOverlayCache(overlayCache);
    }

    Topo2ViewMessageHandler topo2mh = (Topo2ViewMessageHandler)
            handlers.get(Topo2ViewMessageHandler.class);
    if (topo2mh != null) {
        topo2mh.setOverlayCache(overlay2Cache);

        // We also need a link to Topo2Traffic
        Topo2TrafficMessageHandler topo2traffic = (Topo2TrafficMessageHandler)
                handlers.get(Topo2TrafficMessageHandler.class);
        if (topo2traffic != null) {
            topo2mh.setTrafficHandler(topo2traffic);
        } else {
            log.error("No topo2 traffic handler found");
        }
    }
}
 
开发者ID:opennetworkinglab,项目名称:onos,代码行数:23,代码来源:UiWebSocket.java


示例5: createHandlersAndOverlays

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
private synchronized void createHandlersAndOverlays() {
    log.debug("Creating handlers and overlays...");
    handlers = new HashMap<>();
    overlayCache = new TopoOverlayCache();
    overlay2Cache = new Topo2OverlayCache();

    Map<Class<?>, UiMessageHandler> handlerInstances = new HashMap<>();
    UiExtensionService service = directory.get(UiExtensionService.class);
    lionBundleMap = generateLionMap(service);

    service.getExtensions().forEach(ext -> {
        UiMessageHandlerFactory factory = ext.messageHandlerFactory();
        if (factory != null) {
            factory.newHandlers().forEach(handler -> {
                try {
                    handler.init(this, directory);
                    injectLionBundles(handler, lionBundleMap);
                    handler.messageTypes().forEach(type -> handlers.put(type, handler));
                    handlerInstances.put(handler.getClass(), handler);

                } catch (Exception e) {
                    log.warn("Unable to setup handler {} due to", handler, e);
                }
            });
        }
        registerOverlays(ext);
    });

    handlerCrossConnects(handlerInstances);

    log.debug("#handlers = {}, #overlays = {}",
              handlers.size(), overlayCache.size());
}
 
开发者ID:opennetworkinglab,项目名称:onos,代码行数:34,代码来源:UiWebSocket.java


示例6: injectLionBundles

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
private void injectLionBundles(UiMessageHandler handler,
                               Map<String, LionBundle> lionBundleMap) {
    handler.requiredLionBundles().forEach(lbid -> {
        LionBundle lb = lionBundleMap.get(lbid);
        if (lb != null) {
            handler.cacheLionBundle(lb);
        } else {
            log.warn("handler {}: Lion bundle {} non existent!",
                     handler.getClass().getName(), lbid);
        }
    });
}
 
开发者ID:opennetworkinglab,项目名称:onos,代码行数:13,代码来源:UiWebSocket.java


示例7: newHandlers

import org.onosproject.ui.UiMessageHandler; //导入依赖的package包/类
private Collection<UiMessageHandler> newHandlers() {
    return ImmutableList.of(new StreamingControl());
}
 
开发者ID:shlee89,项目名称:athena,代码行数:4,代码来源:IntentPerfUi.java



注:本文中的org.onosproject.ui.UiMessageHandler类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java IRIResolver类代码示例发布时间:2022-05-22
下一篇:
Java MapTypeIdEnum类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap