Class WanConsumerConfig

    • Constructor Detail

      • WanConsumerConfig

        public WanConsumerConfig()
    • Method Detail

      • getProperties

        public java.util.Map<java.lang.String,​java.lang.Comparable> getProperties()
        Returns the properties for the custom WAN consumer.
      • setProperties

        public WanConsumerConfig setProperties​(java.util.Map<java.lang.String,​java.lang.Comparable> properties)
        Sets the properties for the custom WAN consumer. These properties are accessible when initalizing the WAN consumer.
        Parameters:
        properties - the properties for the WAN consumer
        Returns:
        this config
      • getClassName

        public java.lang.String getClassName()
        Returns the fully qualified class name of the class implementing WanConsumer.
        Returns:
        fully qualified class name
      • setClassName

        public WanConsumerConfig setClassName​(@Nonnull
                                              java.lang.String className)
        Sets the fully qualified class name of the class implementing WanConsumer. The class name may be null in which case the implementation or the default processing logic for incoming WAN events will be used.
        Parameters:
        className - fully qualified class name
        Returns:
        this config
        See Also:
        setImplementation(WanConsumer)
      • getImplementation

        public WanConsumer getImplementation()
        Returns the implementation implementing WanConsumer.
        Returns:
        the implementation for this WAN consumer
      • setImplementation

        public WanConsumerConfig setImplementation​(@Nonnull
                                                   WanConsumer implementation)
        Sets the implementation for this WAN consumer. The object must implement WanConsumer. The implementation may be null in which case the class name or the default processing logic for incoming WAN events will be used.
        Parameters:
        implementation - the object implementing WanConsumer
        Returns:
        this config
        See Also:
        setClassName(String)
      • isPersistWanReplicatedData

        public boolean isPersistWanReplicatedData()
        Returns:
        true when persistence of replicated data into backing store is enabled, otherwise returns false. By default this method returns false.
      • setPersistWanReplicatedData

        public WanConsumerConfig setPersistWanReplicatedData​(boolean persistWanReplicatedData)
        Parameters:
        persistWanReplicatedData - set true to enable persistence of replicated data into backing store, otherwise set false to disable it. Default value is false.
        Returns:
        reference to this WanReplicationRef object
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • writeData

        public void writeData​(ObjectDataOutput out)
                       throws java.io.IOException
        Description copied from interface: DataSerializable
        Writes object fields to output stream
        Specified by:
        writeData in interface DataSerializable
        Parameters:
        out - output
        Throws:
        java.io.IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.
      • readData

        public void readData​(ObjectDataInput in)
                      throws java.io.IOException
        Description copied from interface: DataSerializable
        Reads fields from the input stream
        Specified by:
        readData in interface DataSerializable
        Parameters:
        in - input
        Throws:
        java.io.IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object