From 0ad56af5a511aaeecd1b10dbb8c751565d6c6fb4 Mon Sep 17 00:00:00 2001 From: Björn Geiger Date: Mon, 18 Jul 2011 17:15:14 +0200 Subject: minor --- gearman/java/.classpath | 8 ++++ gearman/java/src/ping/afslkdfj.java | 79 ------------------------------------- 2 files changed, 8 insertions(+), 79 deletions(-) create mode 100644 gearman/java/.classpath delete mode 100755 gearman/java/src/ping/afslkdfj.java diff --git a/gearman/java/.classpath b/gearman/java/.classpath new file mode 100644 index 0000000..5c18aa0 --- /dev/null +++ b/gearman/java/.classpath @@ -0,0 +1,8 @@ + + + + + + + + diff --git a/gearman/java/src/ping/afslkdfj.java b/gearman/java/src/ping/afslkdfj.java deleted file mode 100755 index 08fab85..0000000 --- a/gearman/java/src/ping/afslkdfj.java +++ /dev/null @@ -1,79 +0,0 @@ -package ping; - -import java.io.IOException; -import java.net.InetSocketAddress; - -import static org.gearman.GearmanJobResult.workSuccessful; - -import org.gearman.Gearman; -import org.gearman.GearmanClient; -import org.gearman.GearmanFunction; -import org.gearman.GearmanJob; -import org.gearman.GearmanJobResult; -import org.gearman.GearmanWorker; -import org.gearman.GearmanClient.GearmanSubmitHandler; -import org.gearman.GearmanClient.SubmitCallbackResult; -import org.gearman.core.GearmanConstants; - -public class somePingWorker implements GearmanFunction { - public static void main(String[] args) throws IOException { - final Gearman gearman = new Gearman(); - final GearmanWorker worker = gearman.createGearmanWorker(); - worker.addServer(new InetSocketAddress("132.230.4.3", - GearmanConstants.DEFAULT_PORT)); - worker.addFunction("somePing", new somePingWorker()); - } - - @Override - public GearmanJobResult work(GearmanJob job) { - final GearmanSubmitHandler callback = new GearmanSubmitHandler() { - @Override - public void onComplete(GearmanJob newJob, - SubmitCallbackResult result) { - if (result.isSuccessful()) - return; - System.err.println("job submission failed: " + result.name()); - } - }; - //String ips = new String(job.getJobData()); - final GearmanJob pingJob = new GearmanJob("ping", "Hello World" - .getBytes()) { - @Override - public void callbackStatus(long numerator, long denominator) { - assert false; - } - - @Override - public void callbackData(byte[] data) { - assert false; - } - - @Override - public void callbackWarning(byte[] warning) { - assert false; - } - - @Override - protected void onComplete(GearmanJobResult result) { - if (result.isSuccessful()) { - System.out.println(new String(result.getData(), - GearmanConstants.UTF_8)); - } else { - System.err.println("Job execution failed: " - + result.getJobCallbackResult().name()); - } - } - }; - try { - Gearman gearman = new Gearman(); - GearmanClient client = gearman.createGearmanClient(); - client.addServer(new InetSocketAddress("132.230.4.3", - GearmanConstants.DEFAULT_PORT)); - System.out.println("Ping: " + new String(job.getJobData())); - client.submitJob(pingJob, callback); - } catch (IOException e) { - e.printStackTrace(); - } - return workSuccessful(job.getJobData()); - } -} -- cgit v1.2.3-55-g7522 From 3052183fc6ed2c846ff6072a4a3d59348b0f13db Mon Sep 17 00:00:00 2001 From: Björn Geiger Date: Mon, 18 Jul 2011 17:19:33 +0200 Subject: minor --- .gitignore | 1 + 1 file changed, 1 insertion(+) diff --git a/.gitignore b/.gitignore index adc52b0..c7dc9d7 100644 --- a/.gitignore +++ b/.gitignore @@ -4,5 +4,6 @@ library/Zend/ .project .buildpath .settings/ +gearman/java/.classpath application/configs/application.ini resources/ -- cgit v1.2.3-55-g7522 From 2677a856b98ba0e9a0cfd1f17c6371d13f8f4271 Mon Sep 17 00:00:00 2001 From: Björn Geiger Date: Mon, 18 Jul 2011 17:20:08 +0200 Subject: .classpath wieder gelöscht --- gearman/java/.classpath | 8 -------- 1 file changed, 8 deletions(-) delete mode 100644 gearman/java/.classpath diff --git a/gearman/java/.classpath b/gearman/java/.classpath deleted file mode 100644 index 5c18aa0..0000000 --- a/gearman/java/.classpath +++ /dev/null @@ -1,8 +0,0 @@ - - - - - - - - -- cgit v1.2.3-55-g7522