Returns the {@link MessageBroker} for routing messages

@return the message broker
433241
public MessageBroker getMessageBroker() {
        if (this.messageBroker != null) {
            return this.messageBroker;
        }
        Assert.notNull(FlexContext.getMessageBroker(), "A MessageBroker was not set on the MessageTemplate "
            + "and no thread-local MessageBroker could be found in the FlexContext.");
        return FlexContext.getMessageBroker();
    }
1198513
public List<ConversionMessage> getMessages( ConversionMessageType messageType ) {
        List<ConversionMessage> messages = new ArrayList<ConversionMessage>();
        for ( ConversionMessage message : this.messages ) {
            if ( message.getMessageType() == messageType ) {
                messages.add( message );
            }
        }
        return messages;
    }
926479
public static ExtendedTransactionManager getClientTransactionManager() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            Tr.entry(tc, "getClientTransactionManager");

        if (_tranManager == null) {
            loadEmbeddableTranManager(clientTMKey);
        }

        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            Tr.exit(tc, "getClientTransactionManager", _tranManager);
        return _tranManager;
    }
672874
public ConnectionManager getConnectionManager() {
        if (TraceComponent.isAnyTracingEnabled() && tc.isDebugEnabled()) {
            Tr.debug(this, tc, "Connection manager is " + cm + " for managed connection " + this);
            if (cm == null && pm != null) {
                Tr.debug(this, tc, "Connection pool is " + this.pm.toString());
            }
        }
        if (cm != null) {
            return cm;
        } else {
            IllegalStateException e = new IllegalStateException("ConnectionManager is null");
            Tr.error(tc, "ILLEGAL_STATE_EXCEPTION_J2CA0079", "getConnectionManager", e);
            throw e;
        }
    }
892135
private TransactionManager getTransactionManager()
    {
        TransactionManager retval = null;
        try
        {
            if (log.isDebugEnabled()) log.debug("getTransactionManager called");
            retval = TransactionManagerFactoryFactory.instance().getTransactionManager();
        }
        catch (TransactionManagerFactoryException e)
        {
            log.warn("Exception trying to obtain TransactionManager from Factory", e);
            e.printStackTrace();
        }
        return retval;
    }
103055
public static WsByteBufferPoolManager getBufferManager() {
        final CHFWBundle chfw = getCHFWBundle();
        if (null == chfw) {
            return ChannelFrameworkFactory.getBufferManager();
        }
        return chfw.getBufferManager();
    }
84704
protected BrokerServiceAccessor getMethodAccessor(String serviceBrokerName, CatalogService description) {
        return new AnnotationBrokerServiceAccessor(description, serviceBrokerName, getBeanClass(serviceBrokerName),
              context.getBean(serviceBrokerName));
    }
1368545
public BaseConvertToMessage getConvertToMessage()
    {
        if (m_convertToMessage == null)
        {
            BaseMessageHeader trxMessageHeader = this.getMessage().getMessageHeader();
            String strMessageClass = (String)trxMessageHeader.get(TrxMessageHeader.MESSAGE_MARSHALLER_CLASS);
            String strPackage = (String)trxMessageHeader.get(TrxMessageHeader.BASE_PACKAGE);
            strMessageClass = ClassServiceUtility.getFullClassName(strPackage, strMessageClass);
            m_convertToMessage = (BaseConvertToMessage)ClassServiceUtility.getClassService().makeObjectFromClassName(strMessageClass);
            if (m_convertToMessage != null)
            	m_convertToMessage.init(this);
        }
        return m_convertToMessage;
    }
89560
@Override
    public MessageResourcesGateway getMessageResourceGateway() {
        final MessageResourcesGateway gateway = messageResourcesHolder.getGateway();
        if (gateway == null) {
            String msg = "Not found the gateway for message resource: holder=" + messageResourcesHolder;
            throw new IllegalStateException(msg);
        }
        return gateway;
    }
