源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.rocketmq.client.producer.MQProducer

示例1
public MQProducer getInstance(String nameServerAddress, String group) throws MQClientException {
    if (StringUtils.isBlank(group)) {
        group = DEFAULT_GROUP;
    }

    String genKey = genKey(nameServerAddress, group);
    MQProducer p = getProducerInstance().producerMap.get(genKey);
    if (p != null) {
        return p;
    }

    DefaultMQProducer defaultMQProducer = new DefaultMQProducer(group);
    defaultMQProducer.setNamesrvAddr(nameServerAddress);
    MQProducer beforeProducer = null;
    beforeProducer = getProducerInstance().producerMap.putIfAbsent(genKey, defaultMQProducer);
    if (beforeProducer != null) {
        return beforeProducer;
    }
    defaultMQProducer.start();
    return defaultMQProducer;
}
示例2
public MQProducer getInstance(String nameServerAddress, String group) throws MQClientException {
    if (StringUtils.isBlank(group)) {
        group = DEFAULT_GROUP;
    }

    String genKey = genKey(nameServerAddress, group);
    MQProducer p = getProducerInstance().producerMap.get(genKey);
    if (p != null) {
        return p;
    }

    DefaultMQProducer defaultMQProducer = new DefaultMQProducer(group);
    defaultMQProducer.setNamesrvAddr(nameServerAddress);
    MQProducer beforeProducer = null;
    beforeProducer = getProducerInstance().producerMap.putIfAbsent(genKey, defaultMQProducer);
    if (beforeProducer != null) {
        return beforeProducer;
    }
    defaultMQProducer.start();
    return defaultMQProducer;
}
示例3
public MQProducer getInstance(String nameServerAddress, String group) throws MQClientException {
    if (StringUtils.isBlank(group)) {
        group = DEFAULT_GROUP;
    }

    String genKey = genKey(nameServerAddress, group);
    MQProducer p = getProducerInstance().producerMap.get(genKey);
    if (p != null) {
        return p;
    }

    DefaultMQProducer defaultMQProducer = new DefaultMQProducer(group);
    defaultMQProducer.setNamesrvAddr(nameServerAddress);
    MQProducer beforeProducer = null;
    beforeProducer = getProducerInstance().producerMap.putIfAbsent(genKey, defaultMQProducer);
    if (beforeProducer != null) {
        return beforeProducer;
    }
    defaultMQProducer.start();
    return defaultMQProducer;
}
示例4
public MQProducer getInstance(String nameServerAddress, String group) throws MQClientException {
    if (StringUtils.isBlank(group)) {
        group = DEFAULT_GROUP;
    }

    String genKey = genKey(nameServerAddress, group);
    MQProducer p = getProducerInstance().producerMap.get(genKey);
    if (p != null) {
        return p;
    }

    DefaultMQProducer defaultMQProducer = new DefaultMQProducer(group);
    defaultMQProducer.setNamesrvAddr(nameServerAddress);
    MQProducer beforeProducer = null;
    beforeProducer = getProducerInstance().producerMap.putIfAbsent(genKey, defaultMQProducer);
    if (beforeProducer != null) {
        return beforeProducer;
    }
    defaultMQProducer.start();
    return defaultMQProducer;
}
示例5
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;
    }

    DefaultMQProducer defaultMQProducer = new DefaultMQProducer(group);
    defaultMQProducer.setNamesrvAddr(nameServerAddress);
    MQProducer beforeProducer = null;
    //cas put producer
    beforeProducer = producerMap.putIfAbsent(genKey, defaultMQProducer);
    if (beforeProducer != null) {
        return beforeProducer;
    }
    defaultMQProducer.start();
    return defaultMQProducer;
}
示例6
public MQProducer getInstance(String nameServerAddress, String group) throws MQClientException {
    if (StringUtils.isBlank(group)) {
        group = DEFAULT_GROUP;
    }

    String genKey = genKey(nameServerAddress, group);
    MQProducer p = getProducerInstance().producerMap.get(genKey);
    if (p != null) {
        return p;
    }

    DefaultMQProducer defaultMQProducer = new DefaultMQProducer(group);
    defaultMQProducer.setNamesrvAddr(nameServerAddress);
    MQProducer beforeProducer = null;
    beforeProducer = getProducerInstance().producerMap.putIfAbsent(genKey, defaultMQProducer);
    if (beforeProducer != null) {
        return beforeProducer;
    }
    defaultMQProducer.start();
    return defaultMQProducer;
}
示例7
public void removeAndClose(String nameServerAddress, String group) {
    if (group == null) {
        group = DEFAULT_GROUP;
    }
    String genKey = genKey(nameServerAddress, group);
    MQProducer producer = getProducerInstance().producerMap.remove(genKey);

    if (producer != null) {
        producer.shutdown();
    }
}
示例8
public void closeAll() {
    Set<Map.Entry<String, MQProducer>> entries = getProducerInstance().producerMap.entrySet();
    for (Map.Entry<String, MQProducer> entry : entries) {
        getProducerInstance().producerMap.remove(entry.getKey());
        entry.getValue().shutdown();
    }
}
示例9
public void removeAndClose(String nameServerAddress, String group) {
    if (group == null) {
        group = DEFAULT_GROUP;
    }
    String genKey = genKey(nameServerAddress, group);
    MQProducer producer = getProducerInstance().producerMap.remove(genKey);

    if (producer != null) {
        producer.shutdown();
    }
}
示例10
public void closeAll() {
    Set<Map.Entry<String, MQProducer>> entries = getProducerInstance().producerMap.entrySet();
    for (Map.Entry<String, MQProducer> entry : entries) {
        getProducerInstance().producerMap.remove(entry.getKey());
        entry.getValue().shutdown();
    }
}
示例11
public void removeAndClose(String nameServerAddress, String group) {
    if (group == null) {
        group = DEFAULT_GROUP;
    }
    String genKey = genKey(nameServerAddress, group);
    MQProducer producer = getProducerInstance().producerMap.remove(genKey);

    if (producer != null) {
        producer.shutdown();
    }
}
示例12
public void closeAll() {
    Set<Map.Entry<String, MQProducer>> entries = getProducerInstance().producerMap.entrySet();
    for (Map.Entry<String, MQProducer> entry : entries) {
        getProducerInstance().producerMap.remove(entry.getKey());
        entry.getValue().shutdown();
    }
}
示例13
public void removeAndClose(String nameServerAddress, String group) {
    if (group == null) {
        group = DEFAULT_GROUP;
    }
    String genKey = genKey(nameServerAddress, group);
    MQProducer producer = getProducerInstance().producerMap.remove(genKey);

    if (producer != null) {
        producer.shutdown();
    }
}
示例14
public void closeAll() {
    Set<Map.Entry<String, MQProducer>> entries = getProducerInstance().producerMap.entrySet();
    for (Map.Entry<String, MQProducer> entry : entries) {
        getProducerInstance().producerMap.remove(entry.getKey());
        entry.getValue().shutdown();
    }
}
示例15
public static void removeAndClose(String nameServerAddress, String group) {
    if (group == null) {
        group = DEFAULT_GROUP;
    }
    String genKey = genKey(nameServerAddress, group);
    MQProducer producer = producerMap.remove(genKey);

    if (producer != null) {
        producer.shutdown();
    }
}
示例16
public static void closeAll() {
    Set<Map.Entry<String, MQProducer>> entries = producerMap.entrySet();
    for (Map.Entry<String, MQProducer> entry : entries) {
        producerMap.remove(entry.getKey());
        entry.getValue().shutdown();
    }
}
示例17
public void removeAndClose(String nameServerAddress, String group) {
    if (group == null) {
        group = DEFAULT_GROUP;
    }
    String genKey = genKey(nameServerAddress, group);
    MQProducer producer = getProducerInstance().producerMap.remove(genKey);

    if (producer != null) {
        producer.shutdown();
    }
}
示例18
public void closeAll() {
    Set<Map.Entry<String, MQProducer>> entries = getProducerInstance().producerMap.entrySet();
    for (Map.Entry<String, MQProducer> entry : entries) {
        getProducerInstance().producerMap.remove(entry.getKey());
        entry.getValue().shutdown();
    }
}
示例19
private void shutdown() {
    Runtime.getRuntime().addShutdownHook(new Thread(() -> {
        cfgs.values().forEach(cfg -> {
            final MQProducer producer = cfg.getProducer();
            if (producer != null) {
                try {
                    producer.shutdown();
                } catch (final Throwable e) {
                    LOGGER.error("Shutdown producer error: {}", e.getMessage());
                }
            }
        });
    }));
}
示例20
private void bind(final Binder binder) {
    cfgs.forEach((id, cfg) -> {
        final DefaultMQProducer producer = cfg.getProducer();
        if (producer != null) {
            try {
                producer.start();
                binder.bind(MQProducer.class).annotatedWith(Names.named(ROCKETMQ_PREFIX + id)).toInstance(producer);
            } catch (final MQClientException e) {
                producer.shutdown();
                throw new org.nanoframework.orm.rocketmq.exception.MQClientException(e.getErrorMessage(), e);
            }
        }
    });
}
示例21
@Bean
public SendRocketMQService sendRocketMQService(@Qualifier(value = "enodeMQProducer") MQProducer mqProducer) {
    return new SendRocketMQService(mqProducer);
}
示例22
public SendRocketMQService(MQProducer producer) {
    this.producer = producer;
}
示例23
/**
 * Returns the message producer,Only valid after
 * activateOptions() method has been invoked.
 */
protected MQProducer getProducer() {
    return producer;
}
示例24
/**
 * Returns the message producer,Only valid after
 * activateOptions() method has been invoked.返回消息生成器，只有在调用activateOptions()方法后才有效。
 */
protected MQProducer getProducer() {
    return producer;
}
示例25
/**
 * Returns the message producer,Only valid after
 * activateOptions() method has been invoked.
 */
protected MQProducer getProducer() {
    return producer;
}
示例26
/**
 * Returns the message producer,Only valid after
 * activateOptions() method has been invoked.
 */
protected MQProducer getProducer() {
    return producer;
}
示例27
/**
 * Returns the message producer,Only valid after
 * activateOptions() method has been invoked.
 */
protected MQProducer getProducer() {
    return producer;
}
示例28
/**
 * Returns the message producer,Only valid after
 * activateOptions() method has been invoked.
 */
protected MQProducer getProducer() {
    return producer;
}