Package zmq

Class Ctx


public class Ctx extends Object
  • Field Details

  • Constructor Details

    • Ctx

      public Ctx()
  • Method Details

    • destroy

      private void destroy() throws IOException
      Throws:
      IOException
    • isActive

      public boolean isActive()
      Returns:
      false if terminate()terminate() has been called.
    • checkTag

      @Deprecated public boolean checkTag()
      Deprecated.
      use isActive() instead
      Returns:
      false if terminate()terminate() has been called.
    • terminate

      public void terminate()
    • shutdown

      final void shutdown()
    • setUncaughtExceptionHandler

      public void setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler handler)
      Set the handler invoked when a Poller abruptly terminates due to an uncaught exception.

      It default to the value of Thread.getDefaultUncaughtExceptionHandler()

      Parameters:
      handler - The object to use as this thread's uncaught exception handler. If null then this thread has no explicit handler.
    • getUncaughtExceptionHandler

      public Thread.UncaughtExceptionHandler getUncaughtExceptionHandler()
      Returns:
      The handler invoked when a Poller abruptly terminates due to an uncaught exception.
    • setNotificationExceptionHandler

      public void setNotificationExceptionHandler(Thread.UncaughtExceptionHandler handler)
      In Poller.run(), some non-fatal exceptions can be thrown. This handler will be notified, so they can be logged.

      Default to Throwable.printStackTrace()

      Parameters:
      handler - The object to use as this thread's handler for recoverable exceptions notifications.
    • getNotificationExceptionHandler

      public Thread.UncaughtExceptionHandler getNotificationExceptionHandler()
      Returns:
      The handler invoked when a non-fatal exceptions is thrown in zmq.poll.Poller#run()
    • set

      public boolean set(int option, int optval)
    • get

      public int get(int option)
    • createSocket

      public SocketBase createSocket(int type)
    • initSlots

      private void initSlots()
    • destroySocket

      void destroySocket(SocketBase socket)
    • createSelector

      public Selector createSelector()
    • closeSelector

      public boolean closeSelector(Selector selector)
    • getReaper

      ZObject getReaper()
    • sendCommand

      void sendCommand(int tid, Command command)
    • chooseIoThread

      IOThread chooseIoThread(long affinity)
    • registerEndpoint

      boolean registerEndpoint(String addr, Ctx.Endpoint endpoint)
    • unregisterEndpoint

      boolean unregisterEndpoint(String addr, SocketBase socket)
    • unregisterEndpoints

      void unregisterEndpoints(SocketBase socket)
    • findEndpoint

      Ctx.Endpoint findEndpoint(String addr)
    • pendConnection

      void pendConnection(String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
    • connectPending

      void connectPending(String addr, SocketBase bindSocket)
    • connectInprocSockets

      private void connectInprocSockets(SocketBase bindSocket, Options bindOptions, Ctx.PendingConnection pendingConnection, Ctx.Side side)
    • errno

      public Errno errno()
    • forwardChannel

      int forwardChannel(SelectableChannel channel)
      Forward a channel in a monitor socket.
      Parameters:
      channel - a channel to forward
      Returns:
      the handle of the channel to be forwarded, used to retrieve it in getForwardedChannel(Integer)
    • getForwardedChannel

      SelectableChannel getForwardedChannel(Integer handle)
      Retrieve a channel, using the handle returned by forwardChannel(SelectableChannel). As WeakReference are used, if the channel was discarded and a GC ran, it will not be found and this method will return null.
      Parameters:
      handle -
      Returns:
    • cleanForwarded

      private void cleanForwarded()
      Clean all empty references