Class JGroupsBroadcastEndpoint

    • Constructor Detail

      • JGroupsBroadcastEndpoint

        public JGroupsBroadcastEndpoint​(JChannelManager manager,
                                        String channelName)
    • Method Detail

      • receiveBroadcast

        public byte[] receiveBroadcast​(long time,
                                       TimeUnit unit)
                                throws Exception
        Description copied from interface: BroadcastEndpoint
        Receives the broadcast data with a timeout. It blocks until either the data is available or the timeout is reached, whichever comes first.
        Specified by:
        receiveBroadcast in interface BroadcastEndpoint
        Parameters:
        time - : how long the method should wait for the data to arrive.
        unit - : unit of the time.
        Returns:
        a byte array if data is arrived within the timeout, or null if no data is available after the timeout.
        Throws:
        Exception
      • openClient

        public void openClient()
                        throws Exception
        Description copied from interface: BroadcastEndpoint
        This method initializes a BroadcastEndpoint as a receiving end for broadcasts. After that data can be received using one of its receiveBroadcast() methods.
        Specified by:
        openClient in interface BroadcastEndpoint
        Throws:
        Exception
      • createChannel

        public abstract org.jgroups.JChannel createChannel()
                                                    throws Exception
        Throws:
        Exception
      • close

        public void close​(boolean isBroadcast)
                   throws Exception
        Description copied from interface: BroadcastEndpoint
        Close the endpoint. Any related resources should be cleaned up in this method.
        Specified by:
        close in interface BroadcastEndpoint
        Parameters:
        isBroadcast - : indicates whether this endpoint serves as a broadcast or not.
        Throws:
        Exception
      • internalCloseChannel

        protected void internalCloseChannel​(JChannelWrapper channel)
        Closes the channel used in this JGroups Broadcast. Can be overridden by implementations that use an externally managed channel.
        Parameters:
        channel -