Examples of ClusterizableMessageSourceWrapper

org.mule.source.ClusterizableMessageSourceWrapper
Wraps a {@link ClusterizableMessageSource} in order to manage the lifecycleof the wrapped instance differently depending if the node is primary or not inside a cluster. Non clustered nodes are always primary.

Examples of org.mule.source.ClusterizableMessageSourceWrapper


    public void setMessageSource(MessageSource inboundMessageSource)
    {
        if (messageSource instanceof ClusterizableMessageSource)
        {
            this.messageSource = new ClusterizableMessageSourceWrapper(muleContext, (ClusterizableMessageSource) inboundMessageSource, this);
        }
        else
        {
            this.messageSource = inboundMessageSource;
        }

View Full Code Here

Examples of org.mule.source.ClusterizableMessageSourceWrapper

    @Override
    public void setMessageSource(MessageSource messageSource)
    {
        if (messageSource instanceof ClusterizableMessageSource)
        {
            this.messageSource = new ClusterizableMessageSourceWrapper(muleContext,
                    (ClusterizableMessageSource) messageSource, this);
        }
        else
        {
            this.messageSource = messageSource;

View Full Code Here

Examples of org.mule.source.ClusterizableMessageSourceWrapper

        TestPollingController pollingController = new TestPollingController();
        ((DefaultMuleContext) muleContext).setPollingController(pollingController);
        muleContext.start();


        Flow test1 = (Flow) muleContext.getRegistry().get("test1");
        ClusterizableMessageSourceWrapper messageSource = (ClusterizableMessageSourceWrapper) test1.getMessageSource();
        assertTrue(test1.isStarted());
        assertTrue(messageSource.isStarted());
    }

View Full Code Here

Examples of org.mule.source.ClusterizableMessageSourceWrapper

        ((DefaultMuleContext) muleContext).setPollingController(pollingController);


        muleContext.start();


        Flow test1 = (Flow) muleContext.getRegistry().get("test1");
        ClusterizableMessageSourceWrapper messageSource = (ClusterizableMessageSourceWrapper) test1.getMessageSource();


        messageSource.initialise();


        pollingController.isPrimary=true;
        muleContext.fireNotification(new ClusterNodeNotification("primary", ClusterNodeNotification.PRIMARY_CLUSTER_NODE_SELECTED));


        LocalMuleClient client = muleContext.getClient();

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.