Uploaded image for project: 'Help-Desk'
  1. Help-Desk
  2. HELP-7376

FIWARE.Question.Tech.IoT.DataEdge-Cepheus.Sending event to Orion from Cepheus

    Details

      Description

      Created question in FIWARE Q/A platform on 27-09-2016 at 19:09
      Please, ANSWER this question AT http://stackoverflow.com/questions/39730875/sending-event-to-orion-from-cepheus

      Question:
      Sending event to Orion from Cepheus

      Description:
      I am using the latest version of orangeopensource/fiware-cepheus from GitHub.

      The problem is that based on some existing examples my Cepheus-broker doesn't send any events to Orion which I explicitly declared on the "/tmp/cep-default-.json" file. It produces the following results on the log:

      cepheus_1 | 2016-09-27 17:03:20.209 INFO 10 — [nio-8080-exec-7] c.o.cepheus.cep.EsperEventProcessor : EventIn: Event{type='Position', values={id=Room34, key=24}}
      cepheus_1 | 2016-09-27 17:03:20.840 INFO 10 — [Timer-default-0] c.orange.cepheus.cep.EventSinkListener : EventOut: position / id:24 from insert into position select key as id from Position.win:time(10 minutes) group by key output last every 10 seconds

      But the messages of success or error won't show. This could mean 2 things on EventSinkListener.java:

      updateContext is null (line 76)
      eventTypeOut.getBrokers() returns a null broker (line 79)

      My cep-default-.json is as follows

      {
      "host":"http://localhost:8080",
      "in":[
      {
      "id":"position",
      "type":"Position",
      "attributes":[

      { "name":"key", "type":"string"}

      ]
      }
      ],
      "out":[
      {
      "id":"position",
      "type":"Position",
      "attributes":[

      { "name":"key", "type":"string"}

      ],
      "brokers": [

      { "url":"http://172.17.0.3:1026", "serviceName": "myHome", "servicePath": "/enviroment" }

      ]
      }
      ],
      "statements":[
      "INSERT INTO position SELECT key as id FROM Position.win:time(10 min) GROUP BY key OUTPUT LAST EVERY 10 sec"
      ]
      }

      Being confused about this I tried Example 4 changing the broker address (localhost:8082) to my Orion address (http://172.17.0.3:1026). But when running the script it prints the following:

      UpdateContext failed for http://localhost:8082: java.net.ConnectException: Connection refused

      I confirmed that http://172.17.0.3:1026 is used as the broker address on the config file, but it still uses localhost:8082 somehow.

      Any ideas of what I'm doing wrong?

      Thanks.

        Activity

        Hide
        backlogmanager Backlog Manager added a comment -

        2016-09-27 21:05|CREATED monitor | # answers= 0, accepted answer= False

        Show
        backlogmanager Backlog Manager added a comment - 2016-09-27 21:05|CREATED monitor | # answers= 0, accepted answer= False
        Hide
        fermin Fermín Galán added a comment -

        Looking to the question, it seems not related with Orion but Cepheus. Assining back to Manuel Escriche, so he can assign to Cepheus owner.

        Show
        fermin Fermín Galán added a comment - Looking to the question, it seems not related with Orion but Cepheus. Assining back to Manuel Escriche, so he can assign to Cepheus owner.

          People

          • Assignee:
            cazemar Christophe Azemar
            Reporter:
            backlogmanager Backlog Manager
          • Votes:
            0 Vote for this issue
            Watchers:
            2 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved: