diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-02-23 11:52:33 +0100 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-02-23 11:52:33 +0100 |
commit | 7c0df6ee02eb792c6afea7f047539840addb2f02 (patch) | |
tree | e59f52f853a6838c78528b1dba144749a34cb33a /bindings/java/org/zmq | |
parent | ef1b5974891a30b15299464859023a531c2328f8 (diff) |
Java binding beautified, inline documentation added
Diffstat (limited to 'bindings/java/org/zmq')
-rwxr-xr-x[-rw-r--r--] | bindings/java/org/zmq/Context.java | 17 | ||||
-rwxr-xr-x[-rw-r--r--] | bindings/java/org/zmq/Socket.java | 59 |
2 files changed, 49 insertions, 27 deletions
diff --git a/bindings/java/org/zmq/Context.java b/bindings/java/org/zmq/Context.java index 3c00ba8..219b26c 100644..100755 --- a/bindings/java/org/zmq/Context.java +++ b/bindings/java/org/zmq/Context.java @@ -36,17 +36,22 @@ public class Context { construct (appThreads, ioThreads, flags); } - /** - * Internal function. Do not use directly! - */ - public native long createSocket (int type); - /** Initialize the JNI interface */ protected native void construct (int appThreads, int ioThreads, int flags); - /** Free resources used by JNI driver. */ + /** Free all resources used by JNI interface. */ protected native void finalize (); + /** + * Get the underlying context handle. + * + * @return the internal 0MQ context handle. + */ + private long getContextHandle () { + return contextHandle; + } + + /** Opaque data used by JNI driver. */ private long contextHandle; } diff --git a/bindings/java/org/zmq/Socket.java b/bindings/java/org/zmq/Socket.java index 1b427c3..1815b53 100644..100755 --- a/bindings/java/org/zmq/Socket.java +++ b/bindings/java/org/zmq/Socket.java @@ -1,4 +1,4 @@ - /* +/* Copyright (c) 2007-2010 iMatix Corporation This file is part of 0MQ. @@ -19,9 +19,7 @@ package org.zmq; -public class Socket -{ - +public class Socket { static { System.loadLibrary("jzmq"); } @@ -52,44 +50,53 @@ public class Socket public static final int SNDBUF = 11; public static final int RCVBUF = 12; + /** * Class constructor. * - * @param context - * @param type + * @param context a 0MQ context previously created. + * @param type the socket type. */ public Socket (Context context, int type) { construct (context, type); } /** - * Set the socket option value. + * Set the socket option value, given as a long. + * + * @param option ID of the option to set. + * @param optval value (as a long) to set the option to. + */ + public native void setsockopt (int option, long optval); + + /** + * Set the socket option value, given as a String. * - * @param option ID of the option to set - * @param optval value to set the option to + * @param option ID of the option to set. + * @param optval value (as a String) to set the option to. */ - public native void setsockopt (int option, long optval); - public native void setsockopt (int option, String optval); + public native void setsockopt (int option, String optval); /** * Bind to network interface. Start listening for new connections. * - * @param addr + * @param addr the endpoint to bind to. */ public native void bind (String addr); /** * Connect to remote application. * - * @param addr + * @param addr the endpoint to connect to. */ public native void connect (String addr); /** - * Send the message. + * Send a message. * - * @param msg - * @param flags + * @param msg the message to send, as an array of bytes. + * @param flags the flags to apply to the send operation. + * @return true if send was successful, false otherwise. */ public native boolean send (byte [] msg, long flags); @@ -99,19 +106,29 @@ public class Socket public native void flush (); /** - * Receive message. + * Receive a message. * - * @param flags - * @return + * @param flags the flags to apply to the receive operation. + * @return the message received, as an array of bytes; null on error. */ public native byte [] recv (long flags); - /** Initialize JNI driver */ + /** Initialize the JNI interface */ protected native void construct (Context context, int type); - /** Free all resources used by JNI driver. */ + /** Free all resources used by JNI interface. */ protected native void finalize (); + /** + * Get the underlying socket handle. + * + * @return the internal 0MQ socket handle. + */ + private long getSocketHandle () { + return socketHandle; + } + + /** Opaque data used by JNI driver. */ private long socketHandle; |