/* (non-Javadoc)
@see javax.jms.MessageConsumer#setMessageListener(javax.jms.MessageListener)
358360
@Override
	public final void setMessageListener(MessageListener messageListener) throws JMSException
    {
        super.setMessageListener(messageListener);
        
        // If the connection was already started, wake up the new listener in case there were messages
        // waiting in the destination
        if (messageListener != null && connection.isStarted())
        	engine.getDeliveryAsyncTaskManager().execute(wakeUpAsyncTask);
    }
887414
@Override
    public void doMessageReceivedListeners(final Object message) {
        runManagementTask(new Runnable() {
            @Override
            public void run() {
                try {
                    List<SessionManagementListener> sessionListeners = getManagementListeners();
                    for (final SessionManagementListener listener : sessionListeners) {
                        listener.doMessageReceived(SessionManagementBeanImpl.this, message);
                    }

                    markChanged();
                } catch (Exception ex) {
                    logger.warn("Error during doMessageReceived session listener notifications:", ex);
                }
            }
        });
    }
639025
final void setJsMessageType(MessageType value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setJsMessageType", value);
        /* Get the int value of the MessageType and set that into the field */
        jmo.setField(JsHdrAccess.MESSAGETYPE, value.toByte());
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setJsMessageType");
    }
196557
public void removeMessage(Message message) {
        synchronized (messages) {
            messages.removeIf(messageRef -> Objects.equals(messageRef.get(), message));
        }
    }
349507
@Override
	public final void setJMSMessageID(String id) throws JMSException
    {
    	assertDeserializationLevel(MessageSerializationLevel.FULL);
        this.id = id;
    }
527541
@Reference(name = "messageEndpointCollaborator",
               service = MessageEndpointCollaborator.class,
               cardinality = ReferenceCardinality.OPTIONAL,
               policy = ReferencePolicy.DYNAMIC,
               policyOption = ReferencePolicyOption.GREEDY)
    protected void setMessageEndpointCollaborator(ServiceReference<MessageEndpointCollaborator> reference) {
        messageEndpointCollaboratorRef.setReference(reference);
    }
57394
private void setInfoMessage(String newMessage) {
		if (getMessage() == null || getMessageType() < IMessageProvider.INFORMATION)
			setMessage(newMessage, IMessageProvider.INFORMATION);
	}
930115
public void setMessageText(SendableTextMessage.SendableTextMessageBuilder messageBuilder) {
        SendableTextMessage message = messageBuilder.build();
        baseMessage.getBotInstance().editMessageText(baseMessage, message.getMessage(), message.getParseMode(),
                message.isDisableWebPagePreview(), toKeyboard());
    }
98899
public SingleFieldBuilder<MType, BType, IType> setMessage(
      MType message) {
    if (message == null) {
      throw new NullPointerException();
    }
    this.message = message;
    if (builder != null) {
      builder.dispose();
      builder = null;
    }
    onChanged();
    return this;
  }
222213
public void onMessage(Message msg) {
	        try {
                    LOG.debug("Queuing msg [" + msg.getJMSMessageID() + "]");
                } catch (JMSException e) {
                }
		this.queue.offer(msg);
	}
572121
public void setMessage(String message) {
    pushData.clear();
    Map<String, Object> map = AVUtils.createStringObjectMap("alert", message);
    pushData.put("data", map);
  }
1213185
public MessagelistenerType<MessageadapterType<T>> getOrCreateMessagelistener()
   {
      List<Node> nodeList = childNode.get("messagelistener");
      if (nodeList != null &&  nodeList.size() > 0)
      {
         return new MessagelistenerTypeImpl<MessageadapterType<T>>(this, "messagelistener", childNode, nodeList.get(0));
      }
      return createMessagelistener();
   }
243842
public final void setMessageWaitTime(long value) {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "setMessageWaitTime", Long.valueOf(value));
        /* Just set the transient value - it will be written back later */
        cachedMessageWaitTime = Long.valueOf(value);
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.exit(this, tc, "setMessageWaitTime");
    }
35805
@Nonnull
  public EChange setSystemMessage (@Nonnull final ESystemMessageType eMessageType, @Nullable final String sMessage)
  {
    ValueEnforcer.notNull (eMessageType, "MessageType");

    if (m_eMessageType.equals (eMessageType) && EqualsHelper.equals (m_sMessage, sMessage))
      return EChange.UNCHANGED;

    internalSetMessageType (eMessageType);
    internalSetMessage (sMessage);
    setLastUpdate (PDTFactory.getCurrentLocalDateTime ());

    return EChange.CHANGED;
  }
1027171
@SuppressWarnings("unchecked")
    public <T extends WebLocatorAbstractBuilder> T setInfoMessage(final String infoMessage) {
        pathBuilder.setInfoMessage(infoMessage);
        return (T) this;
    }
1337849
public List<MessagelistenerType<MessageadapterType<T>>> getAllMessagelistener()
   {
      List<MessagelistenerType<MessageadapterType<T>>> list = new ArrayList<MessagelistenerType<MessageadapterType<T>>>();
      List<Node> nodeList = childNode.get("messagelistener");
      for(Node node: nodeList)
      {
         MessagelistenerType<MessageadapterType<T>>  type = new MessagelistenerTypeImpl<MessageadapterType<T>>(this, "messagelistener", childNode, node);
         list.add(type);
      }
      return list;
   }
339875
public void setMessage(String message) {

        checkFrozen();
        if (isEnabled() && CmsStringUtil.isEmptyOrWhitespaceOnly(message)) {
            throw new CmsIllegalArgumentException(Messages.get().container(Messages.ERR_LOGIN_MESSAGE_BAD_MESSAGE_0));
        }
        m_message = message;
    }