diff options
Diffstat (limited to 'java/org/zmq')
-rw-r--r-- | java/org/zmq/Context.java | 50 | ||||
-rw-r--r-- | java/org/zmq/Socket.java | 112 |
2 files changed, 0 insertions, 162 deletions
diff --git a/java/org/zmq/Context.java b/java/org/zmq/Context.java deleted file mode 100644 index c63ef60..0000000 --- a/java/org/zmq/Context.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - 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/java/org/zmq/Socket.java b/java/org/zmq/Socket.java deleted file mode 100644 index 501bc16..0000000 --- a/java/org/zmq/Socket.java +++ /dev/null @@ -1,112 +0,0 @@ - /* - 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; - -} |