Package ch.ethz.inf.vs.californium.coap

Examples of ch.ethz.inf.vs.californium.coap.Request.addMessageObserver()

116
117
118
119
120
121
122
123
124
125
126
      System.out.println("+++++ Sending PUT +++++");
      Request asyncRequest = new Request(Code.PUT, Type.CON);
      asyncRequest.setURI(uri);
      asyncRequest.getOptions().setContentFormat((int) Math.random() * 0xFFFF + 1);
      asyncRequest.setPayload("Random");
      asyncRequest.addMessageObserver(new MessageObserverAdapter() {
        public void onResponse(Response response) {
          if (response != null) {
            checkInt(EXPECTED_RESPONSE_CODE_1.value,
                response.getCode().value, "code");
          }
View Full Code Here
115
116
117
118
119
120
121
122
123
124
125
                System.out.println("++++ obs-reset PUT ++++");
                Request asyncRequest = new Request(Code.POST, Type.CON);
                asyncRequest.setPayload("sesame");
                asyncRequest.setURI(serverURI + "/obs-reset");
                asyncRequest.addMessageObserver(new MessageObserverAdapter() {
                    public void onResponse(Response response) {
                        if (response != null) {
                          System.out.println("Received: " + response.getCode());
                          System.out.println("+++++++++++++++++++++++");
                        }
View Full Code Here
117
118
119
120
121
122
123
124
125
126
127
        // Delete the /obs resource of the server (either locally or by
        // having another CoAP client perform a DELETE request)
        System.out.println("+++++ Sending DELETE +++++");
        Request asyncRequest = new Request(Code.DELETE, Type.CON);
        asyncRequest.setURI(uri);
        asyncRequest.addMessageObserver(new MessageObserverAdapter() {
          public void onResponse(Response response) {
            if (response != null) {
              checkInt(EXPECTED_RESPONSE_CODE_1.value, response.getCode().value, "code");
            }
          }
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
    dmtRes.removeAllChildren();
    dtmRes.reload();
   
    Request request = new Request(Code.GET);
    request.setURI(COAP_PROTOCOL+getHost()+"/.well-known/core");
    request.addMessageObserver(new MessageObserverAdapter() {
      @SuppressWarnings({ "rawtypes", "unchecked" })
      public void onResponse(Response response) {
        String text = response.getPayloadString();
        Scanner scanner = new Scanner(text);
        Pattern pattern = Pattern.compile("<");
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
    cancel.setToken(request.getToken());
    cancel.setDestination(request.getDestination());
    cancel.setDestinationPort(request.getDestinationPort());
    // dispatch final response to the same message observers
    for (MessageObserver mo: request.getMessageObservers())
      cancel.addMessageObserver(mo);
    cancel.send();
    // cancel old ongoing request
    request.cancel();
    this.canceled = true;
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.