{@inheritDoc}.
@deprecated see {@link #willReceive(UUID, Event)}
12332
@Deprecated
	@Override
	public void receive(UUID receiverID, Event event) {
		willReceive(receiverID, event);
	}
683220
static void setOverrideNotificationReceipt(Boolean value) {
        if (value == null) {
            remove(OVERRIDE_NOTIFICATION_RECEIPT_PREF_NAME);
        } else {
            putBoolean(OVERRIDE_NOTIFICATION_RECEIPT_PREF_NAME, value);
        }
    }
171935
@Override
	public final void setUUID(UUID id) {
		final UUID oldId = getUUID();
		if ((oldId != null && !oldId.equals(id)) || (oldId == null && id != null)) {
			super.setUUID(oldId);
			fireElementChanged();
		}
	}
595854
protected void sendEvent(T event, Object receiver, CreationalContext<?> creationalContext) {
        try {
            preNotify(event, receiver);
            // As we are working with the contextual instance, we may not have the
            // actual object, but a container proxy (e.g. EJB)
            notificationStrategy.invoke(receiver, observerMethod, event, beanManager, creationalContext);
        } finally {
            postNotify(event, receiver);
        }
    }
224023
public void notifyReceiveAllowedRCD(DestinationHandler destinationHandler)
  {
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.entry(tc, "notifyReceiveAllowedRCD", new Object[] {destinationHandler});

    // For PtoP iterate over anycastInputHandlers
    synchronized (_anycastInputHandlers) 
    { 
      for(Iterator i=_anycastInputHandlers.keySet().iterator(); i.hasNext();) 
      { 
        String key = (String) i.next(); 
        AnycastInputHandler aih = _anycastInputHandlers.get(key); 
        if (aih != null) 
        { 
          RemoteConsumerDispatcher rcd = aih.getRCD();
          rcd.notifyReceiveAllowed(destinationHandler);
        }
      }
    }
        
    if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
      SibTr.exit(tc, "notifyReceiveAllowedRCD");
  }
867035
public void addPreMessageReceivedEventListener(Executor executor, PreMessageReceivedEventListener listener) {
        peersPreMessageReceivedEventListeners.add(new ListenerRegistration<>(checkNotNull(listener), executor));
        for (Peer peer : getConnectedPeers())
            peer.addPreMessageReceivedEventListener(executor, listener);
        for (Peer peer : getPendingPeers())
            peer.addPreMessageReceivedEventListener(executor, listener);
    }
1098233
private <I extends Message, O extends Message> ListenableFuture<JsonRpcResponse> invoke(
      ServerMethod<I, O> method, JsonObject parameter, JsonElement id) {
    I request;
    try {
      request = (I) Messages.fromJson(method.inputBuilder(), parameter);
    } catch (Exception e) {
      serverLogger.logServerFailure(method, e);
      SettableFuture<JsonRpcResponse> future = SettableFuture.create();
      future.setException(e);
      return future;
    }
    ListenableFuture<O> response = method.invoke(request);
    return Futures.transform(response, new JsonConverter(id), TRANSFORM_EXECUTOR);
  }
936583
public function setReceiveDelay($milliseconds = null)
    {
        if (is_integer($milliseconds)
            && $milliseconds >= self::DEF_RECEIVE_DELAY
        ) {
            $this->_receivedelay = $milliseconds;
        } else {
            $this->_receivedelay = self::DEF_RECEIVE_DELAY;
        }
        return $this->_receivedelay;
    }
657461
@Override
    public void notifyReceiveAllowed(boolean isAllowed)
    {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(tc, "notifyReceiveAllowed", new Object[] { Boolean.valueOf(isAllowed), this });

        this.lock();
        try
        {
            try
            {
                checkReceiveAllowed();
            } catch (SISessionUnavailableException e)
            {
                // FFDC
                FFDCFilter.processException(
                                            e,
                                            "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint.notifyReceiveAllowed",
                                            "1:4287:1.22.5.1",
                                            this);

                SibTr.exception(tc, e);
            } catch (SIResourceException e)
            {
                // FFDC
                FFDCFilter.processException(
                                            e,
                                            "com.ibm.ws.sib.processor.impl.JSLocalConsumerPoint.notifyReceiveAllowed",
                                            "1:4298:1.22.5.1",
                                            this);

                SibTr.exception(tc, e);
            }
        } finally
        {
            this.unlock();
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(tc, "notifyReceiveAllowed");
    }
1279790
public static <S, T extends Event, U extends T> InputMapTemplate<S, U> consumeWhen(
            EventPattern<? super T, ? extends U> eventPattern,
            Predicate<? super S> condition,
            BiConsumer<? super S, ? super U> action) {
        return process(eventPattern, (s, u) -> {
            if(condition.test(s)) {
                action.accept(s, u);
                return Result.CONSUME;
            } else {
                return Result.PROCEED;
            }
        });
    }
543990
private void resetReceiveIdleTimer(Event event) {
        final String methodName = "resetReceiveIdleTimer";
        logger.entry(this, methodName, event);

        if (receiveScheduledFuture != null) {
            receiveScheduledFuture.cancel(false);
        }

        final Transport transport = event.getTransport();
        if (transport != null) {
            final int localIdleTimeOut = transport.getIdleTimeout();
            if (localIdleTimeOut > 0) {
                Runnable receiveTimeout = new Runnable() {
                    @Override
                    public void run() {
                        final String methodName = "run";
                        logger.entry(this, methodName);
                        transport.process();
                        transport.tick(System.currentTimeMillis());
                        logger.exit(methodName);
                    }
                };
                receiveScheduledFuture = scheduler.schedule(receiveTimeout,
                        localIdleTimeOut, TimeUnit.MILLISECONDS);
            }
        }
        logger.exit(this, methodName);
    }
611397
protected void sendEvent(final T event) {
        if (isStatic) {
            sendEvent(event, null, null);
        } else {
            CreationalContext<X> creationalContext = null;
            try {
                Object receiver = getReceiverIfExists(null);
                if (receiver == null && reception != Reception.IF_EXISTS) {
                    // creational context is created only if we need it for obtaining receiver
                    // ObserverInvocationStrategy takes care of creating CC for parameters, if needed
                    creationalContext = beanManager.createCreationalContext(declaringBean);
                    receiver = getReceiverIfExists(creationalContext);
                }
                if (receiver != null) {
                    sendEvent(event, receiver, creationalContext);
                }
            } finally {
                if (creationalContext != null) {
                    creationalContext.release();
                }
            }
        }
    }
1321757
@Override
    public void subscribeRemoteEvent(String eventName, boolean subscribe) {
        String channelName = EventUtil.getChannelName(eventName);
        
        if (subscribe) {
            consumer.subscribe(channelName, this);
        } else {
            consumer.unsubscribe(channelName, this);
        }
    }
768627
private void fireFrameReceived(final KnxTunnelEmi emiType, final byte[] frame) throws KNXFormatException
	{
		logger.debug("received {} frame {}", emiType, DataUnitBuilder.toHex(frame, ""));
		final FrameEvent fe = emiType == KnxTunnelEmi.CEmi
				? new FrameEvent(this, CEMIFactory.create(frame, 0, frame.length)) : new FrameEvent(this, frame);
		listeners.fire(l -> l.frameReceived(fe));
	}
1215212
public final void setGuaranteedGatheringTargetUUID(SIBUuid12 value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setGuaranteedGatheringTargetUUID", value);
        if (value != null)
            getHdr2().setField(JsHdr2Access.GUARANTEED_SET_GATHERINGTARGETUUID_VALUE, value.toByteArray());
        else
            getHdr2().setField(JsHdr2Access.GUARANTEED_SET_GATHERINGTARGETUUID, JsHdr2Access.IS_GUARANTEED_SET_GATHERINGTARGETUUID_EMPTY);
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setGuaranteedGatheringTargetUUID");
    }
332082
@Override
    public AsyncAuditOutputStream write(AuditEvent event) {
        if (event instanceof AnnotationAuditEvent) {
            annotationStream.write((AnnotationAuditEvent) event);
        } else {
            deferred.accept(event);
            b.await();
        }
        
        return this;
    }
1244662
@Override
	public void setUUID(UUID id) {
		assert id != null;
		final UUID old = getUUID();
		if (!id.equals(old)) {
			super.setUUID(id);
			firePrimitiveChanged();
		}
	}