J
Size: a a a
J
DK
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() ));
}
}DP
DK
DK
DK
DP
public class ChatService extends Service {
...
public int onStartCommand(Intent intent, int flags, int startId){
startListeners();
}
...
void startListeners(){
try{ receiver = new ChatReceiver(); }
catch(IOException и другие){ Log.d() }
catch(Exception){ /* вот тут вылазит */ }
}
}
DP
DP
startService( new Intent( this, ChatService.class ) );
DK
public class ChatService extends Service {
...
public int onStartCommand(Intent intent, int flags, int startId){
startListeners();
}
...
void startListeners(){
try{ receiver = new ChatReceiver(); }
catch(IOException и другие){ Log.d() }
catch(Exception){ /* вот тут вылазит */ }
}
}
DP
DK
И

DP
DP
DP
ДД

СС
V