Java MisfireException类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: doLaunch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void doLaunch(MessageInput input) throws MisfireException {
    serverStatus.awaitRunning(() -> lifecycleStateChange(Lifecycle.RUNNING));

    LOG.info("Starting s3 subscriber");

    final String legacyRegionName = input.getConfiguration().getString(CK_LEGACY_AWS_REGION, DEFAULT_REGION.getName());
    final String sqsRegionName = input.getConfiguration().getString(CK_AWS_SQS_REGION, legacyRegionName);
    final String s3RegionName = input.getConfiguration().getString(CK_AWS_S3_REGION, legacyRegionName);

    subscriber = new S3Subscriber(
            Region.getRegion(Regions.fromName(sqsRegionName)),
            Region.getRegion(Regions.fromName(s3RegionName)),
            input.getConfiguration().getString(CK_SQS_NAME),
            input,
            input.getConfiguration().getString(CK_ACCESS_KEY),
            input.getConfiguration().getString(CK_SECRET_KEY),
            input.getConfiguration().getInt(CK_THREAD_COUNT)
    );

    subscriber.start();
}

开发者ID:sherzberg，项目名称:graylog-plugin-s3，代码行数:23，代码来源:S3Transport.java

示例2: doLaunch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
protected void doLaunch(final MessageInput input) throws MisfireException {
    consumer = new NsqClientBuilder(configuration).buildLookupd(new NSQMessageCallback() {
        @Override
        public void message(NSQMessage nsqMessage) {
            final RawMessage rawMessage = new RawMessage(nsqMessage.getMessage());
            nsqMessage.finished();
            input.processRawMessage(rawMessage);

            // do throttle the code
            if (isThrottled()) {
                blockUntilUnthrottled();
            }

        }
    });

    consumer.start();
}

开发者ID:condevtec，项目名称:graylog-plugin-nsq，代码行数:20，代码来源:NsqTransport.java

示例3: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(MessageInput input) throws MisfireException {
    appender = new DirectConsumingAppender(
            "graylog-plugin-internal-logs",
            logEvent -> input.processRawMessage(new RawMessage(logEvent)),
            threshold);
    addAppender(appender);
}

开发者ID:graylog-labs，项目名称:graylog-plugin-internal-logs，代码行数:9，代码来源:SerializedLogEventTransport.java

示例4: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(final MessageInput messageInput) throws MisfireException {
    LogEventListener listener = new LogEventListener() {
        @Override
        public void onEvents(List<LogEvent> list) {
            ObjectMapper mapper = new ObjectMapper();
            try {
                for (LogEvent event : list) {
                    ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
                    mapper.writeValue(byteStream,convertToGELF(event));
                    messageInput.processRawMessage(new RawMessage(byteStream.toByteArray()));
                    byteStream.close();
                }
            } catch (Exception e) {
                LOGGER.warn("Exception while processing event ",e);
            }
        }
    };
    ServerConfiguration serverConfiguration = new ServerConfiguration();
    serverConfiguration.setIpAddress(configuration.getString(CK_BIND_IP));
    serverConfiguration.setPort(configuration.getInt(CK_BIND_PORT));
    serverConfiguration.setKeyStorePath(configuration.getString(CK_KEYSTORE_PATH));
    serverConfiguration.setKeyStorePass(configuration.getString(CK_KEYSTORE_PASSWORD));
    serverConfiguration.setKeyPass(configuration.getString(CK_KEY_PASSWORD));
    LOGGER.info("Starting LumberjackTransport with config :" + configuration);
    lumberjackServer = new LumberjackServer(serverConfiguration,
            listener);
    lumberjackServer.start();
    LOGGER.info("Lumberjack transport started");
}

开发者ID:sivasamyk，项目名称:graylog2-input-lumberjack，代码行数:31，代码来源:LumberjackTransport.java

