Подписаться на канал событий в приложении Java - Cumulocity - PullRequest
0 голосов
/ 30 января 2019

Я пытаюсь подписаться на канал событий в приложении 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
}

Есть идеи по этому поводу?Спасибо заранее

...