rocketmq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (ROCKETMQ-194) log appender useing rocketmq
Date Tue, 16 May 2017 02:07:04 GMT

    [ https://issues.apache.org/jira/browse/ROCKETMQ-194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16011624#comment-16011624
] 

ASF GitHub Bot commented on ROCKETMQ-194:
-----------------------------------------

Github user lindzh commented on a diff in the pull request:

    https://github.com/apache/incubator-rocketmq/pull/101#discussion_r116641839
  
    --- Diff: logappender/src/main/java/org/apache/rocketmq/logappender/common/ProducerInstance.java
---
    @@ -0,0 +1,96 @@
    +/*
    + * Licensed to the Apache Software Foundation (ASF) under one or more
    + * contributor license agreements.  See the NOTICE file distributed with
    + * this work for additional information regarding copyright ownership.
    + * The ASF licenses this file to You under the Apache License, Version 2.0
    + * (the "License"); you may not use this file except in compliance with
    + * the License.  You may obtain a copy of the License at
    + *
    + *     http://www.apache.org/licenses/LICENSE-2.0
    + *
    + * Unless required by applicable law or agreed to in writing, software
    + * distributed under the License is distributed on an "AS IS" BASIS,
    + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    + * See the License for the specific language governing permissions and
    + * limitations under the License.
    + */
    +package org.apache.rocketmq.logappender.common;
    +
    +import org.apache.rocketmq.client.exception.MQClientException;
    +import org.apache.rocketmq.client.producer.DefaultMQProducer;
    +import org.apache.rocketmq.client.producer.MQProducer;
    +
    +import java.util.Map;
    +import java.util.Set;
    +import java.util.concurrent.ConcurrentHashMap;
    +
    +/**
    + * Common Producer component
    + */
    +public class ProducerInstance {
    +
    +    public static final String APPENDER_TYPE = "APPENDER_TYPE";
    +
    +    public static final String LOG4J_APPENDER = "LOG4J_APPENDER";
    +
    +    public static final String LOG4J2_APPENDER = "LOG4J2_APPENDER";
    +
    +    public static final String LOGBACK_APPENDER = "LOGBACK_APPENDER";
    +
    +    public static final String DEFAULT_GROUP = "rocketmq_appender";
    +
    +    private static ConcurrentHashMap<String, MQProducer> producerMap = new ConcurrentHashMap<String,
MQProducer>();
    +
    +    private static String genKey(String nameServerAddress, String group) {
    +        return nameServerAddress + "_" + group;
    +    }
    +
    +
    +    public static MQProducer getInstance(String nameServerAddress, String group) throws
MQClientException {
    +        if (group == null) {
    +            group = DEFAULT_GROUP;
    +        }
    +
    +        String genKey = genKey(nameServerAddress, group);
    +        MQProducer p = producerMap.get(genKey);
    +        if (p != null) {
    +            return p;
    --- End diff --
    
    As log initlizer is serializable,if it has ben started before,it must be started.


> log appender useing rocketmq
> ----------------------------
>
>                 Key: ROCKETMQ-194
>                 URL: https://issues.apache.org/jira/browse/ROCKETMQ-194
>             Project: Apache RocketMQ
>          Issue Type: New Feature
>    Affects Versions: 4.1.0-incubating
>         Environment: jdk7
>            Reporter: lindzh
>            Assignee: vongosling
>              Labels: features
>             Fix For: 4.1.0-incubating
>
>   Original Estimate: 72h
>  Remaining Estimate: 72h
>
> As Rocketmq is widely used,A log appender is also necessary.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message