summaryrefslogtreecommitdiff
path: root/bindings/java/org/zmq
diff options
context:
space:
mode:
Diffstat (limited to 'bindings/java/org/zmq')
-rw-r--r--bindings/java/org/zmq/Context.java50
-rw-r--r--bindings/java/org/zmq/Socket.java112
2 files changed, 162 insertions, 0 deletions
diff --git a/bindings/java/org/zmq/Context.java b/bindings/java/org/zmq/Context.java
new file mode 100644
index 0000000..c63ef60
--- /dev/null
+++ b/bindings/java/org/zmq/Context.java
@@ -0,0 +1,50 @@
+/*
+ Copyright (c) 2007-2009 FastMQ Inc.
+
+ This file is part of 0MQ.
+
+ 0MQ is free software; you can redistribute it and/or modify it under
+ the terms of the Lesser GNU General Public License as published by
+ the Free Software Foundation; either version 3 of the License, or
+ (at your option) any later version.
+
+ 0MQ is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ Lesser GNU General Public License for more details.
+
+ You should have received a copy of the Lesser GNU General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+package org.zmq;
+
+public class Context {
+ static {
+ System.loadLibrary("jzmq");
+ }
+
+ /**
+ * Class constructor.
+ *
+ * @param appThreads maximum number of application threads.
+ * @param ioThreads size of the threads pool to handle I/O operations.
+ */
+ public Context (int appThreads, int ioThreads) {
+ construct (appThreads, ioThreads);
+ }
+
+ /**
+ * Internal function. Do not use directly!
+ */
+ public native long createSocket (int type);
+
+ /** Initialize the JNI interface */
+ protected native void construct (int appThreads, int ioThreads);
+
+ /** Free resources used by JNI driver. */
+ protected native void finalize ();
+
+ /** 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
new file mode 100644
index 0000000..501bc16
--- /dev/null
+++ b/bindings/java/org/zmq/Socket.java
@@ -0,0 +1,112 @@
+ /*
+ Copyright (c) 2007-2009 FastMQ Inc.
+
+ This file is part of 0MQ.
+
+ 0MQ is free software; you can redistribute it and/or modify it under
+ the terms of the Lesser GNU General Public License as published by
+ the Free Software Foundation; either version 3 of the License, or
+ (at your option) any later version.
+
+ 0MQ is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ Lesser GNU General Public License for more details.
+
+ You should have received a copy of the Lesser GNU General Public License
+ along with this program. If not, see <http://www.gnu.org/licenses/>.
+*/
+
+package org.zmq;
+
+public class Socket
+{
+
+ static {
+ System.loadLibrary("jzmq");
+ }
+
+ public static final int NOBLOCK = 1;
+ public static final int NOFLUSH = 2;
+
+ public static final int P2P = 0;
+ public static final int PUB = 1;
+ public static final int SUB = 2;
+ public static final int REQ = 3;
+ public static final int REP = 4;
+
+ public static final int HWM = 1;
+ public static final int LWM = 2;
+ public static final int SWAP = 3;
+ public static final int AFFINITY = 4;
+ public static final int IDENTITY = 5;
+ public static final int SUBSCRIBE = 6;
+ public static final int UNSUBSCRIBE = 7;
+ public static final int RATE = 8;
+ public static final int RECOVERY_IVL = 9;
+ public static final int MCAST_LOOP = 10;
+
+ /**
+ * Class constructor.
+ *
+ * @param context
+ * @param type
+ */
+ public Socket (Context context, int type) {
+ construct (context, type);
+ }
+
+ /**
+ * Set the socket option value.
+ *
+ * @param option ID of the option to set
+ * @param optval value to set the option to
+ */
+ public native void setsockopt (int option, long optval);
+ public native void setsockopt (int option, String optval);
+
+ /**
+ * Bind to network interface. Start listening for new connections.
+ *
+ * @param addr
+ */
+ public native void bind (String addr);
+
+ /**
+ * Connect to remote application.
+ *
+ * @param addr
+ */
+ public native void connect (String addr);
+
+ /**
+ * Send the message.
+ *
+ * @param msg
+ * @param flags
+ */
+ public native boolean send (byte [] msg, long flags);
+
+ /**
+ * Flush the messages down the stream.
+ */
+ public native void flush ();
+
+ /**
+ * Receive message.
+ *
+ * @param flags
+ * @return
+ */
+ public native byte [] recv (long flags);
+
+ /** Initialize JNI driver */
+ protected native void construct (Context context, int type);
+
+ /** Free all resources used by JNI driver. */
+ protected native void finalize ();
+
+ /** Opaque data used by JNI driver. */
+ private long socketHandle;
+
+}