J
Size: a a a
J
DK
A
A
A
A
ES
A
СС
СС
В
J
А
J
DK
ЕБ
DK
DP
getMessage()
кажет хрен и я долго там ловил NPE пока не понял, что нет его, сообщения.public ChatAbstract() {
factory = new ConnectionFactory();
Log.d( logTag, "инициализация " + userName + "@" + hostName + "/" + virtualHost );
factory.setHost(hostName);
factory.setPort(portNumber);
factory.setUsername(userName);
factory.setPassword(password);
factory.setVirtualHost(virtualHost);
factory.setAutomaticRecoveryEnabled(true);
//factory.setSaslConfig();
Log.d( logTag, "попытка подключения" );
try {
conn = factory.newConnection("android-client");
Log.d(logTag, "создаю канал");
chan = conn.createChannel();
Log.d(logTag, "объявляю обменник");
chan.exchangeDeclare(exchangeName, "topic", true);
Log.d(logTag, "объявляю очередь");
queueName = chan.queueDeclare().getQueue();
Log.d(logTag, "привинчиваю пересылку сообщений");
chan.queueBind(queueName, exchangeName, ROUTING_KEY);
}catch(IOException e){
Log.d( logTag, "Ошибка подключения: " + Objects.requireNonNull( e.getMessage() ) );
}catch(TimeoutException e1){
Log.d( logTag, "Не смог дождаться подключения: " + Objects.requireNonNull( e1.getMessage() ));
}
}
J
DK