Emit event to subscribers based on timeout rules

@param key     key to change
@param oldval  original value (for logging purposes)
@param value   new value to assign
199479
function(key, oldval, value) {
    if (store._changed_keys.indexOf(key) === -1) {
      store._changed_keys.push(key)
    }

    // suppress active timeout (if any)
    if (store._debounce_timeout) {
      store._clearDebounceTimeout()
    }

    if (store.options.debounce_ms) {
      // delay event emission and set new timeout id
      store._debounce_timeout = setTimeout(store._publish, store.options.debounce_ms)
    } else {
      // publish immediately
      store._publish()
    }
  }
1257192
@Override
    public void setValue(final Object value, final long time) throws DevFailed {
        this.setValue(value);
        this.setTime(time);
    }
951468
public void setValue(Object value, long timeout) {
		_value = value;
		_expiration = System.currentTimeMillis() + timeout;
	}
781244
@Override
	protected void submitRedoPut(final K key, final V value) {
		if (!useRedo) {
			return;
		}
		createRedoThread();
		final ByteBuffer buf = bufstack.pop();
		buf.put((byte) 0x0A); // PUT HEADER
		key.serialize(buf);
		value.serialize(buf);
		buf.put((byte) 0x0A); // PUT FOOTER
		buf.flip();
		if (useRedoThread) {
			try {
				redoQueue.put(buf);
			} catch (InterruptedException e) {
				log.error("InterruptedException in submitRedoPut(key, value)", e);
			}
		} else {
			redoStore.write(buf);
			bufstack.push(buf);
		}
	}
703787
void changedValue(Object value) {
		Object oldValue = super.putSilent(VALUE, value);
		if (!Objects.equals(oldValue, value)) {
			fireChange();
		}
	}
1245254
private void configureEvent(CacheEntryListenerInvocation listenerInvocation,
                               EventImpl<K, V> e, K key, V value, boolean pre, InvocationContext ctx) {
      e.setPre(pre);
      e.setKey(convertKey(listenerInvocation, key));
      e.setValue(convertValue(listenerInvocation, value));
      e.setOriginLocal(ctx.isOriginLocal());
      setTx(ctx, e);
   }
1213662
private void setEventChannelTimeoutMillis(EventChannel eventChannel, int millis) {
        //	Change Jacorb policy for timeout
        org.omg.CORBA.Policy p =
                new org.jacorb.orb.policies.RelativeRoundtripTimeoutPolicy(10000 * millis);
        eventChannel._set_policy_override(new Policy[]{p},
                org.omg.CORBA.SetOverrideType.ADD_OVERRIDE);
    }
1093425
@PublicEvolving
	public void setLong(ConfigOption<Long> key, long value) {
		setValueInternal(key.key(), value);
	}
77045
@Override
    public void userEventTriggered(final ChannelHandlerContext ctx, final Object evt) {
        if (evt instanceof IdleStateEvent) {
            IdleStateEvent e = (IdleStateEvent) evt;
            if (e.state() == IdleState.READER_IDLE) {
                ctx.close();
                LOG.warn(jnrpeContext, "Read Timeout");
                //jnrpeContext.getEventBus().post(new LogEvent(this, LogEventType.INFO, "Read Timeout"));
                //EventsUtil.sendEvent(this.jnrpeContext, this, LogEvent.INFO, "Read Timeout");
            } else if (e.state() == IdleState.WRITER_IDLE) {
                LOG.warn(jnrpeContext, "Write Timeout");
                //jnrpeContext.getEventBus().post(new LogEvent(this, LogEventType.INFO, "Write Timeout"));
                //EventsUtil.sendEvent(jnrpeContext, this, LogEvent.INFO, "Write Timeout");
                ctx.close();
            }
        }
    }
894340
private void superSetProperty(String key, String oldValue)
    {
        if (oldValue != null) {
            super.setProperty(key, oldValue);
        }
    }
133589
public <T> void set(EventLocal<T> key, Object value) {
        EventLocalMap<EventLocal<?>, Object> map = getMap(key);
        if (null == map) {
            // the call to getMap would have created the inheritable map
            // if appropriate, thus always create a disconnected map here
            map = new EventLocalMap<EventLocal<?>, Object>();
            if (key.isInheritable()) {
                this.inheritableLocals = map;
            } else {
                this.locals = map;
            }
        }
        map.put(key, value);
    }
22464
function ( key, value ) {
            var property = this.config[key];
        
            if (property && property.event) {
                property.event.fire(value);
            } 
        }
929249
public void setValue (String name, long value)
    {
        Long oldValue = null;
        if (_prefs.get(name, null) != null || _props.getProperty(name) != null) {
            oldValue = Long.valueOf(_prefs.getLong(name, super.getValue(name, 0L)));
        }

        _prefs.putLong(name, value);
        _propsup.firePropertyChange(name, oldValue, Long.valueOf(value));
    }
106552
function(observable, value, callback) {
            var subscription = observable.subscribe(function() {
               subscription.dispose();
               setTimeout(function() {

                   callback();

               }, 50);
            });

            observable(value);
        }
648146
public void setDefaultChainQuiesceTimeout(Object value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
            Tr.event(tc, "Setting default chain quiesce timeout [" + value + "]");
        }
        try {
            long num = MetatypeUtils.parseLong(PROPERTY_CONFIG_ALIAS, PROPERTY_CHAIN_QUIESCETIMEOUT, value, chainQuiesceTimeout);
            if (0 < num) {
                this.chainQuiesceTimeout = num;
            } else {
                if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
                    Tr.event(tc, "Timeout is too low");
                }
            }
        } catch (NumberFormatException nfe) {
            if (TraceComponent.isAnyTracingEnabled() && tc.isEventEnabled()) {
                Tr.event(tc, "Timeout is not a number");
            }
        }
    }
723830
public void event(double value, long time) {
    int barIndex = getBarIndex(value);
    Bar bar = bars.get(barIndex);
    long before = bar.count();
    bar.insert(value, time);
    long after = bar.count();
    size += (after - before);
    if (after > maxBarSize(barIndex)) {
      split(bar, barIndex);
    }
  }
620357
public static void setRuntimeProperty(Object key, Object value) {

        OpenCmsCore.getInstance().setRuntimeProperty(key, value);
    }