Java MessageSummary类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: getModel

import org.graylog2.plugin.MessageSummary; //导入依赖的package包/类
private Map<String, Object> getModel(AlertCondition condition, AlertCondition.CheckResult alert) throws AlarmCallbackException {
    Stream stream = condition.getStream();
    List<Message> messages = new ArrayList<>();
    for (MessageSummary messageSummary : alert.getMatchingMessages()) {
        messages.add(messageSummary.getRawMessage());
    }
    HashMap<String, Object> model = new HashMap<>();
    model.put("stream", stream);
    model.put("check_result", alert);
    if (graylogBaseUrl != null) {
        model.put("stream_url", buildStreamDetailsURL(graylogBaseUrl, alert, stream));
    }
    model.put("backlog", messages);
    model.put("backlog_size", messages.size());
    return model;
}

开发者ID:graylog-labs，项目名称:graylog-plugin-hipchat，代码行数:17，代码来源:HipChatTrigger.java

示例2: buildJIRAGraylogMapping

import org.graylog2.plugin.MessageSummary; //导入依赖的package包/类
/**
 * Build up a list of JIRA/Graylog field mappings
 * @param stream
 * @param result
 * @return
 */
private Map<String, String> buildJIRAGraylogMapping (final Stream stream, final AlertCondition.CheckResult result) {

  Map<String, String> JIRAFieldMapping = new HashMap<String, String>();
  
  if (configuration.stringIsSet(CK_JIRA_GRAYLOG_MAPPING) && !configuration.getString(CK_JIRA_GRAYLOG_MAPPING).equals("null") && !result.getMatchingMessages().isEmpty()) {
    try {
      // get fields from last message only
      MessageSummary lastMessage = result.getMatchingMessages().get(0);
      
      String[] mappingPairs = StringUtils.split(configuration.getString(CK_JIRA_GRAYLOG_MAPPING), ',');
      
      if (mappingPairs != null && mappingPairs.length > 0) {
        for (String mappingString : mappingPairs) {
            String[] mapping = StringUtils.split(mappingString, '=');
            
            if (mapping.length == 2 && lastMessage.hasField(mapping[0])) {
              Object test = lastMessage.getField(mapping[0]);
              JIRAFieldMapping.put(mapping[1], test.toString());
            }
        }
      }
    } catch (Exception ex) {
      ; // can not do anything - we skip
      LOG.error("Error in generating JIRA/Graylog mapping " + ex.getMessage());
    }
  }
  
  return JIRAFieldMapping;
}

开发者ID:magicdude4eva，项目名称:graylog-jira-alarmcallback，代码行数:36，代码来源:JiraAlarmCallback.java

示例3: getAlarmBacklog

import org.graylog2.plugin.MessageSummary; //导入依赖的package包/类
private List<Message> getAlarmBacklog(AlertCondition.CheckResult result) {
    final AlertCondition alertCondition = result.getTriggeredCondition();
    final List<MessageSummary> matchingMessages = result.getMatchingMessages();
    final int effectiveBacklogSize = Math.min(alertCondition.getBacklog(), matchingMessages.size());

    if (effectiveBacklogSize == 0) return Collections.emptyList();
    final List<MessageSummary> backlogSummaries = matchingMessages.subList(0, effectiveBacklogSize);
    final List<Message> backlog = Lists.newArrayListWithCapacity(effectiveBacklogSize);
    for (MessageSummary messageSummary : backlogSummaries) {
        backlog.add(messageSummary.getRawMessage());
    }

    return backlog;
}

开发者ID:graylog-labs，项目名称:graylog-plugin-slack，代码行数:15，代码来源:SlackAlarmCallback.java

示例4: runCheck

import org.graylog2.plugin.MessageSummary; //导入依赖的package包/类
@Override
  public CheckResult runCheck() {        
      String filter = "streams:" + stream.getId();
      Integer backlogSize = getBacklog();
      boolean backlogEnabled = false;
      int searchLimit = 1;

      if(backlogSize != null && backlogSize > 0) {
          backlogEnabled = true;
          searchLimit = backlogSize;
      }

      SearchResult result = searches.search(
    query,
    filter,
    AbsoluteRange.create(Tools.nowUTC().minus(Minutes.minutes(backtime)).minus(Minutes.minutes(staytime)), Tools.nowUTC().minus(Minutes.minutes(backtime))),
    searchLimit,
    0,
    new Sorting(Message.FIELD_TIMESTAMP, Sorting.Direction.DESC)
);

final List<MessageSummary> summaries;
if (backlogEnabled) {
    summaries = Lists.newArrayListWithCapacity(result.getResults().size());
    for (ResultMessage resultMessage : result.getResults()) {
        final Message msg = resultMessage.getMessage();
        summaries.add(new MessageSummary(resultMessage.getIndex(), msg));
    }
} else {
    summaries = Collections.emptyList();
}

final long count = result.getTotalResults();

final String resultDescription = "Stream received messages matching <" + query + "> "
    + "(Current grace time: " + grace + " minutes)";

if (count > 0) {
    LOG.debug("Alert check <{}> found [{}] messages.", id, count);
    return new CheckResult(true, this, resultDescription, Tools.nowUTC(), summaries);
} else {
    LOG.debug("Alert check <{}> returned no results.", id);
    return new NegativeCheckResult();
}
  }

开发者ID:alcampos，项目名称:graylog-plugin-alert-condition-delorean，代码行数:46，代码来源:DeloreanAlertCondition.java

示例5: buildJIRATitle

import org.graylog2.plugin.MessageSummary; //导入依赖的package包/类
/**
 * Build the JIRA issue title
 * @param stream
 * @param result
 * @return
 */
