Skip to content
Browse files

renamed to vert.x

  • Loading branch information...
1 parent 284d60a commit a6674914a4d9f241c876d4db3028e11cea9e2555 @purplefox purplefox committed Oct 11, 2011
Showing with 1,214 additions and 1,202 deletions.
  1. +1 −1 .yardopts
  2. +1 −1 LICENSE.txt
  3. +16 −16 README.md
  4. +18 −18 build.xml
  5. +3 −3 docs/dev-manual.txt
  6. +3 −3 mgmt/Planning.txt
  7. +21 −21 src/examples/java/README
  8. +2 −2 src/examples/java/build.xml
  9. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/echo/EchoClient.java
  10. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/echo/EchoServer.java
  11. +10 −10 src/examples/java/org/{nodex → vertx}/java/examples/echo/PerfClient.java
  12. +11 −11 src/examples/java/org/{nodex → vertx}/java/examples/fanout/FanoutServer.java
  13. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/http/ClientExample.java
  14. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/http/ServerExample.java
  15. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/https/ClientExample.java
  16. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/https/ServerExample.java
  17. +2 −2 src/examples/java/org/{nodex → vertx}/java/examples/old/amqp/ClientExample.java
  18. +1 −1 src/examples/java/org/{nodex → vertx}/java/examples/old/composition/CompositionExample.java
  19. +6 −6 src/examples/java/org/{nodex → vertx}/java/examples/old/stomp/ClientExample.java
  20. +3 −3 src/examples/java/org/{nodex → vertx}/java/examples/old/stomp/ServerExample.java
  21. +6 −6 src/examples/java/org/{nodex → vertx}/java/examples/old/stomp/StompPerf.java
  22. +8 −8 src/examples/java/org/{nodex → vertx}/java/examples/proxy/HttpClient.java
  23. +8 −8 src/examples/java/org/{nodex → vertx}/java/examples/proxy/HttpServer.java
  24. +11 −11 src/examples/java/org/{nodex → vertx}/java/examples/proxy/ProxyServer.java
  25. +11 −11 src/examples/java/org/{nodex → vertx}/java/examples/pubsub/PubSubServer.java
  26. +11 −11 src/examples/java/org/{nodex → vertx}/java/examples/redis/RedisExample.java
  27. +6 −6 src/examples/java/org/{nodex → vertx}/java/examples/sendfile/SendFileExample.java
  28. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/ssl/SSLClient.java
  29. +7 −7 src/examples/java/org/{nodex → vertx}/java/examples/ssl/SSLServer.java
  30. +13 −13 src/examples/java/org/{nodex → vertx}/java/examples/upload/UploadClient.java
  31. +12 −12 src/examples/java/org/{nodex → vertx}/java/examples/upload/UploadServer.java
  32. +8 −8 src/examples/java/org/{nodex → vertx}/java/examples/websockets/WebsocketsExample.java
  33. +2 −2 src/examples/java/sendfile/index.html
  34. +2 −0 src/examples/java/websockets/ws.html
  35. +20 −20 src/examples/ruby/README
  36. +3 −3 src/examples/ruby/echo/echo_client.rb
  37. +3 −3 src/examples/ruby/echo/echo_server.rb
  38. +4 −4 src/examples/ruby/fanout/fanout_server.rb
  39. +3 −3 src/examples/ruby/http/http_client.rb
  40. +4 −4 src/examples/ruby/http/http_server.rb
  41. +3 −3 src/examples/ruby/https/https_client.rb
  42. +4 −4 src/examples/ruby/https/https_server.rb
  43. +1 −1 src/examples/ruby/old/amqp/amqp_client.sh
  44. +1 −1 src/examples/ruby/old/composition/composition_example.sh
  45. +1 −1 src/examples/ruby/old/redis/redis_client.sh
  46. +1 −1 src/examples/ruby/old/stomp/stomp_client.sh
  47. +1 −1 src/examples/ruby/old/stomp/stomp_perf.sh
  48. +3 −3 src/examples/ruby/proxy/http_client.rb
  49. +3 −3 src/examples/ruby/proxy/http_server.rb
  50. +3 −3 src/examples/ruby/proxy/proxy_server.rb
  51. +4 −4 src/examples/ruby/pubsub/pubsub_server.rb
  52. +3 −3 src/examples/ruby/redis/redis_example.rb
  53. +2 −2 src/examples/ruby/sendfile/index.html
  54. +3 −3 src/examples/ruby/sendfile/sendfile.rb
  55. +3 −3 src/examples/ruby/ssl/ssl_client.rb
  56. +3 −3 src/examples/ruby/ssl/ssl_server.rb
  57. +3 −3 src/examples/ruby/upload/upload_client.rb
  58. +3 −3 src/examples/ruby/upload/upload_server.rb
  59. +3 −3 src/examples/ruby/websockets/websockets.rb
  60. +3 −3 src/main/groovy/org/{nodex/groovy/core/Nodex.groovy → vertx/groovy/core/Vertx.groovy}
  61. +4 −4 src/main/groovy/org/{nodex → vertx}/groovy/core/net/NetServer.groovy
  62. +2 −2 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/AmqpClient.java
  63. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/AmqpConnectHandler.java
  64. +3 −3 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/AmqpConnection.java
  65. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/AmqpMsgCallback.java
  66. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/AmqpProps.java
  67. +4 −4 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/Channel.java
  68. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/ChannelHandler.java
  69. +2 −2 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/ChannelPool.java
  70. 0 src/main/java/org/{nodex → vertx}/java/addons/old/amqp/README
  71. +2 −2 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/Frame.java
  72. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/FrameHandler.java
  73. +4 −4 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/Parser.java
  74. 0 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/README
  75. +4 −4 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/StompClient.java
  76. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/StompConnectHandler.java
  77. +3 −3 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/StompConnection.java
  78. +2 −2 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/StompMsgCallback.java
  79. +4 −4 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/StompServer.java
  80. +2 −2 src/main/java/org/{nodex → vertx}/java/addons/old/stomp/StompServerConnection.java
  81. +10 −10 src/main/java/org/{nodex → vertx}/java/addons/redis/InternalConnection.java
  82. +14 −14 src/main/java/org/{nodex → vertx}/java/addons/redis/RedisConnection.java
  83. +9 −9 src/main/java/org/{nodex → vertx}/java/addons/redis/RedisDeferred.java
  84. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/redis/RedisException.java
  85. +6 −6 src/main/java/org/{nodex → vertx}/java/addons/redis/RedisPool.java
  86. +2 −2 src/main/java/org/{nodex → vertx}/java/addons/redis/RedisReply.java
  87. +1 −1 src/main/java/org/{nodex → vertx}/java/addons/redis/ReplyHandler.java
  88. +5 −5 src/main/java/org/{nodex → vertx}/java/addons/redis/ReplyParser.java
  89. +10 −10 src/main/java/org/{nodex → vertx}/java/core/BlockingAction.java
  90. +1 −1 src/main/java/org/{nodex → vertx}/java/core/CompletionHandler.java
  91. +5 −5 src/main/java/org/{nodex → vertx}/java/core/ConnectionPool.java
  92. +2 −2 src/main/java/org/{nodex → vertx}/java/core/Deferred.java
  93. +2 −2 src/main/java/org/{nodex → vertx}/java/core/DeferredAction.java
  94. +1 −1 src/main/java/org/{nodex → vertx}/java/core/Future.java
  95. +2 −2 src/main/java/org/{nodex → vertx}/java/core/Handler.java
  96. +2 −2 src/main/java/org/{nodex → vertx}/java/core/Immutable.java
  97. +1 −1 src/main/java/org/{nodex → vertx}/java/core/SimpleAction.java
  98. +1 −1 src/main/java/org/{nodex → vertx}/java/core/SimpleFuture.java
  99. +1 −1 src/main/java/org/{nodex → vertx}/java/core/SimpleHandler.java
  100. +1 −1 src/main/java/org/{nodex → vertx}/java/core/SynchronousAction.java
  101. +4 −4 src/main/java/org/{nodex/java/core/Nodex.java → vertx/java/core/Vertx.java}
  102. +19 −19 src/main/java/org/{nodex/java/core/NodexImpl.java → vertx/java/core/VertxImpl.java}
  103. +8 −8 src/main/java/org/{nodex/java/core/NodexMain.java → vertx/java/core/VertxMain.java}
  104. +2 −2 src/main/java/org/{nodex → vertx}/java/core/buffer/Buffer.java
  105. +7 −7 src/main/java/org/{nodex → vertx}/java/core/composition/Composer.java
  106. +25 −25 src/main/java/org/{nodex → vertx}/java/core/file/AsyncFile.java
  107. +1 −1 src/main/java/org/{nodex → vertx}/java/core/file/FileProps.java
  108. +7 −7 src/main/java/org/{nodex → vertx}/java/core/file/FileSystem.java
  109. +1 −1 src/main/java/org/{nodex → vertx}/java/core/file/FileSystemException.java
  110. +1 −1 src/main/java/org/{nodex → vertx}/java/core/file/FileSystemProps.java
  111. +2 −2 src/main/java/org/{nodex → vertx}/java/core/http/AbstractConnection.java
  112. +4 −4 src/main/java/org/{nodex → vertx}/java/core/http/ClientConnection.java
  113. +1 −1 src/main/java/org/{nodex → vertx}/java/core/http/HeaderUtils.java
  114. +17 −17 src/main/java/org/{nodex → vertx}/java/core/http/HttpClient.java
  115. +9 −9 src/main/java/org/{nodex → vertx}/java/core/http/HttpClientRequest.java
  116. +8 −8 src/main/java/org/{nodex → vertx}/java/core/http/HttpClientResponse.java
  117. +11 −12 src/main/java/org/{nodex → vertx}/java/core/http/HttpServer.java
  118. +8 −8 src/main/java/org/{nodex → vertx}/java/core/http/HttpServerRequest.java
  119. +7 −7 src/main/java/org/{nodex → vertx}/java/core/http/HttpServerResponse.java
  120. +6 −6 src/main/java/org/{nodex → vertx}/java/core/http/ServerConnection.java
  121. +10 −10 src/main/java/org/{nodex → vertx}/java/core/http/Websocket.java
  122. +1 −1 src/main/java/org/{nodex → vertx}/java/core/http/WebsocketHandshakeHelper.java
  123. +6 −6 ...a/org/{nodex/java/core/internal/NodexInternal.java → vertx/java/core/internal/VertxInternal.java}
  124. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/JULLogDelegate.java
  125. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/JULLogDelegateFactory.java
  126. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/Log4jLogDelegate.java
  127. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/Log4jLogDelegateFactory.java
  128. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/LogDelegate.java
  129. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/LogDelegateFactory.java
  130. +8 −8 src/main/java/org/{nodex → vertx}/java/core/logging/Logger.java
  131. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/SLF4JLogDelegate.java
  132. +1 −1 src/main/java/org/{nodex → vertx}/java/core/logging/SLF4JLogDelegateFactory.java
  133. +3 −3 .../java/core/logging/NodexLoggerFormatter.java → vertx/java/core/logging/VertxLoggerFormatter.java}
  134. +7 −7 src/main/java/org/{nodex → vertx}/java/core/net/ConnectionBase.java
  135. +4 −4 src/main/java/org/{nodex → vertx}/java/core/net/NetBase.java
  136. +25 −14 src/main/java/org/{nodex → vertx}/java/core/net/NetClient.java
  137. +1 −1 src/main/java/org/{nodex → vertx}/java/core/net/NetClientBase.java
  138. +17 −17 src/main/java/org/{nodex → vertx}/java/core/net/NetServer.java
  139. +1 −1 src/main/java/org/{nodex → vertx}/java/core/net/NetServerBase.java
  140. +12 −12 src/main/java/org/{nodex → vertx}/java/core/net/NetSocket.java
  141. +1 −1 src/main/java/org/{nodex → vertx}/java/core/net/TLSHelper.java
  142. +3 −3 src/main/java/org/{nodex → vertx}/java/core/parsetools/RecordParser.java
  143. +1 −1 src/main/java/org/{nodex → vertx}/java/core/shared/SharedCounter.java
  144. +3 −3 src/main/java/org/{nodex → vertx}/java/core/shared/SharedData.java
  145. +1 −1 src/main/java/org/{nodex → vertx}/java/core/shared/SharedMap.java
  146. +1 −1 src/main/java/org/{nodex → vertx}/java/core/shared/SharedQueue.java
  147. +1 −1 src/main/java/org/{nodex → vertx}/java/core/shared/SharedSet.java
  148. +3 −3 src/main/java/org/{nodex → vertx}/java/core/shared/SharedUtils.java
  149. +9 −9 src/main/java/org/{nodex → vertx}/java/core/stdio/InStream.java
  150. +8 −8 src/main/java/org/{nodex → vertx}/java/core/stdio/OutStream.java
  151. +3 −3 src/main/java/org/{nodex → vertx}/java/core/stdio/Stdio.java
  152. +4 −4 src/main/java/org/{nodex → vertx}/java/core/stdio/StreamBase.java
  153. +5 −5 src/main/java/org/{nodex → vertx}/java/core/streams/Pump.java
  154. +3 −3 src/main/java/org/{nodex → vertx}/java/core/streams/ReadStream.java
  155. +3 −3 src/main/java/org/{nodex → vertx}/java/core/streams/WriteStream.java
  156. +1 −1 src/main/java/org/{nodex → vertx}/java/scratch/ConnectionHandler.java
  157. +1 −1 src/main/java/org/{nodex → vertx}/java/scratch/Pool.java
  158. BIN src/main/resources/jars/jedis/jedis-2.0.0.jar
  159. BIN src/main/resources/jars/rabbit/commons-cli-1.1.jar
  160. BIN src/main/resources/jars/rabbit/commons-io-1.2.jar
  161. BIN src/main/resources/jars/rabbit/rabbitmq-client.jar
  162. +4 −4 src/main/resources/logging.properties
  163. +8 −8 src/main/ruby/addons/old/amqp.rb
  164. +6 −6 src/main/ruby/addons/old/composition.rb
  165. +4 −4 src/main/ruby/addons/old/redis.rb
  166. +4 −4 src/main/ruby/addons/old/stomp.rb
  167. +9 −9 src/main/ruby/addons/redis.rb
  168. +4 −4 src/main/ruby/core/buffer.rb
  169. +9 −9 src/main/ruby/core/composition.rb
  170. +43 −43 src/main/ruby/core/file_system.rb
  171. +9 −9 src/main/ruby/core/global_handlers.rb
  172. +3 −3 src/main/ruby/core/http.rb
  173. +5 −5 src/main/ruby/core/net.rb
  174. +3 −3 src/main/ruby/core/parsetools.rb
  175. +8 −8 src/main/ruby/core/shared_data.rb
  176. +1 −1 src/main/ruby/core/ssl_support.rb
  177. +4 −4 src/main/ruby/core/std_io.rb
  178. +2 −2 src/main/ruby/core/streams.rb
  179. +8 −8 src/main/ruby/core/timers.rb
  180. +5 −5 src/main/ruby/{nodex.rb → vertx.rb}
  181. +3 −3 src/scripts/{nodex-java → vertx-java}
  182. +3 −3 src/scripts/{nodex-ruby → vertx-ruby}
  183. +2 −2 src/tests/java/org/{nodex → vertx}/tests/AwaitDone.java
  184. +2 −2 src/tests/java/org/{nodex → vertx}/tests/Utils.java
  185. +15 −15 src/tests/java/org/{nodex → vertx}/tests/addons/redis/RedisReconnectTest.java
  186. +16 −16 src/tests/java/org/{nodex → vertx}/tests/addons/redis/RedisTest.java
  187. +8 −8 src/tests/java/org/{nodex → vertx}/tests/addons/redis/ReplyParserTest.java
  188. +8 −8 src/tests/java/org/{nodex → vertx}/tests/core/ConnectionPoolTest.java
  189. +18 −18 src/tests/java/org/{nodex → vertx}/tests/core/GlobalHandlersTest.java
  190. +8 −8 src/tests/java/org/{nodex → vertx}/tests/core/TestBase.java
  191. +18 −18 src/tests/java/org/{nodex → vertx}/tests/core/TimerTest.java
  192. +4 −4 src/tests/java/org/{nodex → vertx}/tests/core/buffer/BufferTest.java
  193. +4 −4 src/tests/java/org/{nodex → vertx}/tests/core/composition/ComposerTest.java
  194. +21 −21 src/tests/java/org/{nodex → vertx}/tests/core/file/FileSystemTest.java
  195. +25 −25 src/tests/java/org/{nodex → vertx}/tests/core/http/HttpTest.java
  196. +12 −12 src/tests/java/org/{nodex → vertx}/tests/core/http/WebsocketTest.java
  197. +28 −28 src/tests/java/org/{nodex → vertx}/tests/core/net/NetTest.java
  198. +16 −16 src/tests/java/org/{nodex → vertx}/tests/core/net/TLSTest.java
  199. +20 −20 src/tests/java/org/{nodex → vertx}/tests/core/net/ThreadingTest.java
  200. +5 −5 src/tests/java/org/{nodex → vertx}/tests/core/parsetools/RecordParserTest.java
  201. +6 −6 src/tests/java/org/{nodex → vertx}/tests/core/shared/SharedDataTest.java
  202. +11 −11 src/tests/java/org/{nodex → vertx}/tests/core/stdio/StdioTest.java
  203. +8 −8 src/tests/java/org/{nodex → vertx}/tests/core/streams/PumpTest.java
  204. +10 −10 src/tests/ruby/actor_test.rb
  205. +5 −5 src/tests/ruby/addons/redis_test.rb
  206. +3 −3 src/tests/ruby/buffer_test.rb
  207. +2 −2 src/tests/ruby/composition_test.rb
  208. +7 −7 src/tests/ruby/file_system_test.rb
  209. +3 −3 src/tests/ruby/http_test.rb
  210. +5 −5 src/tests/ruby/net_test.rb
  211. +2 −2 src/tests/ruby/record_parser_test.rb
  212. +1 −1 src/tests/ruby/run_tests.sh
  213. +2 −2 src/tests/ruby/scratch_test.rb
  214. +2 −2 src/tests/ruby/shared_data_test.rb
  215. +7 −7 src/tests/ruby/timer_test.rb
  216. +4 −4 src/tests/ruby/utils.rb