示例5: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(final MessageInput messageInput) throws MisfireException {
    EventListener listener = new EventListener() {
        @Override
        public void onEvents(List<Event> list) {
            ObjectMapper mapper = new ObjectMapper();
            try {
                for (Event event : list) {
                    ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
                    mapper.writeValue(byteStream,convertToGELF(event));
                    messageInput.processRawMessage(new RawMessage(byteStream.toByteArray()));
                    byteStream.close();
                }
            } catch (Exception e) {
                LOGGER.warn("Exception while processing event ",e);
            }
        }
    };
    ServerConfiguration serverConfiguration = new ServerConfiguration();
    serverConfiguration.setIpAddress(configuration.getString(CK_BIND_IP));
    serverConfiguration.setPort(configuration.getInt(CK_BIND_PORT));
    serverConfiguration.setKeyStorePath(configuration.getString(CK_KEYSTORE_PATH));
    serverConfiguration.setKeyStorePass(configuration.getString(CK_KEYSTORE_PASSWORD));
    serverConfiguration.setKeyPass(configuration.getString(CK_KEY_PASSWORD));
    LOGGER.info("Starting BeatsTransport with config :" + configuration);
    lumberjackServer = new LumberjackServer(serverConfiguration,
            listener);
    lumberjackServer.start();
    LOGGER.info("BeatsTransport started");
}

开发者ID:sivasamyk，项目名称:graylog-beats-plugin，代码行数:31，代码来源:BeatsTransport.java

示例6: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(MessageInput input) throws MisfireException {
    ExecutorService executor = Executors.newSingleThreadExecutor(new ThreadFactoryBuilder()
            .setDaemon(true)
            .setNameFormat("aws-kinesis-reader-%d")
            .setUncaughtExceptionHandler((t, e) -> LOG.error("Uncaught exception in AWS Kinesis reader.", e))
            .build());

    final AWSPluginConfiguration awsConfig = clusterConfigService.getOrDefault(AWSPluginConfiguration.class,
            AWSPluginConfiguration.createDefault());
    AWSAuthProvider authProvider = new AWSAuthProvider(
            awsConfig, configuration.getString(CK_ACCESS_KEY),
            configuration.getString(CK_SECRET_KEY),
            configuration.getString(CK_AWS_REGION),
            configuration.getString(CK_ASSUME_ROLE_ARN)
    );

    this.reader = new KinesisConsumer(
            configuration.getString(CK_KINESIS_STREAM_NAME),
            Region.getRegion(Regions.fromName(configuration.getString(CK_AWS_REGION))),
            kinesisCallback(input),
            awsConfig,
            authProvider,
            nodeId,
            graylogConfiguration.getHttpProxyUri() == null ? null : HttpUrl.get(graylogConfiguration.getHttpProxyUri())
    );

    LOG.info("Starting Kinesis reader thread for input [{}/{}]", input.getName(), input.getId());

    executor.submit(this.reader);
}

开发者ID:Graylog2，项目名称:graylog-plugin-aws，代码行数:32，代码来源:KinesisTransport.java

示例7: doLaunch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void doLaunch(MessageInput input) throws MisfireException {
    serverStatus.awaitRunning(() -> lifecycleStateChange(Lifecycle.RUNNING));

    final AWSPluginConfiguration config = clusterConfigService.getOrDefault(AWSPluginConfiguration.class,
            AWSPluginConfiguration.createDefault());

    LOG.info("Starting cloud trail subscriber");

    final String legacyRegionName = input.getConfiguration().getString(CK_LEGACY_AWS_REGION, DEFAULT_REGION.getName());
    final String sqsRegionName = input.getConfiguration().getString(CK_AWS_SQS_REGION, legacyRegionName);
    final String s3RegionName = input.getConfiguration().getString(CK_AWS_S3_REGION, legacyRegionName);

    final HttpUrl proxyUrl = config.proxyEnabled() && httpProxyUri != null ? HttpUrl.get(httpProxyUri) : null;

    final AWSAuthProvider authProvider = new AWSAuthProvider(
            config,
            input.getConfiguration().getString(CK_ACCESS_KEY),
            input.getConfiguration().getString(CK_SECRET_KEY),
            input.getConfiguration().getString(CK_AWS_SQS_REGION),
            input.getConfiguration().getString(CK_ASSUME_ROLE_ARN)
    );

    subscriber = new CloudTrailSubscriber(
            Region.getRegion(Regions.fromName(sqsRegionName)),
            Region.getRegion(Regions.fromName(s3RegionName)),
            input.getConfiguration().getString(CK_SQS_NAME),
            input,
            authProvider,
            proxyUrl,
            objectMapper
    );

    subscriber.start();
}

开发者ID:Graylog2，项目名称:graylog-plugin-aws，代码行数:36，代码来源:CloudTrailTransport.java

