Skip to content

Instantly share code, notes, and snippets.

set :application, "myapp"
set :repository, "[email protected]:myapp.git"
set :scm, :git
# Or: `accurev`, `bzr`, `cvs`, `darcs`, `git`, `mercurial`, `perforce`, `subversion` or `none`
set :user, "ubuntu"
set :use_sudo, false
set :location, "MY_EC2_PUBLIC_DNS"
default_run_options[:pty] = true
ssh_options[:keys_only] = true
for(i in docs) {
var doc = docs[i];
if(doc != null) {
var msg = doc['project_id'] + '. ' + doc['created_at'] + '. ' + doc['message'];
sys.puts("I'll send " + msg);
redis_client.smembers("conn:project:" + doc['project_id'], function(err, client_ids) {
client_ids.forEach(function(client_id, i) {
client = socketio.clients[client_id];
if(typeof client != 'undefined') {
client.send(msg);
docs.forEach(function(doc) {
if(doc != null) {
var msg = doc['project_id'] + '. ' + doc['created_at'] + '. ' + doc['message'];
redis_client.smembers("conn:project:" + doc['project_id'], function(err, client_ids) {
client_ids.forEach(function(client_id, i) {
client = socketio.clients[client_id];
if(typeof client != 'undefined') {
client.send(msg);
}
});
User.find_all_by_name("bob").each do |u|
u.update_something()
u.save()
end
➜ snowflake git:(master) sbt update
Getting org.scala-tools.sbt sbt_2.8.1 0.7.4 ...
:: problems summary ::
:::: WARNINGS
module not found: org.scala-tools.sbt#sbt_2.8.1;0.7.4
==== local: tried
/Users/elben/.ivy2/local/org.scala-tools.sbt/sbt_2.8.1/0.7.4/ivys/ivy.xml
➜ snowflake git:(master) ✗ sbt update
[info] Standard project rules 0.11.6 loaded (2011-03-21).
[info] Building project snowflake 1.0 against Scala 2.8.1
[info] using SnowflakeProject with sbt 0.7.4 and Scala 2.7.7
[info]
[info] == update ==
[warn] Host download.java.net not found. url=http://download.java.net/maven/2/com/twitter/util-core/1.8.1/util-core-1.8.1-sources.jar
[info] You probably access the destination server through a proxy server that is not well configured.
[warn] Host download.java.net not found. url=http://download.java.net/maven/2/com/twitter/util-core/1.8.1/util-core-1.8.1-javadoc.jar
[info] You probably access the destination server through a proxy server that is not well configured.
WARN 13:55:38,450 Error reading a field from document : SolrDocument[{id=134336550594031616, order=134336553672511488}]
java.lang.NullPointerException
at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:52)
at java.nio.ByteBuffer.wrap(ByteBuffer.java:350)
at org.apache.solr.schema.BinaryField.toObject(BinaryField.java:60)
at org.apache.solr.schema.BinaryField.toObject(BinaryField.java:31)
at org.apache.solr.response.BinaryResponseWriter$Resolver.getDoc(BinaryResponseWriter.java:148)
at org.apache.solr.response.BinaryResponseWriter$Resolver.writeDocList(BinaryResponseWriter.java:122)
at org.apache.solr.response.BinaryResponseWriter$Resolver.resolve(BinaryResponseWriter.java:86)
at org.apache.solr.common.util.JavaBinCodec.writeVal(JavaBinCodec.java:144)
diff --git a/src/lucandra/IndexReader.java b/src/lucandra/IndexReader.java
index e88e789..5596b87 100644
--- a/src/lucandra/IndexReader.java
+++ b/src/lucandra/IndexReader.java
@@ -34,6 +34,7 @@ import com.google.common.collect.MapMaker;
import org.apache.cassandra.db.*;
import org.apache.cassandra.thrift.ColumnParent;
import org.apache.cassandra.utils.ByteBufferUtil;
+import org.apache.cassandra.utils.FBUtilities;
import org.apache.log4j.Logger;
/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/bin/java -agentlib:jdwp=transport=dt_socket,address=127.0.0.1:55404,suspend=y,server=n -Dfile.encoding=UTF-8 -classpath /Applications/IntelliJ IDEA 10 CE.app/lib/idea_rt.jar:/Applications/IntelliJ IDEA 10 CE.app/plugins/junit/lib/junit-rt.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/deploy.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/dt.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/javaws.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/jce.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/jconsole.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/management-agent.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/plugin.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/lib/sa-jdi.jar:/System/Library/Java/JavaVirtualMachines/1.6.0.jdk/Contents/Home/../Cla
import org.specs2._
class HelloWorldSpec extends Specification { def is =
"This is a specification to check the 'Hello world' string" ^
p^
"The 'Hello world' string should" ^
"contain 11 characters" ! e1^
"start with 'Hello'" ! e2^
"end with 'world'" ! e3^