Я хочу использовать 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?