Отправить сообщение из нескольких потоков Java - PullRequest
0 голосов
/ 11 июня 2018

Я хочу использовать ExecutorService для использования нескольких потоков Java для отправки и получения сообщения с RabbitMQ:

public class EndPoint {

    public ExecutorService es;  
    public EndPoint(String endpointName) throws Exception {     
        es = Executors.newFixedThreadPool(20);          
        ConnectionFactory factory = new ConnectionFactory();            
        connection = factory.newConnection(es);
        channel = connection.createChannel();
        ..........
    }

    private static EndPoint single_instance = null; 
    public static EndPoint getInstance() throws Exception
    {
        if (single_instance == null)
            single_instance = new EndPoint(null);

        return single_instance;
    }
}

В некотором удаленном классе:

EndPoint vvvv = EndPoint.getInstance();
vvvv.es.execute(some content);

Как я могу отправитьи получать данные из нескольких потоков?Пока что код, который мне удалось создать.

channel.basicPublish(EXCHANGE_NAME, endPointName, null, SerializationUtils.serialize(object));

Но как приведенный выше код и использоваться с Java Thread?

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...