View
2 .yardopts
@@ -1 +1 @@
---title "Node.x Ruby API" --readme README.md --no-private --output-dir target/docs/ruby/api/ src/main/ruby/nodex.rb src/main/ruby/core/** - LICENSE.txt
+--title "vert.x Ruby API" --readme README.md --no-private --output-dir target/docs/ruby/api/ src/main/ruby/vertx.rb src/main/ruby/core/** - LICENSE.txt
View
2 LICENSE.txt
@@ -1,4 +1,4 @@
-Node.x is licensed under the Apache License, Version 2.0 (the "License");
+vert.x is licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
View
32 README.md
@@ -1,13 +1,13 @@
-# Node.x
+# vert.x
-## What is Node.x?
+## What is vert.x?
The next generation polyglot asynchronous application framework.
* Runs on the JVM.
* Embraces the good bits of event driven frameworks like node.js without the bad bits. Then adds some even juicier bits.
* Everything is non-blocking.
-* Polyglot. Node.x will be usable from multiple languages: Ruby, Groovy, Java, JavaScript, Python, Clojure, Scala. Write your code in the language *you* choose. Leverage the power of node.x from that language.
+* Polyglot. vert.x will be usable from multiple languages: Ruby, Groovy, Java, JavaScript, Python, Clojure, Scala. Write your code in the language *you* choose. Leverage the power of vert.x from that language.
* Goes with the recent developments with InvokeDynamic in Java 7 and bets on the JVM being the future premier runtime for dynamic languages.
* Enables you to create network servers or clients incredibly easily.
* True scalability. Unlike other well-known event-driven frameworks, you can have more than one event loop per process. No more spinning up 32 instances just to utilise the cores on your server.
@@ -16,47 +16,47 @@ The next generation polyglot asynchronous application framework.
* Efficiently serve static files from the filesystem bypassing userspace altogether.
* Provides an elegant api for composing asynchronous actions together. Glue together HTTP, AMQP, Redis or whatever in a few lines of code.
* Asynchronous plugins will be provided for a wide variety of other systems and protocols including AMQP, Redis, REST, Gemfire, MongoDB, STOMP, Twitter, SMTP, JDBC, Memcached, JMS, ZeroMQ, JDBC, web frameworks, etc
-* Module manager. Install modules from a public repository. Create your own applications and push them to the repo. Creates a market for an ecosystem of node.x modules.
+* Module manager. Install modules from a public repository. Create your own applications and push them to the repo. Creates a market for an ecosystem of vert.x modules.
## Jump to the examples
-Take a look at some of these working Ruby examples to see the kind of things you can do with Node.x
+Take a look at some of these working Ruby examples to see the kind of things you can do with vert.x
-[Ruby examples](https://github.com/purplefox/node.x/tree/master/src/examples/ruby "Ruby examples")
+[Ruby examples](https://github.com/purplefox/vert.x/tree/master/src/examples/ruby "Ruby examples")
-[Java examples](https://github.com/purplefox/node.x/tree/master/src/examples/java "Java examples")
+[Java examples](https://github.com/purplefox/vert.x/tree/master/src/examples/java "Java examples")
-## What is the status of Node.x?
+## What is the status of vert.x?
-The first binary release, node.x 0.1, has been released. We aim to follow the mantra of "release early, release often"
+The first binary release, vert.x 0.1, has been released. We aim to follow the mantra of "release early, release often"
-You can find the Road-map [here] (https://github.com/purplefox/node.x/wiki/Road-map)
+You can find the Road-map [here] (https://github.com/purplefox/vert.x/wiki/Road-map)
## What is the architecture?
-Node.x *core* is written in Java. We then provide a thin layer in each of the JVM languages we support which allows the API to be used in each of the supported languages.
+vert.x *core* is written in Java. We then provide a thin layer in each of the JVM languages we support which allows the API to be used in each of the supported languages.
We do not expose the Java API directly in the other languages since we wish to retain the normal coding idioms for each supported language.
We don't leak Java stuff to other languages through the API.
-Node.x internally uses [Netty](https://github.com/netty/netty "Netty") for much of the asynchronous IO.
+vert.x internally uses [Netty](https://github.com/netty/netty "Netty") for much of the asynchronous IO.
## Building from source
-Instructions for building node.x from source are [here](https://github.com/purplefox/node.x/wiki/Build-instructions)
+Instructions for building vert.x from source are [here](https://github.com/purplefox/vert.x/wiki/Build-instructions)
## Installation and running the examples
-Instructions for installing and running node.x are are [here] (https://github.com/purplefox/node.x/wiki/Instructions-for-installing-and-running-node.x)
+Instructions for installing and running vert.x are are [here] (https://github.com/purplefox/vert.x/wiki/Instructions-for-installing-and-running-vert.x)
## Development and user discussions
-[node.x dev Google Group](http://groups.google.com/group/nodex-dev "Node.x dev")
+[vert.x dev Google Group](http://groups.google.com/group/nodex-dev "Node.x dev")
## FAQ
-FAQ [here] (https://github.com/purplefox/node.x/wiki/FAQ)
+FAQ [here] (https://github.com/purplefox/vert.x/wiki/FAQ)
## IRC
View
36 build.xml
@@ -14,18 +14,18 @@
~ limitations under the License.
-->
-<project name="node.x" default="jar-core" basedir=".">
+<project name="vert.x" default="jar-core" basedir=".">
<description>
- Build script for node.x
+ Build script for vert.x
</description>
<!-- set global properties for this build -->
<property name="target" value="target"/>
- <property name="jar-file" value="node.x.jar"/>
+ <property name="jar-file" value="vert.x.jar"/>
<property name="version-number" value="0.1"/>
<property name="dist-build-base" value="${target}/dist-build"/>
- <property name="dist-build" value="${dist-build-base}/node.x-${version-number}"/>
+ <property name="dist-build" value="${dist-build-base}/vert.x-${version-number}"/>
<property name="core-src" value="src/main/java"/>
<property name="core-target" value="${target}/core/classes"/>
@@ -51,7 +51,7 @@
<include name="*.jar"/>
</fileset>
<pathelement location="${tests-target}"/>
- <pathelement location="target/node.x.jar"/>
+ <pathelement location="target/vert.x.jar"/>
</path>
<taskdef name="testng" classpathref="test-classpath"
@@ -85,7 +85,7 @@
<target name="java-tests" depends="compile-tests">
<testng classpathref="test-classpath">
- <!-- <testng classpathref="test-classpath" methods="org.nodex.tests.core.net.NetTest.*"> -->
+ <!-- <testng classpathref="test-classpath" methods="org.vertx.tests.core.net.NetTest.*"> -->
<sysproperty key="java.util.logging.config.file" value="${resources-dir}/logging.properties"/>
<classfileset dir="${tests-target}" includes="**/*Test.class" excludes="**/redis/*.class"/>
<!-- <classfileset dir="${tests-target}" includes="**/RedisReconnectTest.class"/> -->
@@ -104,14 +104,14 @@
</target>
<target name="javadoc" depends="compile-core">
- <javadoc destdir="${target}/${javadoc-dir}" author="true" version="false" use="true" windowtitle="Node.x Java API"
- classpathref="core-lib-classpath" Public="true" sourcepath="${core-src}" packagenames="org.nodex.java.core.*"
- excludepackagenames="org.nodex.java.core.internal">
+ <javadoc destdir="${target}/${javadoc-dir}" author="true" version="false" use="true" windowtitle="vert.x Java API"
+ classpathref="core-lib-classpath" Public="true" sourcepath="${core-src}" packagenames="org.vertx.java.core.*"
+ excludepackagenames="org.vertx.java.core.internal">
<!-- <fileset dir="${core-src}" defaultexcludes="yes">
- <include name="org/nodex/java/core/**"/>
+ <include name="org/vertx/java/core/**"/>
</fileset>
-->
- <doctitle><![CDATA[<h1>Node.x Java API</h1>]]></doctitle>
+ <doctitle><![CDATA[<h1>vert.x Java API</h1>]]></doctitle>
</javadoc>
</target>
@@ -162,12 +162,12 @@
<mkdir dir="${dist-build}/bin"/>
<exec executable="cp">
- <arg value="src/scripts/nodex-java"/>
- <arg value="${dist-build}/bin/nodex-java"/>
+ <arg value="src/scripts/vertx-java"/>
+ <arg value="${dist-build}/bin/vertx-java"/>
</exec>
<exec executable="cp">
- <arg value="src/scripts/nodex-ruby"/>
- <arg value="${dist-build}/bin/nodex-ruby"/>
+ <arg value="src/scripts/vertx-ruby"/>
+ <arg value="${dist-build}/bin/vertx-ruby"/>
</exec>
<copy todir="${dist-build}/examples">
@@ -184,9 +184,9 @@
</copy>
<!-- Don't create the zip since file permissions are not preserved - use tar.gz instead
- <zip destfile="${target}/node.x-${version-number}.zip" basedir="${dist-build-base}"/> -->
+ <zip destfile="${target}/vert.x-${version-number}.zip" basedir="${dist-build-base}"/> -->
- <tar destfile="${target}/node.x-${version-number}.tar" longfile="gnu">
+ <tar destfile="${target}/vert.x-${version-number}.tar" longfile="gnu">
<tarfileset dir="${dist-build-base}" filemode="755">
<include name="**/bin/**"/>
</tarfileset>
@@ -195,7 +195,7 @@
</tarfileset>
</tar>
- <gzip destfile="${target}/node.x-${version-number}.tar.gz" src="${target}/node.x-${version-number}.tar"/>
+ <gzip destfile="${target}/vert.x-${version-number}.tar.gz" src="${target}/vert.x-${version-number}.tar"/>
</target>
</project>
View
6 docs/dev-manual.txt
@@ -1,17 +1,17 @@
-Node.x developers manual
+vert.x developers manual
------------------------
Topics:
-1) Intro to node.x - what is it?
+1) Intro to vert.x - what is it?
2) Creating TCP servers and clients
3) Creating HTTP servers and clients
4) Websockets
-5) The node.x concurrency model
+5) The vert.x concurrency model
6) Sharing data between event loops
View
6 mgmt/Planning.txt
@@ -1,4 +1,4 @@
-Node.x planning/ideas/TODO
+vert.x planning/ideas/TODO
==========================
Modules
@@ -14,7 +14,7 @@ STDIO - done
Buffer - done
Composition - partially done
Shared data - done
-Node (including Timers, registering handlers) - done
+Vertx (including Timers, registering handlers) - done
FileSystem - done
ParseTools - done
Http - done
@@ -76,7 +76,7 @@ TODO
12) Netty needs to implement event loop
13) HTTP server side 100-continue handling
15) Netty should build timers into event loop
-19) Make Java nodex methods static ??
+19) Make Java vertx methods static ??
20) Package manager and deployment
21) HTTPClient should pool HTTP connections in same way as redis client, i.e. have HTTPPool and HTTPConnection class -
otherwise can't do proper pipelining since can't guarantee same connection.
View
42 src/examples/java/README
@@ -1,4 +1,4 @@
-Node.x Java Examples
+vert.x Java Examples
====================
Prerequisites:
@@ -13,9 +13,9 @@ Prerequisites:
2. Run an example by invoking:
-nodex-java -cp classes <example class name>
+vertx-java -cp classes <example class name>
-where <example class name> is, for example, org.nodex.java.examples.echo.EchoServer
+where <example class name> is, for example, org.vertx.java.examples.echo.EchoServer
There now follows a description of all the available examples:
@@ -26,13 +26,13 @@ A simple echo server which echos back any sent to it
To run the server:
-nodex-java -cp classes org.nodex.java.examples.echo.EchoServer
+vertx-java -cp classes org.vertx.java.examples.echo.EchoServer
Then either telnet localhost 8080 and notice how text entered via telnet is echoed back
Instead of telnet you can also run a simple echo client:
-nodex-java -cp classes org.nodex.java.examples.echo.EchoClient
+vertx-java -cp classes org.vertx.java.examples.echo.EchoClient
Fanout Server
=============
@@ -41,7 +41,7 @@ Fans out all data received on any one connection to all other connections.
To run the server:
-nodex-java -cp classes org.nodex.java.examples.fanout.FanoutServer
+vertx-java -cp classes org.vertx.java.examples.fanout.FanoutServer
Then telnet localhost 8080 from different consoles. Note how data entered in telnet is echoed to all connected connections
@@ -53,13 +53,13 @@ request and displays the response it receives.
To run the server:
-nodex-java -cp classes org.nodex.java.examples.http.ServerExample
+vertx-java -cp classes org.vertx.java.examples.http.ServerExample
Then point your browser at http://localhost:8080
Alternatively, you can also run the HTTP client:
-nodex-java -cp classes org.nodex.java.examples.http.ClientExample
+vertx-java -cp classes org.vertx.java.examples.http.ClientExample
HTTPS
=====
@@ -68,13 +68,13 @@ Like the HTTP example, but using HTTPS
To run the server:
-nodex-java -cp classes org.nodex.java.examples.https.ServerExample
+vertx-java -cp classes org.vertx.java.examples.https.ServerExample
Then point your browser at http://localhost:4443
Alternatively, you can also run the HTTPS client:
-nodex-java -cp classes org.nodex.java.examples.https.ClientExample
+vertx-java -cp classes org.vertx.java.examples.https.ClientExample
You'll get a warning from your browser since the server certificate the server is using is not known to it, that's
normal.
@@ -97,15 +97,15 @@ To run, open three consoles.
In console 1, run the http server:
-nodex-java -cp classes org.nodex.java.examples.proxy.HttpServer
+vertx-java -cp classes org.vertx.java.examples.proxy.HttpServer
In console 2, run the proxy server:
-nodex-java -cp classes org.nodex.java.examples.proxy.ProxyServer
+vertx-java -cp classes org.vertx.java.examples.proxy.ProxyServer
In console 3, run the http client:
-nodex-java -cp classes org.nodex.java.examples.proxy.HttpClient
+vertx-java -cp classes org.vertx.java.examples.proxy.HttpClient
PubSub
======
@@ -138,7 +138,7 @@ Where:
To run the server:
-nodex-java -cp classes org.nodex.java.examples.pubsub.PubSubServer
+vertx-java -cp classes org.vertx.java.examples.pubsub.PubSubServer
Then open some more consoles and telnet localhost 8080, and experiment with the protocol.
@@ -152,7 +152,7 @@ The example contains three static pages: index.html, page1.html and page2.html w
To run the server:
-nodex-java -cp classes org.nodex.java.examples.sendfile.SendFileExample
+vertx-java -cp classes org.vertx.java.examples.sendfile.SendFileExample
Then point your browser at http://localhost:8080 and click around
@@ -163,11 +163,11 @@ This is like the echo example, but this time using SSL.
To run the server:
-nodex-java -cp classes org.nodex.java.examples.ssl.SSLServer
+vertx-java -cp classes org.vertx.java.examples.ssl.SSLServer
To run the client:
-nodex-java -cp classes org.nodex.java.examples.ssl.SSLClient
+vertx-java -cp classes org.vertx.java.examples.ssl.SSLClient
Upload
======
@@ -177,11 +177,11 @@ HTTP request and streams the data to a file on disk.
To run the server:
-nodex-java -cp classes org.nodex.java.examples.upload.UploadServer
+vertx-java -cp classes org.vertx.java.examples.upload.UploadServer
To run the client:
-nodex-java -cp classes org.nodex.java.examples.upload.UploadClient
+vertx-java -cp classes org.vertx.java.examples.upload.UploadClient
Websockets
==========
@@ -191,7 +191,7 @@ to create a websocket to a server, and send and receive data from it.
To run the server:
-nodex-java -cp classes org.nodex.java.examples.websockets.WebsocketsExample
+vertx-java -cp classes org.vertx.java.examples.websockets.WebsocketsExample
Then point your browser at: http://localhost:8080
@@ -205,7 +205,7 @@ To run this example you must have a Redis server running on localhost.
The, to run the example:
-nodex-java -cp classes org.nodex.java.examples.redis.RedisExample
+vertx-java -cp classes org.vertx.java.examples.redis.RedisExample
Then point your browser at: http://localhost:8080 and hit refresh a few times
View
4 src/examples/java/build.xml
@@ -14,10 +14,10 @@
~ limitations under the License.
-->
-<project name="node.x.java.examples" default="compile" basedir=".">
+<project name="vert.x.java.examples" default="compile" basedir=".">
<description>
- Build script for node.x Java examples
+ Build script for vert.x Java examples
</description>
<property name="src" value="."/>
View
14 .../nodex/java/examples/echo/EchoClient.java → .../vertx/java/examples/echo/EchoClient.java
@@ -14,15 +14,15 @@
* limitations under the License.
*/
-package org.nodex.java.examples.echo;
+package org.vertx.java.examples.echo;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetClient;
-import org.nodex.java.core.net.NetSocket;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetClient;
+import org.vertx.java.core.net.NetSocket;
-public class EchoClient extends NodexMain {
+public class EchoClient extends VertxMain {
public static void main(String[] args) throws Exception {
new EchoClient().run();
View
14 .../nodex/java/examples/echo/EchoServer.java → .../vertx/java/examples/echo/EchoServer.java
@@ -14,15 +14,15 @@
* limitations under the License.
*/
-package org.nodex.java.examples.echo;
+package org.vertx.java.examples.echo;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetServer;
-import org.nodex.java.core.net.NetSocket;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetServer;
+import org.vertx.java.core.net.NetSocket;
-public class EchoServer extends NodexMain {
+public class EchoServer extends VertxMain {
public static void main(String[] args) throws Exception {
new EchoServer().run();
View
20 .../nodex/java/examples/echo/PerfClient.java → .../vertx/java/examples/echo/PerfClient.java
@@ -14,17 +14,17 @@
* limitations under the License.
*/
-package org.nodex.java.examples.echo;
+package org.vertx.java.examples.echo;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.Nodex;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.SimpleHandler;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetClient;
-import org.nodex.java.core.net.NetSocket;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.SimpleHandler;
+import org.vertx.java.core.Vertx;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetClient;
+import org.vertx.java.core.net.NetSocket;
-public class PerfClient extends NodexMain {
+public class PerfClient extends VertxMain {
public static void main(String[] args) throws Exception {
new EchoClient().run();
@@ -71,7 +71,7 @@ public void handle() {
}
};
if (!socket.writeQueueFull()) {
- Nodex.instance.nextTick(handler);
+ Vertx.instance.nextTick(handler);
} else {
socket.drainHandler(handler);
}
View
22 ...ex/java/examples/fanout/FanoutServer.java → ...tx/java/examples/fanout/FanoutServer.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.nodex.java.examples.fanout;
+package org.vertx.java.examples.fanout;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.Nodex;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.SimpleHandler;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetServer;
-import org.nodex.java.core.net.NetSocket;
-import org.nodex.java.core.shared.SharedData;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.SimpleHandler;
+import org.vertx.java.core.Vertx;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetServer;
+import org.vertx.java.core.net.NetSocket;
+import org.vertx.java.core.shared.SharedData;
import java.util.Set;
-public class FanoutServer extends NodexMain {
+public class FanoutServer extends VertxMain {
public static void main(String[] args) throws Exception {
new FanoutServer().run();
@@ -44,7 +44,7 @@ public void handle(final NetSocket socket) {
socket.dataHandler(new Handler<Buffer>() {
public void handle(Buffer buffer) {
for (Long actorID : connections) {
- Nodex.instance.sendToHandler(actorID, buffer);
+ Vertx.instance.sendToHandler(actorID, buffer);
}
}
});
View
14 ...dex/java/examples/http/ClientExample.java → ...rtx/java/examples/http/ClientExample.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.nodex.java.examples.http;
+package org.vertx.java.examples.http;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpClient;
-import org.nodex.java.core.http.HttpClientResponse;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpClient;
+import org.vertx.java.core.http.HttpClientResponse;
/**
* User: tim
* Date: 12/08/11
* Time: 11:44
*/
-public class ClientExample extends NodexMain {
+public class ClientExample extends VertxMain {
public static void main(String[] args) throws Exception {
new ClientExample().run();
View
14 ...dex/java/examples/http/ServerExample.java → ...rtx/java/examples/http/ServerExample.java
@@ -14,14 +14,14 @@
* limitations under the License.
*/
-package org.nodex.java.examples.http;
+package org.vertx.java.examples.http;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
-public class ServerExample extends NodexMain {
+public class ServerExample extends VertxMain {
public static void main(String[] args) throws Exception {
new ServerExample().run();
@@ -38,7 +38,7 @@ public void handle(HttpServerRequest req) {
System.out.println(key + ":" + req.getHeader(key));
}
req.response.putHeader("Content-Type", "text/html; charset=UTF-8").
- end("<html><body><h1>Hello from node.x!</h1></body></html>");
+ end("<html><body><h1>Hello from vert.x!</h1></body></html>");
}
}).listen(8080);
}
View
14 ...ex/java/examples/https/ClientExample.java → ...tx/java/examples/https/ClientExample.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.nodex.java.examples.https;
+package org.vertx.java.examples.https;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpClient;
-import org.nodex.java.core.http.HttpClientResponse;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpClient;
+import org.vertx.java.core.http.HttpClientResponse;
/**
* User: tim
* Date: 12/08/11
* Time: 11:44
*/
-public class ClientExample extends NodexMain {
+public class ClientExample extends VertxMain {
public static void main(String[] args) throws Exception {
new ClientExample().run();
View
14 ...ex/java/examples/https/ServerExample.java → ...tx/java/examples/https/ServerExample.java
@@ -14,14 +14,14 @@
* limitations under the License.
*/
-package org.nodex.java.examples.https;
+package org.vertx.java.examples.https;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
-public class ServerExample extends NodexMain {
+public class ServerExample extends VertxMain {
public static void main(String[] args) throws Exception {
new ServerExample().run();
@@ -39,7 +39,7 @@ public void handle(HttpServerRequest req) {
}
req.response.putHeader("Content-Type", "text/html; charset=UTF-8");
req.response.setChunked(true);
- req.response.write("<html><body><h1>Hello from node.x!</h1></body></html>", "UTF-8").end();
+ req.response.write("<html><body><h1>Hello from vert.x!</h1></body></html>", "UTF-8").end();
}
}).setSSL(true).setKeyStorePath("server-keystore.jks").setKeyStorePassword("wibble").listen(4443);
}
View
4 ...java/examples/old/amqp/ClientExample.java → ...java/examples/old/amqp/ClientExample.java
@@ -14,14 +14,14 @@
* limitations under the License.
*/
-package org.nodex.java.examples.old.amqp;
+package org.vertx.java.examples.old.amqp;
public class ClientExample {
//
// private static String QUEUE_NAME = "my-queue";
//
// public static void main(String[] args) throws IOException {
-// org.nodex.java.addons.old.amqp.AmqpClient.createClient().connect(new AmqpConnectHandler() {
+// org.vertx.java.addons.old.amqp.AmqpClient.createClient().connect(new AmqpConnectHandler() {
// public void onConnect(AmqpConnection conn) {
// conn.createChannel(new ChannelHandler() {
// public void onCreate(final Channel channel) {
View
2 ...s/old/composition/CompositionExample.java → ...s/old/composition/CompositionExample.java
@@ -14,7 +14,7 @@
* limitations under the License.
*/
-package org.nodex.java.examples.old.composition;
+package org.vertx.java.examples.old.composition;
public class CompositionExample {
public static void main(String[] args) throws Exception {
View
12 ...ava/examples/old/stomp/ClientExample.java → ...ava/examples/old/stomp/ClientExample.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.nodex.java.examples.old.stomp;
+package org.vertx.java.examples.old.stomp;
-import org.nodex.java.addons.old.stomp.StompConnectHandler;
-import org.nodex.java.addons.old.stomp.StompConnection;
-import org.nodex.java.addons.old.stomp.StompMsgCallback;
-import org.nodex.java.core.buffer.Buffer;
+import org.vertx.java.addons.old.stomp.StompConnectHandler;
+import org.vertx.java.addons.old.stomp.StompConnection;
+import org.vertx.java.addons.old.stomp.StompMsgCallback;
+import org.vertx.java.core.buffer.Buffer;
import java.util.Map;
public class ClientExample {
public static void main(String[] args) throws Exception {
- org.nodex.java.addons.old.stomp.StompClient.connect(8181, new StompConnectHandler() {
+ org.vertx.java.addons.old.stomp.StompClient.connect(8181, new StompConnectHandler() {
public void onConnect(final StompConnection conn) {
// Subscribe to a topic
View
6 ...ava/examples/old/stomp/ServerExample.java → ...ava/examples/old/stomp/ServerExample.java
@@ -14,10 +14,10 @@
* limitations under the License.
*/
-package org.nodex.java.examples.old.stomp;
+package org.vertx.java.examples.old.stomp;
-import org.nodex.java.addons.old.stomp.StompServer;
-import org.nodex.java.core.net.NetServer;
+import org.vertx.java.addons.old.stomp.StompServer;
+import org.vertx.java.core.net.NetServer;
public class ServerExample {
public static void main(String[] args) throws Exception {
View
12 ...ex/java/examples/old/stomp/StompPerf.java → ...tx/java/examples/old/stomp/StompPerf.java
@@ -14,13 +14,13 @@
* limitations under the License.
*/
-package org.nodex.java.examples.old.stomp;
+package org.vertx.java.examples.old.stomp;
-import org.nodex.java.addons.old.stomp.StompClient;
-import org.nodex.java.addons.old.stomp.StompConnectHandler;
-import org.nodex.java.addons.old.stomp.StompConnection;
-import org.nodex.java.addons.old.stomp.StompMsgCallback;
-import org.nodex.java.core.buffer.Buffer;
+import org.vertx.java.addons.old.stomp.StompClient;
+import org.vertx.java.addons.old.stomp.StompConnectHandler;
+import org.vertx.java.addons.old.stomp.StompConnection;
+import org.vertx.java.addons.old.stomp.StompMsgCallback;
+import org.vertx.java.core.buffer.Buffer;
import java.util.Map;
View
16 ...nodex/java/examples/proxy/HttpClient.java → ...vertx/java/examples/proxy/HttpClient.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.nodex.java.examples.proxy;
+package org.vertx.java.examples.proxy;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpClientRequest;
-import org.nodex.java.core.http.HttpClientResponse;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpClientRequest;
+import org.vertx.java.core.http.HttpClientResponse;
/**
* User: tim
* Date: 12/08/11
* Time: 11:44
*/
-public class HttpClient extends NodexMain {
+public class HttpClient extends VertxMain {
public static void main(String[] args) throws Exception {
new HttpClient().run();
@@ -36,7 +36,7 @@ public static void main(String[] args) throws Exception {
}
public void go() throws Exception {
- HttpClientRequest req = new org.nodex.java.core.http.HttpClient().setPort(8080).setHost("localhost").put("/some-url", new Handler<HttpClientResponse>() {
+ HttpClientRequest req = new org.vertx.java.core.http.HttpClient().setPort(8080).setHost("localhost").put("/some-url", new Handler<HttpClientResponse>() {
public void handle(HttpClientResponse response) {
response.dataHandler(new Handler<Buffer>() {
public void handle(Buffer data) {
View
16 ...nodex/java/examples/proxy/HttpServer.java → ...vertx/java/examples/proxy/HttpServer.java
@@ -14,15 +14,15 @@
* limitations under the License.
*/
-package org.nodex.java.examples.proxy;
+package org.vertx.java.examples.proxy;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.SimpleHandler;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpServerRequest;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.SimpleHandler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpServerRequest;
-public class HttpServer extends NodexMain {
+public class HttpServer extends VertxMain {
public static void main(String[] args) throws Exception {
new HttpServer().run();
@@ -31,7 +31,7 @@ public static void main(String[] args) throws Exception {
}
public void go() throws Exception {
- new org.nodex.java.core.http.HttpServer().requestHandler(new Handler<HttpServerRequest>() {
+ new org.vertx.java.core.http.HttpServer().requestHandler(new Handler<HttpServerRequest>() {
public void handle(final HttpServerRequest req) {
System.out.println("Got request: " + req.uri);
System.out.println("Headers are: ");
View
22 ...odex/java/examples/proxy/ProxyServer.java → ...ertx/java/examples/proxy/ProxyServer.java
@@ -14,19 +14,19 @@
* limitations under the License.
*/
-package org.nodex.java.examples.proxy;
+package org.vertx.java.examples.proxy;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.SimpleHandler;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpClient;
-import org.nodex.java.core.http.HttpClientRequest;
-import org.nodex.java.core.http.HttpClientResponse;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.SimpleHandler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpClient;
+import org.vertx.java.core.http.HttpClientRequest;
+import org.vertx.java.core.http.HttpClientResponse;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
-public class ProxyServer extends NodexMain {
+public class ProxyServer extends VertxMain {
public static void main(String[] args) throws Exception {
new ProxyServer().run();
View
22 ...ex/java/examples/pubsub/PubSubServer.java → ...tx/java/examples/pubsub/PubSubServer.java
@@ -14,20 +14,20 @@
* limitations under the License.
*/
-package org.nodex.java.examples.pubsub;
+package org.vertx.java.examples.pubsub;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.Nodex;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetServer;
-import org.nodex.java.core.net.NetSocket;
-import org.nodex.java.core.parsetools.RecordParser;
-import org.nodex.java.core.shared.SharedData;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.Vertx;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetServer;
+import org.vertx.java.core.net.NetSocket;
+import org.vertx.java.core.parsetools.RecordParser;
+import org.vertx.java.core.shared.SharedData;
import java.util.Set;
-public class PubSubServer extends NodexMain {
+public class PubSubServer extends VertxMain {
public static void main(String[] args) throws Exception {
new PubSubServer().run();
@@ -51,7 +51,7 @@ public void handle(Buffer frame) {
} else if (line.startsWith("publish")) {
Set<Long> actorIDs = SharedData.getSet(parts[1]);
for (Long actorID : actorIDs) {
- Nodex.instance.sendToHandler(actorID, Buffer.create(parts[2]));
+ Vertx.instance.sendToHandler(actorID, Buffer.create(parts[2]));
}
}
}
View
22 ...dex/java/examples/redis/RedisExample.java → ...rtx/java/examples/redis/RedisExample.java
@@ -14,19 +14,19 @@
* limitations under the License.
*/
-package org.nodex.java.examples.redis;
+package org.vertx.java.examples.redis;
-import org.nodex.java.addons.redis.RedisConnection;
-import org.nodex.java.addons.redis.RedisPool;
-import org.nodex.java.core.CompletionHandler;
-import org.nodex.java.core.Future;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
+import org.vertx.java.addons.redis.RedisConnection;
+import org.vertx.java.addons.redis.RedisPool;
+import org.vertx.java.core.CompletionHandler;
+import org.vertx.java.core.Future;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
-public class RedisExample extends NodexMain {
+public class RedisExample extends VertxMain {
public static void main(String[] args) throws Exception {
new RedisExample().run();
View
12 ...va/examples/sendfile/SendFileExample.java → ...va/examples/sendfile/SendFileExample.java
@@ -14,19 +14,19 @@
* limitations under the License.
*/
-package org.nodex.java.examples.sendfile;
+package org.vertx.java.examples.sendfile;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
/**
* User: tim
* Date: 12/08/11
* Time: 09:04
*/
-public class SendFileExample extends NodexMain {
+public class SendFileExample extends VertxMain {
public static void main(String[] args) throws Exception {
new SendFileExample().run();
View
14 ...rg/nodex/java/examples/ssl/SSLClient.java → ...rg/vertx/java/examples/ssl/SSLClient.java
@@ -14,15 +14,15 @@
* limitations under the License.
*/
-package org.nodex.java.examples.ssl;
+package org.vertx.java.examples.ssl;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetClient;
-import org.nodex.java.core.net.NetSocket;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetClient;
+import org.vertx.java.core.net.NetSocket;
-public class SSLClient extends NodexMain {
+public class SSLClient extends VertxMain {
public static void main(String[] args) throws Exception {
new SSLClient().run();
View
14 ...rg/nodex/java/examples/ssl/SSLServer.java → ...rg/vertx/java/examples/ssl/SSLServer.java
@@ -14,15 +14,15 @@
* limitations under the License.
*/
-package org.nodex.java.examples.ssl;
+package org.vertx.java.examples.ssl;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.net.NetServer;
-import org.nodex.java.core.net.NetSocket;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.net.NetServer;
+import org.vertx.java.core.net.NetSocket;
-public class SSLServer extends NodexMain {
+public class SSLServer extends VertxMain {
public static void main(String[] args) throws Exception {
new SSLServer().run();
View
26 ...ex/java/examples/upload/UploadClient.java → ...tx/java/examples/upload/UploadClient.java
@@ -14,18 +14,18 @@
* limitations under the License.
*/
-package org.nodex.java.examples.upload;
+package org.vertx.java.examples.upload;
-import org.nodex.java.core.CompletionHandler;
-import org.nodex.java.core.Future;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.SimpleHandler;
-import org.nodex.java.core.file.AsyncFile;
-import org.nodex.java.core.file.FileSystem;
-import org.nodex.java.core.http.HttpClientRequest;
-import org.nodex.java.core.http.HttpClientResponse;
-import org.nodex.java.core.streams.Pump;
+import org.vertx.java.core.CompletionHandler;
+import org.vertx.java.core.Future;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.SimpleHandler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.file.AsyncFile;
+import org.vertx.java.core.file.FileSystem;
+import org.vertx.java.core.http.HttpClientRequest;
+import org.vertx.java.core.http.HttpClientResponse;
+import org.vertx.java.core.streams.Pump;
import java.nio.file.Files;
import java.nio.file.Paths;
@@ -35,7 +35,7 @@
* Date: 25/08/11
* Time: 11:30
*/
-public class UploadClient extends NodexMain {
+public class UploadClient extends VertxMain {
public static void main(String[] args) throws Exception {
new UploadClient().run();
@@ -45,7 +45,7 @@ public static void main(String[] args) throws Exception {
public void go() throws Exception {
- final HttpClientRequest req = new org.nodex.java.core.http.HttpClient().setPort(8080).setHost("localhost").put("/some-url", new Handler<HttpClientResponse>() {
+ final HttpClientRequest req = new org.vertx.java.core.http.HttpClient().setPort(8080).setHost("localhost").put("/some-url", new Handler<HttpClientResponse>() {
public void handle(HttpClientResponse response) {
System.out.println("File uploaded " + response.statusCode);
}
View
24 ...ex/java/examples/upload/UploadServer.java → ...tx/java/examples/upload/UploadServer.java
@@ -14,22 +14,22 @@
* limitations under the License.
*/
-package org.nodex.java.examples.upload;
+package org.vertx.java.examples.upload;
-import org.nodex.java.core.CompletionHandler;
-import org.nodex.java.core.Future;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.SimpleHandler;
-import org.nodex.java.core.file.AsyncFile;
-import org.nodex.java.core.file.FileSystem;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
-import org.nodex.java.core.streams.Pump;
+import org.vertx.java.core.CompletionHandler;
+import org.vertx.java.core.Future;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.SimpleHandler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.file.AsyncFile;
+import org.vertx.java.core.file.FileSystem;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
+import org.vertx.java.core.streams.Pump;
import java.util.UUID;
-public class UploadServer extends NodexMain {
+public class UploadServer extends VertxMain {
public static void main(String[] args) throws Exception {
new UploadServer().run();
View
16 ...xamples/websockets/WebsocketsExample.java → ...xamples/websockets/WebsocketsExample.java
@@ -14,21 +14,21 @@
* limitations under the License.
*/
-package org.nodex.java.examples.websockets;
+package org.vertx.java.examples.websockets;
-import org.nodex.java.core.Handler;
-import org.nodex.java.core.NodexMain;
-import org.nodex.java.core.buffer.Buffer;
-import org.nodex.java.core.http.HttpServer;
-import org.nodex.java.core.http.HttpServerRequest;
-import org.nodex.java.core.http.Websocket;
+import org.vertx.java.core.Handler;
+import org.vertx.java.core.VertxMain;
+import org.vertx.java.core.buffer.Buffer;
+import org.vertx.java.core.http.HttpServer;
+import org.vertx.java.core.http.HttpServerRequest;
+import org.vertx.java.core.http.Websocket;
/**
* User: tim
* Date: 12/08/11
* Time: 08:05
*/
-public class WebsocketsExample extends NodexMain {
+public class WebsocketsExample extends VertxMain {
public static void main(String[] args) throws Exception {
new WebsocketsExample().run();
View
4 src/examples/java/sendfile/index.html
@@ -18,10 +18,10 @@
"http://www.w3.org/TR/html4/loose.dtd">
<html>
<head>
- <title>Node.x static web server</title>
+ <title>vert.x static web server</title>
</head>
<body>
-<h1>This is the node.x static web server. Click on some links below</h1>
+<h1>This is the vert.x static web server. Click on some links below</h1>
<br>
<br>
View
2 src/examples/java/websockets/ws.html
@@ -23,6 +23,8 @@
<html>
<head><title>Web Socket Test</title></head>
<body>
+<p>This will currently only work in Google Chrome 6 <= version < 14</p>
+<p>Support for hybi-10 version on its way soon!</p>
<script type="text/javascript">
var socket;
if (window.WebSocket) {
View
40 src/examples/ruby/README
@@ -1,4 +1,4 @@
-Node.x Ruby Examples
+vert.x Ruby Examples
====================
Prerequisites:
@@ -11,7 +11,7 @@ Prerequisites:
Run an example by invoking:
-nodex-ruby <example ruby script>
+vertx-ruby <example ruby script>
where <example ruby script> is, for example, echo/echo_server.rb
@@ -24,13 +24,13 @@ A simple echo server which echos back any sent to it
To run the server:
-nodex-ruby echo/echo_server.rb
+vertx-ruby echo/echo_server.rb
Then either telnet localhost 8080 and notice how text entered via telnet is echoed back
Instead of telnet you can also run a simple echo client:
-nodex-ruby echo/echo_client.rb
+vertx-ruby echo/echo_client.rb
Fanout Server
=============
@@ -39,7 +39,7 @@ Fans out all data received on any one connection to all other connections.
To run the server:
-nodex-ruby fanout/fanout_server.rb
+vertx-ruby fanout/fanout_server.rb
Then telnet localhost 8080 from different consoles. Note how data entered in telnet is echoed to all connected connections
@@ -51,13 +51,13 @@ request and displays the response it receives.
To run the server:
-nodex-ruby http/http_server.rb
+vertx-ruby http/http_server.rb
Then point your browser at http://localhost:8080
Alternatively, you can also run the HTTP client:
-nodex-ruby http/http_client.rb
+vertx-ruby http/http_client.rb
HTTPS
=====
@@ -66,13 +66,13 @@ Like the HTTP example, but using HTTPS
To run the server:
-nodex-ruby https/https_server.rb
+vertx-ruby https/https_server.rb
Then point your browser at http://localhost:4443
Alternatively, you can also run the HTTPS client:
-nodex-ruby https/https_client.rb
+vertx-ruby https/https_client.rb
You'll get a warning from your browser since the server certificate the server is using is not known to it, that's
normal.
@@ -95,15 +95,15 @@ To run, open three consoles.
In console 1, run the http server:
-nodex-ruby proxy/http_server.rb
+vertx-ruby proxy/http_server.rb
In console 2, run the proxy server:
-nodex-ruby proxy/proxy_server.rb
+vertx-ruby proxy/proxy_server.rb
In console 3, run the http client:
-nodex-ruby proxy/http_client.rb
+vertx-ruby proxy/http_client.rb
PubSub
======
@@ -136,7 +136,7 @@ Where:
To run the server:
-nodex-ruby pubsub/pubsub_server.rb
+vertx-ruby pubsub/pubsub_server.rb
Then open some more consoles and telnet localhost 8080, and experiment with the protocol.
@@ -150,7 +150,7 @@ The example contains three static pages: index.html, page1.html and page2.html w
To run the server:
-nodex-ruby sendfile/sendfile.rb
+vertx-ruby sendfile/sendfile.rb
Then point your browser at http://localhost:8080 and click around
@@ -161,11 +161,11 @@ This is like the echo example, but this time using SSL.
To run the server:
-nodex-ruby ssl/ssl_server.rb
+vertx-ruby ssl/ssl_server.rb
To run the client:
-nodex-ruby ssl/ssl_client.rb
+vertx-ruby ssl/ssl_client.rb
Upload
======
@@ -175,11 +175,11 @@ HTTP request and streams the data to a file on disk.
To run the server:
-nodex-ruby upload/upload_server.rb
+vertx-ruby upload/upload_server.rb
To run the client:
-nodex-ruby upload/upload_client.rb
+vertx-ruby upload/upload_client.rb
Websockets
==========
@@ -189,7 +189,7 @@ to create a websocket to a server, and send and receive data from it.
To run the server:
-nodex-ruby websockets/websockets.rb
+vertx-ruby websockets/websockets.rb
Then point your browser at: http://localhost:8080
@@ -203,7 +203,7 @@ To run this example you must have a Redis server running on localhost.
The, to run the example:
-nodex-ruby redis/RedisExample
+vertx-ruby redis/RedisExample
Then point your browser at: http://localhost:8080 and hit refresh a few times
View
6 src/examples/ruby/echo/echo_client.rb
@@ -12,10 +12,10 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
NetClient.new.connect(8080, "localhost") do |socket|
socket.data_handler { |data| puts "Echo client received #{data.to_s}" }
(1..10).each do |i|
View
6 src/examples/ruby/echo/echo_server.rb
@@ -12,10 +12,10 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
NetServer.new.connect_handler { |socket| socket.data_handler { |data| socket.write_buffer(data) } }.listen(8080)
end
puts "hit enter to exit"
View
8 src/examples/ruby/fanout/fanout_server.rb
@@ -12,15 +12,15 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
conns = SharedData::get_set("conns")
NetServer.new.connect_handler do |socket|
conns.add(socket.write_handler_id)
socket.data_handler do |data|
- conns.each { |actor_id| Nodex::send_to_handler(actor_id, data) }
+ conns.each { |actor_id| Vertx::send_to_handler(actor_id, data) }
end
socket.closed_handler { conns.delete(socket.write_handler_id) }
end.listen(8080)
View
6 src/examples/ruby/http/http_client.rb
@@ -12,10 +12,10 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
client = HttpClient.new
client.port = 8080
client.host = "localhost"
View
8 src/examples/ruby/http/http_server.rb
@@ -12,12 +12,12 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
HttpServer.new.request_handler do |req|
- req.response.write_str_and_end("<html><body><h1>Hello from Node.x!</h1></body></html>")
+ req.response.write_str_and_end("<html><body><h1>Hello from vert.x!</h1></body></html>")
end.listen(8080)
end
View
6 src/examples/ruby/https/https_client.rb
@@ -12,10 +12,10 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
client = HttpClient.new
client.ssl = true
client.port = 4443
View
8 src/examples/ruby/https/https_server.rb
@@ -12,18 +12,18 @@
# See the License for the specific language governing permissions and
# limitations under the License.
-require "nodex"
-include Nodex
+require "vertx"
+include Vertx
-Nodex::go do
+Vertx::go do
server = HttpServer.new
server.ssl = true
server.key_store_path = "server-keystore.jks"
server.key_store_password = "wibble"
server.request_handler do |req|
req.response.chunked = true
- req.response.write_str("<html><body><h1>Hello from Node.x over HTTPS!</h1></body></html>", "UTF-8").end
+ req.response.write_str("<html><body><h1>Hello from vert.x over HTTPS!</h1></body></html>", "UTF-8").end
end.listen(4443)