Постоянное подключение к АТС Asterisk?

Question

[Владимир Сачков]

Суть вопроса в том как держать постоянное подключение с АТС ASterisk через java console. У меня есть код который выполняет мой Action и я получаю ответ , но программа выполняется 1 раз. Как реализовать постоянное соединение(подключение) облазил инет ничего стоящего не нашел или пропустил. Благодарю заранее за помощь.

Comments

[Gansterito]

Что-то не понял что за java console.
Внешние системы могут взаимодействовать с Asterisk по протоколам AMI, AGI и ARI (усовершенствованная версия первых двух). Ваш java-код скорей всего подключается через AMI (там есть Action) и отдает команды Asterisk-у.
AMI подразумевает постоянное подключение (подключился, слушаешь события, отдаешь команды), а не сессионное (подключился, отдал команду, получил ответ, отключился), поэтому описанное Вами поведение явно ненормальное.

[roswell]

Код в студию, а то все телепаты в отпуске чот...

[Владимир Сачков]

roswell, import org.asteriskjava.manager.*;
import org.asteriskjava.manager.event.ExtensionStatusEvent;
import org.asteriskjava.manager.event.ManagerEvent;
import org.asteriskjava.manager.event.QueueMemberEvent;
import org.asteriskjava.manager.response.ManagerResponse;

import java.io.IOException;
import java.io.PrintStream;
import java.util.*;

public class AmiConnection implements ManagerEventListener {
List list = new ArrayList<>();
List list1 = new ArrayList<>();
static Map map = new HashMap<>();
int i = 0;

public AmiConnection() throws AuthenticationFailedException, TimeoutException, IOException {
ManagerConnectionFactory factory = new ManagerConnectionFactory(
AstriskConnection.ADDRESS,
AstriskConnection.PORT,
AstriskConnection.LOGIN,
AstriskConnection.PASSWORD);

ManagerConnection managerConnection = factory.createManagerConnection();

ManagerResponse response;

// System.setOut(new PrintStream("stdout.log"));
System.setErr(new PrintStream("stderr.log"));
ExtensionStateList extensionStateList = new ExtensionStateList();

managerConnection.addEventListener(this);
managerConnection.login();

// ===================== Вывод статусов ====================

response = managerConnection.sendAction(extensionStateList, 30000);

System.out.println("SendAction = " + extensionStateList);
System.out.println("Response = " + response);

managerConnection.logoff();
}

public void onManagerEvent(ManagerEvent event) {

String event_name = event.getClass().getSimpleName();
// System.out.println("Name = " + event_name);
if (event_name.equals("QueueMemberEvent")) {
QueueMemberEvent e = (QueueMemberEvent) event;
System.out.print(e.getName() + " - ");//caller number
System.out.println(e.getStatus());//Called number
}
if (event_name.equals("ExtensionStatusEvent")) {
ExtensionStatusEvent e = (ExtensionStatusEvent) event;
if (e.getExten().length() < 3) {
list.add(e.getExten());
list1.add(e.getStatus().toString());
map.put(list.get(i), list1.get(i));
i++;
}

}

}

public static void sortbykeyMap() {
// TreeMap to store values of HashMap
TreeMap sorted = new TreeMap<>();

// Copy all data from hashMap into TreeMap
sorted.putAll(map);

// Display the TreeMap which is naturally sorted
for (Map.Entry entry : sorted.entrySet())
switch (entry.getValue().toString()) {
case "16":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " On Hold");
break;
case "8":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " Ringing");
break;
case "-1":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " Extension not found");
break;
case "2":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " Busy");
break;
case "4":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " Unavailable");
break;
case "1":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " In use");
break;
case "0":
System.out.println("PJSIP " + entry.getKey() +
",Status " + entry.getValue() + " Idle");
break;
}
}

public static void main(String[] args) throws Exception {
new AmiConnection();
sortbykeyMap();

}
}

[Владимир Сачков]

Gansterito, Я хотел написать что будет работать как консольное приложение в фоновом режиме

[roswell]

Владимир Сачков, ясно-понятно. Action: Ping в отдельном треде пару раз в минуту спасёт отца демократии.

[Владимир Сачков]

roswell, можешь пожалуйста на примере накидать?

[Тима]

roswell, т.е. создать поток, а куда передавать Ping?
Если не сложно, пожалуйста напишите кусочек или объясните по подробнее.
Тоже сижу с такой проблемой уже несколько часов.

С ув. Спасибо!

[roswell]

Владимир Сачков, Тима, примерно так

Executors.newScheduledThreadPool(1).schedule(() -> {
    if (managerConnection != null) {
        managerConnection.sendAction(new PingAction());
    }
}, 30, TimeUnit.SECONDS);

Кстати, managerConnection.logoff() там выше в коде совершенно лишняя штука.

[Владимир Сачков]

roswell, Огромное спасибо , сделал , работает на ура !

[roswell]

Владимир Сачков, та нема за шо. Сейчас ответом оформлю, если уж разобрались.

Answer 1

[roswell]

Примерно так

Executors.newScheduledThreadPool(1).schedule(() -> {
    if (managerConnection != null) {
        managerConnection.sendAction(new PingAction());
    }
}, 30, TimeUnit.SECONDS);

Кстати, managerConnection.logoff() там выше в коде совершенно лишняя штука.