Calling the vert.x event bus with zeromq

by
No comments yet

This is the start of a project bridging zeromq (zeromq.org) and vert.x (vertx.io).

https://github.com/p14n/vert-zeromq 

ZeroMQBridge bridge = new ZeroMQBridge("tcp://*:5558", vertx.eventBus());
bridge.start();

vertx.eventBus().registerHandler("testHandler", new Handler>() {
        @Override
        public void handle(Message message) {
                message.reply(message.body());
        }
});

 Hopefully I'll get the time soon to make it a proper vert-x mod.

Creating an angular directive in Clojurescript

by
No comments yet

This example compiles with :optimizations :advanced.

(ns gameapp)
(def gamemod
"Create a gameapp module within Angular.js"
(.module js/angular "gameapp" (array)))
(.directive gamemod "gameslist"
(fn []
(js-obj
"restrict" "E"
"scope" (js-obj "games" "=")
"template" "<div ng-repeat='game in games'>Game {{game.name}}</div>"
)))
(defn ^:export GameCtrl [$scope]
(aset $scope "mygames" (array
(js-obj "name" "a")
(js-obj "name" "b")
(js-obj "name" "c"))))
(aset GameCtrl "$inject" (array "$scope"))
view raw cljs-w-directive.cljs hosted with ❤ by GitHub
<!doctype html>
<html ng-app="gameapp">
<head>
<script src="angular.min.js"></script>
<script src="cljs-w-directive.js"></script>
</head>
<body>
<h2>Game names</h2>
<div ng-controller="gameapp.GameCtrl">
<gameslist games="mygames"/>
</div>
</body>
</html>
view raw cljs-w-directive.html hosted with ❤ by GitHub

Radiator

by
No comments yet

Our new information radiator. Stories are on the right in todo/qa/done order. On the left is a list of projects and status for build and functional test suite. Yes, I do work with Tom Selleck. He's a great programmer - not the cavalier type you might expect from Magnum.

Akka - Getting immediate notification of remote actor failure

by
No comments yet

Seems odd to me, so this is posted with the caveat that may be a better, more idiomatic way of achieving the same result, but to immediately fail an actor using the ask pattern when there has been some sort of remoting failure:

public class RemoteErrorActor extends UntypedActor {
@SuppressWarnings("rawtypes")
@Override
public void onReceive(Object o) throws Exception {
if (o instanceof RemoteClientWriteFailed) {
RemoteClientWriteFailed fail = (RemoteClientWriteFailed) o;
if (fail.getRequest() instanceof Tuple3) {
Tuple3 t3 = (Tuple3) fail.getRequest();
if (t3._2() instanceof Some) {
Some s = (Some) t3._2();
if (s.get() instanceof PromiseActorRef) {
PromiseActorRef par = (PromiseActorRef) s.get();
par.tell(/*something useful*/, self());
}
}
}
}
}
}
system.eventStream().subscribe(system.actorOf(new Props(RemoteErrorActor.class)),
RemoteClientWriteFailed.class);
view raw gistfile1.txt hosted with ❤ by GitHub

Spray with embedded Jetty

by
1 Comment

The Spray-template jetty example comes with a web.xml configuration. If embedded is more your style, this is the way to go (Jetty 8.1.7):

package com.example
import spray.servlet.Servlet30ConnectorServlet
import spray.servlet.Initializer
import org.eclipse.jetty.server.Server
import org.eclipse.jetty.server.bio.SocketConnector
import org.eclipse.jetty.webapp.WebAppContext
import org.eclipse.jetty.servlet.ServletContextHandler
object JettyServer {
def main(args : Array[String]) : Unit = {
start()
}
def start() {
try {
val server = new Server()
val connector = new SocketConnector();
connector.setPort(8080);
val context = new ServletContextHandler(ServletContextHandler.SESSIONS);
context.setContextPath("/");
server.setHandler(context);
context.addEventListener(new Initializer());
val servletHolder = context.addServlet(classOf[Servlet30ConnectorServlet].getName(), "/*");
server.setConnectors(Array(connector));
server.start();
} catch {
case e:Throwable => e.printStackTrace();
}
}
}
view raw gistfile1.scala hosted with ❤ by GitHub