示例8: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(MessageInput messageInput) throws MisfireException {

    this.executionInterval = configuration.getInt(CK_CONFIG_INTERVAL);
    this.getExecutionIntervalTimeUnit = TimeUnit.valueOf(configuration.getString(CK_CONFIG_INTERVAL_UNIT));
    this.label = configuration.getString(CK_CONFIG_LABEL);
    String hosts[] = configuration.getString(CK_CONFIG_HOSTS).split(",");

    servers = new ArrayList<>(hosts.length);

    for (String host : hosts) {
        Server server = Server.builder().setHost(host.trim())
                .setPort(String.valueOf(configuration.getInt(CK_CONFIG_PORT)))
                .setUsername(configuration.getString(CK_CONFIG_USER_NAME))
                .setPassword(configuration.getString(CK_CONFIG_PASSWORD))
                .setTrustStorePath(configuration.getString(CK_CONFIG_TRUSTSTORE_PATH))
                .setTrustStorePass(configuration.getString(CK_CONFIG_TRUSTSTORE_PASS))
                .build();
        servers.add(server);
    }

    String jmxObjectType = configuration.getString(CK_CONFIG_TYPE);
    ObjectMapper configMapper = new ObjectMapper();
    String jsonFilePath = jmxObjectType;

    try {
        if ("custom".equals(jmxObjectType)) {
            jsonFilePath = configuration.getString(CK_CONFIG_CUSTOM_FILE_PATH);
            if (jsonFilePath != null && jsonFilePath.length() > 0) {
                if (new File(jsonFilePath).exists()) {
                    queryConfig = configMapper.readValue(new File(jsonFilePath), GLQueryConfig.class);
                } else {
                    LOGGER.error("Custom config file not present." + jsonFilePath);
                    throw new MisfireException("Cannot find custom config file " + jsonFilePath);
                }
            } else {
                LOGGER.error("Custom config file not entered.");
                throw new MisfireException("Custom config file not entered");
            }
        } else {
            queryConfig = configMapper.readValue(
                    JMXTransport.class.getClassLoader().getResourceAsStream(jsonFilePath),
                    GLQueryConfig.class);
        }
    } catch (IOException e) {
        LOGGER.error("Exception while parsing config file", e);
        throw new MisfireException("Exception while parsing config file " + jsonFilePath, e);
    }
    startMonitoring(messageInput);
}

开发者ID:sivasamyk，项目名称:graylog-plugin-input-jmx，代码行数:51，代码来源:JMXTransport.java

示例9: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(MessageInput messageInput) throws MisfireException {
    scheduler.scheduleAtFixedRate(readDataFromNOAA(messageInput), 0, 60, TimeUnit.SECONDS);
}

开发者ID:graylog-labs，项目名称:graylog-plugin-spaceweather，代码行数:5，代码来源:SpaceweatherTransport.java

示例10: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
    public void launch(MessageInput messageInput) throws MisfireException {
        this.messageInput = messageInput;
        URLMonitorConfig urlMonitorConfig = new URLMonitorConfig();
        urlMonitorConfig.setUrl(configuration.getString(CK_CONFIG_URL));
        urlMonitorConfig.setLabel(configuration.getString(CK_CONFIG_LABEL));
        urlMonitorConfig.setMethod(configuration.getString(CK_CONFIG_METHOD));

        String proxyUri = configuration.getString(CK_CONFIG_HTTP_PROXY);
        if (proxyUri != null && !proxyUri.isEmpty()) {
            urlMonitorConfig.setHttpProxyUri(URI.create(proxyUri));
        }

        String requestHeaders = configuration.getString(CK_CONFIG_HEADERS_TO_SEND);
        if (StringUtils.isNotEmpty(requestHeaders)) {
            urlMonitorConfig.setRequestHeadersToSend(
                    requestHeaders.split(","));
        }
        urlMonitorConfig.setUsername(configuration.getString(CK_CONFIG_USER_NAME));
        urlMonitorConfig.setPassword(configuration.getString(CK_CONFIG_PASSWORD));
        urlMonitorConfig.setExecutionInterval(configuration.getInt(CK_CONFIG_INTERVAL));
        urlMonitorConfig.setTimeout(configuration.getInt(CK_CONFIG_TIMEOUT));
        urlMonitorConfig.setTimeoutUnit(TimeUnit.valueOf(configuration.getString(CK_CONFIG_TIMEOUT_UNIT)));
        urlMonitorConfig.setIntervalUnit(TimeUnit.valueOf(configuration.getString(CK_CONFIG_INTERVAL_UNIT)));

//        long timoutInMs = TimeUnit.MILLISECONDS.convert(urlMonitorConfig.getTimeout(), urlMonitorConfig.getTimeoutUnit());
//        long intervalInMs = TimeUnit.MILLISECONDS.convert(urlMonitorConfig.getExecutionInterval(), urlMonitorConfig.getIntervalUnit());
//
//        if (intervalInMs <= timoutInMs) {
//            String message = MessageFormat.format("Timeout {0} {1} should be smaller than interval {2} {3}",
//                    urlMonitorConfig.getTimeout(),urlMonitorConfig.getTimeoutUnit(),
//                    urlMonitorConfig.getExecutionInterval(), urlMonitorConfig.getIntervalUnit());
//            throw new MisfireException(message);
//        }

        urlMonitorConfig.setRequestBody(configuration.getString(CK_CONFIG_REQUEST_BODY));
        urlMonitorConfig.setLogResponseBody(configuration.getBoolean(CK_CONFIG_LOG_RESPONSE_BODY));

        String responseHeaders = configuration.getString(CK_CONFIG_HEADERS_TO_RECORD);
        if (StringUtils.isNotEmpty(responseHeaders)) {
            urlMonitorConfig.setResponseHeadersToRecord(
                    responseHeaders.split(","));
        }

        startMonitoring(urlMonitorConfig);
    }

