Package org.vertx.java.core.buffer

Examples of org.vertx.java.core.buffer.Buffer

36
37
38
39
40
41
42
43
44
45
        });
        //Now send some dataHandler
        for (int i = 0; i < 10; i++) {
          String str = "hello" + i + "\n";
          System.out.print("Net client sending: " + str);
          socket.write(new Buffer(str));
        }
      }
    });
  }
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
65
      client.connectWebsocket("/mtgox", new Handler<WebSocket>() {
        @Override
        public void handle(final WebSocket ws) {
          LOGGER.info("Connected to: " + MTGOX_HOST_NAME);

          ws.writeBuffer(new Buffer("{\"op\":\"unsubscribe\",\"channel\":\"" + MTGOX_TICKER_CHANNEL + "\"}"));
          ws.writeBuffer(new Buffer("{\"op\":\"unsubscribe\",\"channel\":\"" + MTGOX_DEPTH_CHANNEL + "\"}"));

          ws.dataHandler(new Handler<Buffer>() {
            @Override
            public void handle(Buffer buffer) {
              LOGGER.info("Message received: " + buffer);
View Full Code Here
42
43
44
45
46
47
48
49
50
51
52
53
    client.connectWebsocket("/mtgox", new Handler<WebSocket>() {
      @Override
        public void handle(final WebSocket ws) {
        container.getLogger().info("Connected to: " + MTGOX_HOST_NAME);

        ws.writeBuffer(new Buffer("{\"op\":\"unsubscribe\",\"channel\":\"" + MTGOX_TICKER_CHANNEL + "\"}"));
        ws.writeBuffer(new Buffer("{\"op\":\"unsubscribe\",\"channel\":\"" + MTGOX_DEPTH_CHANNEL + "\"}"));

        ws.dataHandler(new Handler<Buffer>() {
          @Override
          public void handle(Buffer buffer) {
            container.getLogger().info("Message received: " + buffer);
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
              start = end;
            }
          }
        });

        Buffer buff = new Buffer(new byte[packetSize]);

        sendData(socket, buff);
      }
    });
  }
View Full Code Here
35
36
37
38
39
40
41
42
43
44
        //Now send some data
        for (int i = 0; i < 10; i++) {
          String str = "hello" + i + "\n";
          System.out.print("Net client sending: " + str);
          socket.write(new Buffer(str));
        }
      }
    });
  }
View Full Code Here
223
224
225
226
227
228
229
230
231
232
233
              String responseText = getHostPage(sessionId, username, activeClientId);
              response.statusCode = HttpStatus.SC_OK;
              byte[] page = responseText.getBytes(Charset.forName("UTF-8"));
              response.putHeader("Content-Length", page.length);
              response.putHeader("Content-Type", "text/html");
              response.end(new Buffer(page));         
            } else {
              sendRedirect(req, "/static/login.html");
            }
          }
        });
View Full Code Here
125
126
127
128
129
130
131
132
133
134
135
  }

  private void writeWebSocket(final WebSocket ws) {
    if (!ws.writeQueueFull()) {
      //ws.writeTextFrame(message);
      ws.writeBinaryFrame(new Buffer(message));
      vertx.runOnLoop(new SimpleHandler() {
        public void handle() {
          writeWebSocket(ws);
        }
      });
View Full Code Here
33
34
35
36
37
38
39
40
41
42
        });
        //Now send some dataHandler
        for (int i = 0; i < 10; i++) {
          String str = "hello" + i + "\n";
          System.out.print("Net client sending: " + str);
          socket.write(new Buffer(str));
        }
      }
    });
  }
View Full Code Here
43
44
45
46
47
48
49
50
51
52
53
            } else if (line.startsWith("publish")) {
              System.out.println("Publish to topic is " + parts[1]);
              Set<String> actorIDs = vertx.sharedData().getSet(parts[1]);
              for (String actorID : actorIDs) {
                System.out.println("Sending to verticle");
                vertx.eventBus().publish(actorID, new Buffer(parts[2]));
              }
            }
          }
        }));
      }
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
    @Override
    public void handle(final HttpServerRequest vertxRequest) {

        // Wait for the body for jersey to handle form/json/xml params
        if (shouldReadData(vertxRequest)) {
            final Buffer body = new Buffer();

            vertxRequest.dataHandler(new Handler<Buffer>() {
                public void handle(Buffer buff) {
                    body.appendBuffer(buff);
                    if (body.length() > maxBodySize) {
                        throw new RuntimeException("The input stream has exceeded the max allowed body size "
                                + maxBodySize + ".");
                    }
                }
            });
            vertxRequest.endHandler(new Handler<Void>() {
                @Override
                public void handle(Void event) {
                    InputStream inputStream = new FastByteArrayInputStream(body.getBytes());
                    DefaultJerseyHandler.this.handle(vertxRequest, inputStream);
                }
            });

        } else {
View Full Code Here
TOP

Related Classes of org.vertx.java.core.buffer.Buffer

  • com.englishtown.vertx.cassandra.binarystore.impl.DefaultBinaryStoreWriter
  • com.englishtown.vertx.cassandra.binarystore.impl.DefaultFileReader
  • com.englishtown.vertx.CassandraBinaryStore
  • com.englishtown.vertx.CouchbasePersistor
  • com.englishtown.vertx.GridFSModule
  • com.englishtown.vertx.jersey.impl.DefaultJerseyHandler
  • com.englishtown.vertx.jersey.impl.VertxResponseWriter$VertxChunkedOutputStream
  • com.englishtown.vertx.jersey.impl.VertxResponseWriter$VertxOutputStream
  • com.google.collide.server.fe.WebFE
  • com.jetdrone.vertx.persona.Persona
    • Copyright © 2018 www.massapicom. 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.