private String buildJIRATitle (final Stream stream, final AlertCondition.CheckResult result) {

  StringBuilder sb = new StringBuilder();
  
  try {
    if (!result.getMatchingMessages().isEmpty()) {
      // get fields from last message only
      MessageSummary lastMessage = result.getMatchingMessages().get(0);
      
      Map<String, Object> lastMessageFields = lastMessage.getFields();
      
      String strTitle = "[Alert] Graylog alert for stream: " + stream.getTitle();

      if (configuration.stringIsSet(CK_JIRA_TITLE_TEMPLATE) && !configuration.getString(CK_JIRA_TITLE_TEMPLATE).equals("null")) {
        strTitle = configuration.getString(CK_JIRA_TITLE_TEMPLATE);
      }
      
      strTitle = strTitle.replace("[LAST_MESSAGE.source]", lastMessage.getSource());
      
      for (Map.Entry<String, Object> arg : lastMessageFields.entrySet()) {
        strTitle = strTitle.replace("[LAST_MESSAGE." + arg.getKey() + "]", arg.getValue().toString());
      }
      
      if (configuration.stringIsSet(CK_MESSAGE_REGEX) && !configuration.getString(CK_MESSAGE_REGEX).equals("null")) {
        Matcher matcher = Pattern.compile(configuration.getString(CK_MESSAGE_REGEX)).matcher(lastMessage.getMessage());
        
        if (matcher.find()) {
          if (configuration.stringIsSet(CK_JIRA_TITLE_TEMPLATE) && !configuration.getString(CK_JIRA_TITLE_TEMPLATE).equals("null")) {
            strTitle = strTitle.replace("[MESSAGE_REGEX]", matcher.group());
          } else {
            strTitle = "[Graylog] " + matcher.group();
          }
        }
      }
      
      // We regex template fields which have not been replaced
      strTitle = strTitle.replaceAll("\\[LAST_MESSAGE\\.[^\\]]*\\]", "");
      
      sb.append(strTitle);
    }
  } catch (Exception ex) {
    ; // can not do anything - we skip
    LOG.error("Error in building title: " + ex.getMessage());
  }
  
  if (sb.length() == 0) {
    sb.append("[Alert] Graylog alert for stream: ").append(stream.getTitle());
  }
  
  return sb.toString();
}

开发者ID:magicdude4eva，项目名称:graylog-jira-alarmcallback，代码行数:58，代码来源:JiraAlarmCallback.java

示例6: buildDescription

import org.graylog2.plugin.MessageSummary; //导入依赖的package包/类
/**
 * Build the JIRA description
 * @param stream
 * @param result
 * @return
 */
private String buildDescription (final Stream stream, final AlertCondition.CheckResult result) {

  String strMessage = CONST_JIRA_MESSAGE_TEMPLATE;
  
  if (configuration.stringIsSet(CK_JIRA_MESSAGE_TEMPLATE) &&
      !configuration.getString(CK_JIRA_MESSAGE_TEMPLATE).equals("null") &&
      !configuration.getString(CK_JIRA_MESSAGE_TEMPLATE).isEmpty()) {
    strMessage = configuration.getString(CK_JIRA_MESSAGE_TEMPLATE);
  }
  
  strMessage = StringEscapeUtils.unescapeJava(strMessage);
  
  // Get the last message
  if (!result.getMatchingMessages().isEmpty()) {
    // get fields from last message only
    MessageSummary lastMessage = result.getMatchingMessages().get(0);
    Map<String, Object> lastMessageFields = lastMessage.getFields();

    strMessage = strMessage.replace("[LAST_MESSAGE.message]", lastMessage.getMessage());
    strMessage = strMessage.replace("[LAST_MESSAGE.source]", lastMessage.getSource());
    
    for (Map.Entry<String, Object> arg : lastMessageFields.entrySet()) {
      strMessage = strMessage.replace("[LAST_MESSAGE." + arg.getKey() + "]", arg.getValue().toString());
    }
    
    // We regex template fields which have not been replaced
    strMessage = strMessage.replaceAll("\\[LAST_MESSAGE\\.[^\\]]*\\]", "");
  }

  // replace placeholders
  strMessage = strMessage.replace("[CALLBACK_DATE]", Tools.iso8601().toString());
  strMessage = strMessage.replace("[STREAM_ID]", stream.getId());
  strMessage = strMessage.replace("[STREAM_TITLE]", stream.getTitle());
  strMessage = strMessage.replace("[STREAM_URL]", buildStreamURL(configuration.getString(CK_GRAYLOG_URL), stream));
  strMessage = strMessage.replace("[STREAM_RULES]", buildStreamRules(stream));
  strMessage = strMessage.replace("[STREAM_RESULT]", result.getResultDescription());
  strMessage = strMessage.replace("[ALERT_TRIGGERED_AT]", result.getTriggeredAt().toString());
  strMessage = strMessage.replace("[ALERT_TRIGGERED_CONDITION]", result.getTriggeredCondition().toString());
  
  // create final string
  StringBuilder sb = new StringBuilder();
  sb.append("\n\n");
  sb.append(strMessage).append("\n\n");
  
  return sb.toString();
}

开发者ID:magicdude4eva，项目名称:graylog-jira-alarmcallback，代码行数:53，代码来源:JiraAlarmCallback.java

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Calc类代码示例发布时间：2022-05-23

Java VFileProperty类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18032|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9595|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8141|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8522|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8425|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9333|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8390|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7826|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8379|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7372|2022-11-06

客服电话

电子邮件

Java MessageSummary类代码示例

示例1: getModel

示例2: buildJIRAGraylogMapping

示例3: getAlarmBacklog

示例4: runCheck

示例5: buildJIRATitle

示例6: buildDescription

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

qiangxi/CheckUpdateLibrary: Android检查

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053