538450
@Override
    public QueueBrowser createBrowser(Queue queue, String messageSelector) throws JMSRuntimeException, InvalidDestinationRuntimeException, InvalidSelectorRuntimeException {
        if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
            SibTr.entry(this, tc, "createBrowser", new Object[] { queue, messageSelector });

        QueueBrowser queueBrowser = null;

        try {
            queueBrowser = jmsSession.createBrowser(queue, messageSelector);
        } catch (InvalidDestinationException ide) {
            throw (InvalidDestinationRuntimeException) JmsErrorUtils.getJMS2Exception(ide, InvalidDestinationRuntimeException.class);
        } catch (InvalidSelectorException ise) {
            throw (InvalidSelectorRuntimeException) JmsErrorUtils.getJMS2Exception(ise, InvalidSelectorRuntimeException.class);
        } catch (JMSException jmse) {
            throw (JMSRuntimeException) JmsErrorUtils.getJMS2Exception(jmse, JMSRuntimeException.class);
        } finally {
            if (TraceComponent.isAnyTracingEnabled() && tc.isEntryEnabled())
                SibTr.exit(this, tc, "createBrowser");
        }

        return queueBrowser;
    }
140301
function startBroker() {
	let worker = cluster.worker;

	if (worker) {
		Object.assign(config, {
			nodeID: (config.nodeID || utils.getNodeID()) + "-" + worker.id
		});
	}

	// Create service broker
	broker = new Moleculer.ServiceBroker(Object.assign({}, config));

	loadServices();

	return broker.start()
		.then(() => {
			if (flags.repl && (!worker || worker.id === 1))
				broker.repl();
		});
}
1367333
public MessageMgr build(){
		if(this.messageHandlers.size()==0){
			this.buildErrors.addError("no message handlers set");
			return null;
		}
		return new MessageMgr(this.appID, this.messageHandlers, this.doCollectMessages);
	}
499302
protected static ManagedMessagingService buildMessagingService(ClusterConfig config) {
    return new NettyMessagingService(
        config.getClusterId(),
        config.getNodeConfig().getAddress(),
        config.getMessagingConfig());
  }
876767
public synchronized GrizzlySoapWebServicePublisher getSoapWebServicePublisher(@NotNull TransportInfo transportInfo) {
        GrizzlySoapWebServicePublisher publisher = soapPublishers.get(transportInfo);
        if (publisher==null) {
            publisher = new GrizzlySoapWebServicePublisher(httpServer, transportInfo);
            soapPublishers.put(transportInfo, publisher);
        }
        return publisher;
    }
598874
public List<MessageDestinationRefType<WebFragmentDescriptor>> getAllMessageDestinationRef()
   {
      List<MessageDestinationRefType<WebFragmentDescriptor>> list = new ArrayList<MessageDestinationRefType<WebFragmentDescriptor>>();
      List<Node> nodeList = model.get("message-destination-ref");
      for(Node node: nodeList)
      {
         MessageDestinationRefType<WebFragmentDescriptor>  type = new MessageDestinationRefTypeImpl<WebFragmentDescriptor>(this, "message-destination-ref", model, node);
         list.add(type);
      }
      return list;
   }
720821
public MessageManager getMessageManager()
    {
        if (m_messageManager == null)
        {
        	MessageApp messageApplication = null;
        	BaseApplication app = null;
        	if (this.getRecord() != null)
        		if (this.getRecord().getRecordOwner() != null)
        			if (this.getRecord().getRecordOwner().getTask() != null)
        				app = (BaseApplication)this.getRecord().getRecordOwner().getTask().getApplication();
        	if (app != null)
        		messageApplication = app.getEnvironment().getMessageApplication(true, app.getProperties());
        	else
        		messageApplication = ((Environment)this.getDatabase().getDatabaseOwner().getEnvironment()).getMessageApplication(true, null);
            m_messageManager = RemoteMessageManager.getMessageManager(messageApplication);
        }
        return m_messageManager;
    }
590398
@Bean
    SystemMessagesProvider systemMessagesProvider() {
        return new SystemMessagesProvider() {
            @Override
            public SystemMessages getSystemMessages(SystemMessagesInfo systemMessagesInfo) {
                CustomizedSystemMessages systemMessages = new CustomizedSystemMessages();
                systemMessages.setSessionExpiredNotificationEnabled(false);
                return systemMessages;
            }
        };
    }