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

        Transition Time In Source Status Execution Times Last Executer Last Execution Date
        Open Open In Progress In Progress
        2d 16h 29m 1 Christophe Azemar 30/Sep/16 1:35 PM
        In Progress In Progress Answered Answered
        7s 1 Christophe Azemar 30/Sep/16 1:36 PM
        Answered Answered Closed Closed
        2s 1 Christophe Azemar 30/Sep/16 1:36 PM

          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: