Я пытаюсь подписаться на канал событий в приложении Java.Я пытаюсь создать нового подписчика, следуя примеру, найденному здесь.
Как java-клиент в cumulocity слушает события?
Меня особенно интересуетсобытия, происходящие на устройстве, поэтому я подписываюсь на канал "/ events / 123", где 123 - идентификатор устройства.
public static void main( String[] args )
{
String uRl = "urlOfMyCumulocityIstance";
CumulocityCredentials rC = new CumulocityCredentials("username","password");
PlatformParameters parameters = new PlatformParameters(uRl,rC,new ClientConfiguration());
CepCustomNotificationsSubscriber t = new CepCustomNotificationsSubscriber(parameters);
System.out.println(t.toString() + " - " + t.CEP_CUSTOM_NOTIFICATIONS_URL.toString()); // It prints an integer number corresponding to the subscriber t.
t.subscribe("/events/123", new SubscriptionListener<String, Object>() {
public void onError(Subscription arg0, Throwable arg1) {
// TODO Auto-generated method stub
System.out.println(arg1.getMessage());
}
public void onNotification(Subscription arg0, Object arg1) {
// TODO Auto-generated method stub
System.out.println(arg1);
}
});
}
Тем не менее, я не получаю ни одного из отправленных событийна устройство.
Подводя итог, я хотел бы сделать то, что вы делаете в Apama, набирая
monitor.subscribe(Event.CHANNEL)
on all Event(source=123) as e
{
// do something
}
Есть идеи по этому поводу?Спасибо заранее