Package zmq

Class Ctx.ChannelForwardHolder

  • Enclosing class:
    Ctx
    private static class Ctx.ChannelForwardHolder
extends java.lang.Object
    A class that holds the informations needed to forward channel in monitor sockets. Of course, it only works with inproc sockets.

    It uses WeakReference to avoid holding references to channel if the monitor event is lost.

    A class is used as a lock in lazy allocation of the needed objects.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.concurrent.atomic.AtomicInteger handleSource  
      private java.util.Map<java.lang.Integer,​java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>> map  
      private java.lang.ref.ReferenceQueue<java.nio.channels.SelectableChannel> queue  
      private java.util.Map<java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>,​java.lang.Integer> reversemap  

    • Method Summary

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • handleSource

        private final java.util.concurrent.atomic.AtomicInteger handleSource

      • map

        private final java.util.Map<java.lang.Integer,​java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>> map

      • reversemap

        private final java.util.Map<java.lang.ref.WeakReference<java.nio.channels.SelectableChannel>,​java.lang.Integer> reversemap

      • queue

        private final java.lang.ref.ReferenceQueue<java.nio.channels.SelectableChannel> queue

    • Constructor Detail

      • ChannelForwardHolder

        private ChannelForwardHolder()