开发者ID:sivasamyk，项目名称:graylog2-plugin-input-httpmonitor，代码行数:47，代码来源:HttpMonitorTransport.java

示例11: launch

import org.graylog2.plugin.inputs.MisfireException; //导入依赖的package包/类
@Override
public void launch(MessageInput input) throws MisfireException {
    serverStatus.awaitRunning(() -> lifecycleStateChange(Lifecycle.RUNNING));
    serverEventBus.register(this);

    LOG.debug("Launching MongoDB profiler reader.");
    final Configuration configuration = input.getConfiguration();

    final int port = configuration.getInt(CK_MONGO_PORT);
    final MongoClient mongoClient;
    final List<MongoCredential> credentialList;
    final String db = configuration.getString(CK_MONGO_DB);
    if (configuration.getBoolean(CK_MONGO_USE_AUTH)) {
        final MongoCredential credentials = MongoCredential.createCredential(
                configuration.getString(CK_MONGO_USER),
                db,
                configuration.getString(CK_MONGO_PW).toCharArray()
        );

        credentialList = ImmutableList.of(credentials);
    } else {
        credentialList = ImmutableList.of();
    }

    final String mongoHost = configuration.getString(CK_MONGO_HOST);
    final String[] hosts = mongoHost.split(",");
    final List<ServerAddress> replicaHosts = new ArrayList<>(hosts.length);
    for (String host : hosts) {
        replicaHosts.add(new ServerAddress(host, port));
    }
    mongoClient = new MongoClient(replicaHosts, credentialList);

    // Try the connection.
    try {
        mongoClient.getDB(db).getStats();
    } catch (Exception e) {
        throw new MisfireException("Could not verify MongoDB profiler connection.", e);
    }

    subscriber = new ProfileSubscriber(mongoClient, db, input, localRegistry);
    subscriber.start();
}

开发者ID:graylog-labs，项目名称:graylog-plugin-mongodb-profiler，代码行数:43，代码来源:MongoDBProfilerTransport.java

注：本文中的org.graylog2.plugin.inputs.MisfireException类示例整理自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 TridentKafkaConfig类代码示例发布时间：2022-05-22

Java ClientResponseFailure类代码示例发布时间：2022-05-22

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

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

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

阅读：19277|2023-10-27

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

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

阅读：10015|2022-11-06

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

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

阅读：8341|2022-11-06

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

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

阅读：8710|2022-11-06

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

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

阅读：8655|2022-11-06

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

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

阅读：9684|2022-11-06

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

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

阅读：8643|2022-11-06

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

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

阅读：8011|2022-11-06

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

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

阅读：8680|2022-11-06

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

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

阅读：7547|2022-11-06

客服电话

电子邮件

Java MisfireException类代码示例

示例1: doLaunch

示例2: doLaunch

示例3: launch

示例4: launch

示例5: launch

示例6: launch

示例7: doLaunch

示例8: launch

示例9: launch

示例10: launch

示例11: launch

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-32214

hyperledger-labs/hlf-operator: Hyperledg

solegalli/feature-selection-for-machine-

sussillo/hfopt-matlab: A parallel, cpu-b

win7系统重装系统初始设置的操作方法

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

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

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053