summaryrefslogtreecommitdiff
path: root/java/org
diff options
context:
space:
mode:
authormalosek <malosek@fastmq.com>2009-09-15 09:44:44 +0200
committermalosek <malosek@fastmq.com>2009-09-15 09:44:44 +0200
commit364281343ce0fd03b25bc6b1b451ee7ba8db436b (patch)
tree32cd09900e2ecdc31d6a8f2a47a68fe128980169 /java/org
parentbdf22e9c2fe82366283f4edc02fd59c37fdb2c4b (diff)
parentf7ad4a203ad184d97002111f4ffb8bfe6a8f7c01 (diff)
Merge branch 'master' of git@github.com:sustrik/zeromq2
Diffstat (limited to 'java/org')
-rw-r--r--java/org/zmq/Socket.java58
1 files changed, 15 insertions, 43 deletions
diff --git a/java/org/zmq/Socket.java b/java/org/zmq/Socket.java
index 4c6a3d3..0d96c71 100644
--- a/java/org/zmq/Socket.java
+++ b/java/org/zmq/Socket.java
@@ -27,19 +27,24 @@ public class Socket
}
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;
+
/**
* Class constructor.
*
@@ -51,46 +56,13 @@ public class Socket
}
/**
- * Set the high watermark on the socket.
- *
- * @param hwm high watermark.
- */
- public native void setHwm (long hwm);
-
- /**
- * Set the low watermark on the socket.
- *
- * @param lwm low watermark.
- */
- public native void setLwm (long lwm);
-
- /**
- * Set swap size.
- *
- * @param swap_size swap size.
- */
- public native void setSwap (long swap_size);
-
- /**
- * Set reception mask.
- *
- * @param mask mask.
- */
- public native void setMask (long mask);
-
- /**
- * Set affinity.
- *
- * @param affinity
- */
- public native void setAffinity (long affinity);
-
- /**
- * Set identity.
+ * Set the socket option value.
*
- * @param identity
+ * @param option ID of the option to set
+ * @param optval value to set the option to
*/
- public native void setIdentity (String identity);
+ 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.