Clients Exenchange of Messages Independently

[JackyMule]

Hello Friends, I have queries about publisher(mule client1) & consumer(mule client2) synchronization. I am using Mule2.
I am running mule server & all my clients communicatng using remoteDispatcher. Setup is working fine.

Publisher(muleclient1) is publishing data on JMS (ActiveMQ) using dispatcher.dispatchRemote.
consumer (muleClient2) is receiving data on JMS (ActiveMQ) using dispatcher.receiveRemote.

publisher, consumer & mule server all are working fine.

My problem is when i stop my publisher(muleclient1) & restart it again i dont receive any message at running consumer(muleclient2).
If i want to receive messages then i also have to restart my consumer.

I want consumer & publisher to run independently & they should send & receive messages as an when they comes up.
If one goes down, there should not be dependency to restart other.


Here is my Mule-Config.xml

        <client:remote-dispatcher-agent>
                <client:remote-endpoint address="tcp://localhost:60504"
                        synchronous="true" />
        </client:remote-dispatcher-agent>

        <vm:connector name="asyncVm" queueEvents="true" />

        <jms:activemq-connector name="jmsConnector"
                brokerURL="tcp://localhost:61616" specification="1.1" />

        <endpoint name="jmsCaafConfiguration"
                address="jms://topic:caaf.configuration" />
         
        <model name="EventBridge">
                <service name="publisherUMO">
                        <inbound>
                                <vm:inbound-endpoint path="publisherVM" />
                        </inbound>
                        <bridge-component />
                        <outbound>
                                <multicasting-router>
                                        <outbound-endpoint ref="jmsCaafConfiguration" />
                                        <!-- <stdio:outbound-endpoint system="OUT"/>-->
                                </multicasting-router>
                        </outbound>
                </service>
                <service name="caafConfiguration">
                        <inbound>
                                <inbound-endpoint ref="jmsCaafConfiguration"/>
                        </inbound>
                        <bridge-component />
                        <outbound>
                                <outbound-pass-through-router>
                                        <vm:outbound-endpoint path="vmCaafConfiguration"/>
                                </outbound-pass-through-router>
                        </outbound>
                </service>
        </model>
</mule>


 
Here is my publisher(muleclient1) code

public static void main(String args[])
    {                  
           MuleClient client = new MuleClient();
           RemoteDispatcher dispatcher = client.getRemoteDispatcher("tcp://localhost:60504");  
           int i = 1;
            while (true)
            {
                dispatcher.dispatchRemote("vm://publisherVM", i + " give me the price of XXX", null);                              
                i++;
                Thread.sleep(1000);
            }            
    }
 




Here is my consumer(muleClient2) code
public static void main(String args[]) throws Exception
    {
        MuleClient client = new MuleClient();
        RemoteDispatcher dispatcher = client.getRemoteDispatcher("tcp://localhost:60504");
        MuleMessage muleMessage = null;      
        while (true)
        {          
            muleMessage = dispatcher.receiveRemote("vm://vmCaafConfiguration", 0);                                      
            System.out.println("Received " + muleMessage.getPayloadAsString());
            Thread.sleep(1000);
        }

        return exitCode;
    }




I want consumer & publisher to run independently & they should send & receive messages as an when they comes up.
If one goes down, there should not be dependency to restart other.
Please let me know how can i acheive this. Is it possible in MULE2?

thanks & regards,
Jack

[JackyMule]

Hello Friends,

Can any one help me with the problem posted in my previous post.
I am using RemoteDispatcher to opt services of mule server. Problem arrives when consumer client consume messages with greater rate then producer client produces it. As soon as consumer client consume all messages from the queue, it stop listening to that queue any more.
After that consumer client don't retrieve any message from the queue though producer is still pumping messages in the queue at slower rate.
For now i am using a workaround, i.e i make sure that message producing rate of producer should be higher then consumer rate. Then every thing goes well. But as soon as i speed up my consumer client, it stops retrieving messages.

I want, my producer & consumer should be agree to a topic & they should be able to send & receive messages as an when needed. As in the field we can't expect messages to come at regular interval.

Please guide me how can i resolve this issue.

Thanks in advance.

JackyMule

JackyMule wrote:

Hello Friends, I have queries about publisher(mule client1) & consumer(mule client2) synchronization. I am using Mule2.
I am running mule server & all my clients communicatng using remoteDispatcher. Setup is working fine.

Publisher(muleclient1) is publishing data on JMS (ActiveMQ) using dispatcher.dispatchRemote.
consumer (muleClient2) is receiving data on JMS (ActiveMQ) using dispatcher.receiveRemote.

publisher, consumer & mule server all are working fine.

My problem is when i stop my publisher(muleclient1) & restart it again i dont receive any message at running consumer(muleclient2).
If i want to receive messages then i also have to restart my consumer.

I want consumer & publisher to run independently & they should send & receive messages as an when they comes up.
If one goes down, there should not be dependency to restart other.


Here is my Mule-Config.xml

        <client:remote-dispatcher-agent>
                <client:remote-endpoint address="tcp://localhost:60504"
                        synchronous="true" />
        </client:remote-dispatcher-agent>

        <vm:connector name="asyncVm" queueEvents="true" />

        <jms:activemq-connector name="jmsConnector"
                brokerURL="tcp://localhost:61616" specification="1.1" />

        <endpoint name="jmsCaafConfiguration"
                address="jms://topic:caaf.configuration" />
         
        <model name="EventBridge">
                <service name="publisherUMO">
                        <inbound>
                                <vm:inbound-endpoint path="publisherVM" />
                        </inbound>
                        <bridge-component />
                        <outbound>
                                <multicasting-router>
                                        <outbound-endpoint ref="jmsCaafConfiguration" />
                                        <!-- <stdio:outbound-endpoint system="OUT"/>-->
                                </multicasting-router>
                        </outbound>
                </service>
                <service name="caafConfiguration">
                        <inbound>
                                <inbound-endpoint ref="jmsCaafConfiguration"/>
                        </inbound>
                        <bridge-component />
                        <outbound>
                                <outbound-pass-through-router>
                                        <vm:outbound-endpoint path="vmCaafConfiguration"/>
                                </outbound-pass-through-router>
                        </outbound>
                </service>
        </model>
</mule>


 
Here is my publisher(muleclient1) code

public static void main(String args[])
    {                  
           MuleClient client = new MuleClient();
           RemoteDispatcher dispatcher = client.getRemoteDispatcher("tcp://localhost:60504");  
           int i = 1;
            while (true)
            {
                dispatcher.dispatchRemote("vm://publisherVM", i + " give me the price of XXX", null);                              
                i++;
                Thread.sleep(1000);
            }            
    }
 




Here is my consumer(muleClient2) code
public static void main(String args[]) throws Exception
    {
        MuleClient client = new MuleClient();
        RemoteDispatcher dispatcher = client.getRemoteDispatcher("tcp://localhost:60504");
        MuleMessage muleMessage = null;      
        while (true)
        {          
            muleMessage = dispatcher.receiveRemote("vm://vmCaafConfiguration", 0);                                      
            System.out.println("Received " + muleMessage.getPayloadAsString());
            Thread.sleep(1000);
        }

        return exitCode;
    }




I want consumer & publisher to run independently & they should send & receive messages as an when they comes up.
If one goes down, there should not be dependency to restart other.
Please let me know how can i acheive this. Is it possible in MULE2?

thanks & regards,
Jack

[antoine.borg]

Hello,

You provided a little more information this time - previously you just
mentioned that the problem occurs when you stop/restart the publisher; now
it's a speed issue.

This topic has been discussed recently on this user list - you should be
able to find something there.

A


Antoine Borg, Senior Consultant | Tel: [phone]
ricston Ltd., BP 2, 1180 Uccle, Brussels, BELGIUM
email: antoine.borg@... | blog: blog.ricston.com | web: ricston.com

-----Original Message-----
From: JackyMule [mailto:angelscs2005@...]
Sent: Wednesday, July 23, 2008 10:37 PM
To: user@...
Subject: Re: [mule-user] Clients Exenchange of Messages Independently



Hello Friends,

Can any one help me with the problem posted in my previous post.
I am using RemoteDispatcher to opt services of mule server. Problem arrives
when consumer client consume messages with greater rate then producer client
produces it. As soon as consumer client consume all messages from the queue,
it stop listening to that queue any more.
After that consumer client don't retrieve any message from the queue though
producer is still pumping messages in the queue at slower rate.
For now i am using a workaround, i.e i make sure that message producing rate
of producer should be higher then consumer rate. Then every thing goes well.
But as soon as i speed up my consumer client, it stops retrieving messages.

I want, my producer & consumer should be agree to a topic & they should be
able to send & receive messages as an when needed. As in the field we can't
expect messages to come at regular interval.

Please guide me how can i resolve this issue.

Thanks in advance.

JackyMule


JackyMule wrote:

>
> Hello Friends, I have queries about publisher(mule client1) &
> consumer(mule client2) synchronization. I am using Mule2.
> I am running mule server & all my clients communicatng using
> remoteDispatcher. Setup is working fine.
>
> Publisher(muleclient1) is publishing data on JMS (ActiveMQ) using
> dispatcher.dispatchRemote.
> consumer (muleClient2) is receiving data on JMS (ActiveMQ) using
> dispatcher.receiveRemote.
>
> publisher, consumer & mule server all are working fine.
>
> My problem is when i stop my publisher(muleclient1) & restart it again
> i dont receive any message at running consumer(muleclient2).
> If i want to receive messages then i also have to restart my consumer.
>
> I want consumer & publisher to run independently & they should send &
> receive messages as an when they comes up.
> If one goes down, there should not be dependency to restart other.
>
>
> Here is my Mule-Config.xml
>
> <client:remote-dispatcher-agent>
> <client:remote-endpoint address="tcp://localhost:60504"
> synchronous="true" />
> </client:remote-dispatcher-agent>
>
> <vm:connector name="asyncVm" queueEvents="true" />
>
> <jms:activemq-connector name="jmsConnector"
> brokerURL="tcp://localhost:61616" specification="1.1" />
>
> <endpoint name="jmsCaafConfiguration"
> address="jms://topic:caaf.configuration" />
>
> <model name="EventBridge">
> <service name="publisherUMO">
> <inbound>
> <vm:inbound-endpoint path="publisherVM" />
> </inbound>
> <bridge-component />
> <outbound>
> <multicasting-router>
> <outbound-endpoint

ref="jmsCaafConfiguration" />
> <!-- <stdio:outbound-endpoint
system="OUT"/>-->
> </multicasting-router>
> </outbound>
> </service>
> <service name="caafConfiguration">
> <inbound>
> <inbound-endpoint
ref="jmsCaafConfiguration"/>
> </inbound>
> <bridge-component />
> <outbound>
> <outbound-pass-through-router>
> <vm:outbound-endpoint
path="vmCaafConfiguration"/>

> </outbound-pass-through-router>
> </outbound>
> </service>
> </model>
> </mule>
>
>
>  
> Here is my publisher(muleclient1) code
>
> public static void main(String args[])
>     {                  
>            MuleClient client = new MuleClient();
>            RemoteDispatcher dispatcher =
> client.getRemoteDispatcher("tcp://localhost:60504");  
>            int i = 1;
>             while (true)
>             {
>                 dispatcher.dispatchRemote("vm://publisherVM", i + " give
> me the price of XXX", null);                              
>                 i++;
>                 Thread.sleep(1000);
>             }            
>     }
>  
>
>
>
>
> Here is my consumer(muleClient2) code
> public static void main(String args[]) throws Exception
>     {
>         MuleClient client = new MuleClient();
>         RemoteDispatcher dispatcher =
> client.getRemoteDispatcher("tcp://localhost:60504");
>         MuleMessage muleMessage = null;      
>         while (true)
>         {          
>             muleMessage =
> dispatcher.receiveRemote("vm://vmCaafConfiguration", 0);

>             System.out.println("Received " +
> muleMessage.getPayloadAsString());
>             Thread.sleep(1000);
>         }
>
>         return exitCode;
>     }
>
>
>
>
> I want consumer & publisher to run independently & they should send &
> receive messages as an when they comes up.
> If one goes down, there should not be dependency to restart other.
> Please let me know how can i acheive this. Is it possible in MULE2?
>
> thanks & regards,
> Jack
>
>
>

--
View this message in context:
http://www.nabble.com/Clients-Exenchange-of-Messages-Independently-tp1858720
8p18619640.html
Sent from the Mule - User mailing list archive at Nabble.com.


---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email



---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email

[JackyMule]

Hello Antoine,

Thanks for your response. but i am not able to find any similar discussion here. i performed lot of search but couldn't find any. Could you please guide me where to get more information to resolve this.

One more query, speed issue can really be resolvable  or it is know bug & fix in coming releases of Mule?

Thanks & regards,
JackyMule

Antoine Borg wrote:

Hello,

You provided a little more information this time - previously you just
mentioned that the problem occurs when you stop/restart the publisher; now
it's a speed issue.

This topic has been discussed recently on this user list - you should be
able to find something there.

A


Antoine Borg, Senior Consultant | Tel: [phone]
ricston Ltd., BP 2, 1180 Uccle, Brussels, BELGIUM
email: [e-mail] | blog: blog.ricston.com | web: ricston.com

-----Original Message-----
From: JackyMule [mailto:[e-mail]]
Sent: Wednesday, July 23, 2008 10:37 PM
To: [e-mail]
Subject: Re: [mule-user] Clients Exenchange of Messages Independently



Hello Friends,

Can any one help me with the problem posted in my previous post.
I am using RemoteDispatcher to opt services of mule server. Problem arrives
when consumer client consume messages with greater rate then producer client
produces it. As soon as consumer client consume all messages from the queue,
it stop listening to that queue any more.
After that consumer client don't retrieve any message from the queue though
producer is still pumping messages in the queue at slower rate.
For now i am using a workaround, i.e i make sure that message producing rate
of producer should be higher then consumer rate. Then every thing goes well.
But as soon as i speed up my consumer client, it stops retrieving messages.

I want, my producer & consumer should be agree to a topic & they should be
able to send & receive messages as an when needed. As in the field we can't
expect messages to come at regular interval.

Please guide me how can i resolve this issue.

Thanks in advance.

JackyMule


JackyMule wrote:
>
> Hello Friends, I have queries about publisher(mule client1) &
> consumer(mule client2) synchronization. I am using Mule2.
> I am running mule server & all my clients communicatng using
> remoteDispatcher. Setup is working fine.
>
> Publisher(muleclient1) is publishing data on JMS (ActiveMQ) using
> dispatcher.dispatchRemote.
> consumer (muleClient2) is receiving data on JMS (ActiveMQ) using
> dispatcher.receiveRemote.
>
> publisher, consumer & mule server all are working fine.
>
> My problem is when i stop my publisher(muleclient1) & restart it again
> i dont receive any message at running consumer(muleclient2).
> If i want to receive messages then i also have to restart my consumer.
>
> I want consumer & publisher to run independently & they should send &
> receive messages as an when they comes up.
> If one goes down, there should not be dependency to restart other.
>
>
> Here is my Mule-Config.xml
>
> <client:remote-dispatcher-agent>
> <client:remote-endpoint address="tcp://localhost:60504"
> synchronous="true" />
> </client:remote-dispatcher-agent>
>
> <vm:connector name="asyncVm" queueEvents="true" />
>
> <jms:activemq-connector name="jmsConnector"
> brokerURL="tcp://localhost:61616" specification="1.1" />
>
> <endpoint name="jmsCaafConfiguration"
> address="jms://topic:caaf.configuration" />
>
> <model name="EventBridge">
> <service name="publisherUMO">
> <inbound>
> <vm:inbound-endpoint path="publisherVM" />
> </inbound>
> <bridge-component />
> <outbound>
> <multicasting-router>
> <outbound-endpoint
ref="jmsCaafConfiguration" />
> <!-- <stdio:outbound-endpoint
system="OUT"/>-->
> </multicasting-router>
> </outbound>
> </service>
> <service name="caafConfiguration">
> <inbound>
> <inbound-endpoint
ref="jmsCaafConfiguration"/>
> </inbound>
> <bridge-component />
> <outbound>
> <outbound-pass-through-router>
> <vm:outbound-endpoint
path="vmCaafConfiguration"/>
> </outbound-pass-through-router>
> </outbound>
> </service>
> </model>
> </mule>
>
>
>  
> Here is my publisher(muleclient1) code
>
> public static void main(String args[])
>     {                  
>            MuleClient client = new MuleClient();
>            RemoteDispatcher dispatcher =
> client.getRemoteDispatcher("tcp://localhost:60504");  
>            int i = 1;
>             while (true)
>             {
>                 dispatcher.dispatchRemote("vm://publisherVM", i + " give
> me the price of XXX", null);                              
>                 i++;
>                 Thread.sleep(1000);
>             }            
>     }
>  
>
>
>
>
> Here is my consumer(muleClient2) code
> public static void main(String args[]) throws Exception
>     {
>         MuleClient client = new MuleClient();
>         RemoteDispatcher dispatcher =
> client.getRemoteDispatcher("tcp://localhost:60504");
>         MuleMessage muleMessage = null;      
>         while (true)
>         {          
>             muleMessage =
> dispatcher.receiveRemote("vm://vmCaafConfiguration", 0);

>             System.out.println("Received " +
> muleMessage.getPayloadAsString());
>             Thread.sleep(1000);
>         }
>
>         return exitCode;
>     }
>
>
>
>
> I want consumer & publisher to run independently & they should send &
> receive messages as an when they comes up.
> If one goes down, there should not be dependency to restart other.
> Please let me know how can i acheive this. Is it possible in MULE2?
>
> thanks & regards,
> Jack
>
>
>

--
View this message in context:
http://www.nabble.com/Clients-Exenchange-of-Messages-Independently-tp1858720
8p18619640.html
Sent from the Mule - User mailing list archive at Nabble.com.


---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email



---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email

[antoine.borg]

Hello again,

http://www.nabble.com/Mule-Client%3A-Problem-in-receiving-message-td17268119
.html#a17268119 is one thread you could look at.
http://www.nabble.com/Update-on-throttling-JMS-consumption--td15606697.html#
a17736398 is another.

Which speed issue are you referring to? If you want to find out if something
is a known bug, look at the JIRA page:
http://mule.mulesource.org/jira/secure/Dashboard.jspa and search there.

A

Antoine Borg, Senior Consultant | Tel: [phone]
ricston Ltd., BP 2, 1180 Uccle, Brussels, BELGIUM
email: antoine.borg@... | blog: blog.ricston.com | web: ricston.com

-----Original Message-----
From: JackyMule [mailto:angelscs2005@...]
Sent: Thursday, July 24, 2008 12:10 PM
To: user@...
Subject: RE: [mule-user] Clients Exenchange of Messages Independently


Hello Antoine,

Thanks for your response. but i am not able to find any similar discussion
here. i performed lot of search but couldn't find any. Could you please
guide me where to get more information to resolve this.

One more query, speed issue can really be resolvable  or it is know bug &
fix in coming releases of Mule?

Thanks & regards,
JackyMule




Antoine Borg wrote:

>
> Hello,
>
> You provided a little more information this time - previously you just
> mentioned that the problem occurs when you stop/restart the publisher;
> now it's a speed issue.
>
> This topic has been discussed recently on this user list - you should
> be able to find something there.
>
> A
>
>
> Antoine Borg, Senior Consultant | Tel: [phone] ricston Ltd., BP
> 2, 1180 Uccle, Brussels, BELGIUM
> email: antoine.borg@... | blog: blog.ricston.com | web:
> ricston.com
>
> -----Original Message-----
> From: JackyMule [mailto:angelscs2005@...]
> Sent: Wednesday, July 23, 2008 10:37 PM
> To: user@...
> Subject: Re: [mule-user] Clients Exenchange of Messages Independently
>
>
>
> Hello Friends,
>
> Can any one help me with the problem posted in my previous post.
> I am using RemoteDispatcher to opt services of mule server. Problem
> arrives when consumer client consume messages with greater rate then
> producer client produces it. As soon as consumer client consume all
> messages from the queue, it stop listening to that queue any more.
> After that consumer client don't retrieve any message from the queue
> though producer is still pumping messages in the queue at slower rate.
> For now i am using a workaround, i.e i make sure that message
> producing rate of producer should be higher then consumer rate. Then
> every thing goes well.
> But as soon as i speed up my consumer client, it stops retrieving
> messages.
>
> I want, my producer & consumer should be agree to a topic & they
> should be able to send & receive messages as an when needed. As in the
> field we can't expect messages to come at regular interval.
>
> Please guide me how can i resolve this issue.
>
> Thanks in advance.
>
> JackyMule
>
>
> JackyMule wrote:
>>
>> Hello Friends, I have queries about publisher(mule client1) &
>> consumer(mule client2) synchronization. I am using Mule2.
>> I am running mule server & all my clients communicatng using
>> remoteDispatcher. Setup is working fine.
>>
>> Publisher(muleclient1) is publishing data on JMS (ActiveMQ) using
>> dispatcher.dispatchRemote.
>> consumer (muleClient2) is receiving data on JMS (ActiveMQ) using
>> dispatcher.receiveRemote.
>>
>> publisher, consumer & mule server all are working fine.
>>
>> My problem is when i stop my publisher(muleclient1) & restart it
>> again i dont receive any message at running consumer(muleclient2).
>> If i want to receive messages then i also have to restart my consumer.
>>
>> I want consumer & publisher to run independently & they should send &
>> receive messages as an when they comes up.
>> If one goes down, there should not be dependency to restart other.
>>
>>
>> Here is my Mule-Config.xml
>>
>> <client:remote-dispatcher-agent>
>> <client:remote-endpoint address="tcp://localhost:60504"
>> synchronous="true" />
>> </client:remote-dispatcher-agent>
>>
>> <vm:connector name="asyncVm" queueEvents="true" />
>>
>> <jms:activemq-connector name="jmsConnector"
>> brokerURL="tcp://localhost:61616" specification="1.1" />
>>
>> <endpoint name="jmsCaafConfiguration"
>> address="jms://topic:caaf.configuration" />
>>
>> <model name="EventBridge">
>> <service name="publisherUMO">
>> <inbound>
>> <vm:inbound-endpoint path="publisherVM" />
>> </inbound>
>> <bridge-component />
>> <outbound>
>> <multicasting-router>
>> <outbound-endpoint
> ref="jmsCaafConfiguration" />
>> <!-- <stdio:outbound-endpoint
> system="OUT"/>-->
>> </multicasting-router>
>> </outbound>
>> </service>
>> <service name="caafConfiguration">
>> <inbound>
>> <inbound-endpoint
> ref="jmsCaafConfiguration"/>
>> </inbound>
>> <bridge-component />
>> <outbound>
>> <outbound-pass-through-router>
>> <vm:outbound-endpoint
> path="vmCaafConfiguration"/>
>> </outbound-pass-through-router>
>> </outbound>
>> </service>
>> </model>
>> </mule>
>>
>>
>>  
>> Here is my publisher(muleclient1) code
>>
>> public static void main(String args[])
>>     {                  
>>            MuleClient client = new MuleClient();
>>            RemoteDispatcher dispatcher =
>> client.getRemoteDispatcher("tcp://localhost:60504");  
>>            int i = 1;
>>             while (true)
>>             {
>>                 dispatcher.dispatchRemote("vm://publisherVM", i + " give
>> me the price of XXX", null);                              
>>                 i++;
>>                 Thread.sleep(1000);
>>             }            
>>     }
>>  
>>
>>
>>
>>
>> Here is my consumer(muleClient2) code public static void main(String
>> args[]) throws Exception
>>     {
>>         MuleClient client = new MuleClient();
>>         RemoteDispatcher dispatcher =
>> client.getRemoteDispatcher("tcp://localhost:60504");
>>         MuleMessage muleMessage = null;      
>>         while (true)
>>         {          
>>             muleMessage =
>> dispatcher.receiveRemote("vm://vmCaafConfiguration", 0);
>
>>             System.out.println("Received " +
>> muleMessage.getPayloadAsString());
>>             Thread.sleep(1000);
>>         }
>>
>>         return exitCode;
>>     }
>>
>>
>>
>>
>> I want consumer & publisher to run independently & they should send &
>> receive messages as an when they comes up.
>> If one goes down, there should not be dependency to restart other.
>> Please let me know how can i acheive this. Is it possible in MULE2?
>>
>> thanks & regards,
>> Jack
>>
>>
>>
>
> --
> View this message in context:
> http://www.nabble.com/Clients-Exenchange-of-Messages-Independently-tp1
> 858720
> 8p18619640.html
> Sent from the Mule - User mailing list archive at Nabble.com.
>
>
> ---------------------------------------------------------------------
> To unsubscribe from this list, please visit:
>
>     http://xircles.codehaus.org/manage_email
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe from this list, please visit:
>
>     http://xircles.codehaus.org/manage_email
>
>
>
>

--
View this message in context:
http://www.nabble.com/Clients-Exenchange-of-Messages-Independently-tp1858720
8p18628862.html
Sent from the Mule - User mailing list archive at Nabble.com.


---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email



---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email

[PawanModi]

Hi Antoine,

Many thanks for those refrences. But first link is giving 404 error.
I went through the second link which conclude that it a know issue / bug with mule.

Description says if consumer is consuming faster then producer then will go in to block state.
Ideally it should not happen.

Do you know any information about fix, mule version or any timeline that come with the fixes?

Thanks for your time & responses.

JackyMule

Antoine Borg wrote:

Hello again,

http://www.nabble.com/Mule-Client%3A-Problem-in-receiving-message-td17268119
.html#a17268119 is one thread you could look at.
http://www.nabble.com/Update-on-throttling-JMS-consumption--td15606697.html#
a17736398 is another.

Which speed issue are you referring to? If you want to find out if something
is a known bug, look at the JIRA page:
http://mule.mulesource.org/jira/secure/Dashboard.jspa and search there.

A

Antoine Borg, Senior Consultant | Tel: [phone]
ricston Ltd., BP 2, 1180 Uccle, Brussels, BELGIUM
email: [e-mail] | blog: blog.ricston.com | web: ricston.com

-----Original Message-----
From: JackyMule [mailto:[e-mail]]
Sent: Thursday, July 24, 2008 12:10 PM
To: [e-mail]
Subject: RE: [mule-user] Clients Exenchange of Messages Independently


Hello Antoine,

Thanks for your response. but i am not able to find any similar discussion
here. i performed lot of search but couldn't find any. Could you please
guide me where to get more information to resolve this.

One more query, speed issue can really be resolvable  or it is know bug &
fix in coming releases of Mule?

Thanks & regards,
JackyMule




Antoine Borg wrote:
>
> Hello,
>
> You provided a little more information this time - previously you just
> mentioned that the problem occurs when you stop/restart the publisher;
> now it's a speed issue.
>
> This topic has been discussed recently on this user list - you should
> be able to find something there.
>
> A
>
>
> Antoine Borg, Senior Consultant | Tel: [phone] ricston Ltd., BP
> 2, 1180 Uccle, Brussels, BELGIUM
> email: [e-mail] | blog: blog.ricston.com | web:
> ricston.com
>
> -----Original Message-----
> From: JackyMule [mailto:[e-mail]]
> Sent: Wednesday, July 23, 2008 10:37 PM
> To: [e-mail]
> Subject: Re: [mule-user] Clients Exenchange of Messages Independently
>
>
>
> Hello Friends,
>
> Can any one help me with the problem posted in my previous post.
> I am using RemoteDispatcher to opt services of mule server. Problem
> arrives when consumer client consume messages with greater rate then
> producer client produces it. As soon as consumer client consume all
> messages from the queue, it stop listening to that queue any more.
> After that consumer client don't retrieve any message from the queue
> though producer is still pumping messages in the queue at slower rate.
> For now i am using a workaround, i.e i make sure that message
> producing rate of producer should be higher then consumer rate. Then
> every thing goes well.
> But as soon as i speed up my consumer client, it stops retrieving
> messages.
>
> I want, my producer & consumer should be agree to a topic & they
> should be able to send & receive messages as an when needed. As in the
> field we can't expect messages to come at regular interval.
>
> Please guide me how can i resolve this issue.
>
> Thanks in advance.
>
> JackyMule
>
>
> JackyMule wrote:
>>
>> Hello Friends, I have queries about publisher(mule client1) &
>> consumer(mule client2) synchronization. I am using Mule2.
>> I am running mule server & all my clients communicatng using
>> remoteDispatcher. Setup is working fine.
>>
>> Publisher(muleclient1) is publishing data on JMS (ActiveMQ) using
>> dispatcher.dispatchRemote.
>> consumer (muleClient2) is receiving data on JMS (ActiveMQ) using
>> dispatcher.receiveRemote.
>>
>> publisher, consumer & mule server all are working fine.
>>
>> My problem is when i stop my publisher(muleclient1) & restart it
>> again i dont receive any message at running consumer(muleclient2).
>> If i want to receive messages then i also have to restart my consumer.
>>
>> I want consumer & publisher to run independently & they should send &
>> receive messages as an when they comes up.
>> If one goes down, there should not be dependency to restart other.
>>
>>
>> Here is my Mule-Config.xml
>>
>> <client:remote-dispatcher-agent>
>> <client:remote-endpoint address="tcp://localhost:60504"
>> synchronous="true" />
>> </client:remote-dispatcher-agent>
>>
>> <vm:connector name="asyncVm" queueEvents="true" />
>>
>> <jms:activemq-connector name="jmsConnector"
>> brokerURL="tcp://localhost:61616" specification="1.1" />
>>
>> <endpoint name="jmsCaafConfiguration"
>> address="jms://topic:caaf.configuration" />
>>
>> <model name="EventBridge">
>> <service name="publisherUMO">
>> <inbound>
>> <vm:inbound-endpoint path="publisherVM" />
>> </inbound>
>> <bridge-component />
>> <outbound>
>> <multicasting-router>
>> <outbound-endpoint
> ref="jmsCaafConfiguration" />
>> <!-- <stdio:outbound-endpoint
> system="OUT"/>-->
>> </multicasting-router>
>> </outbound>
>> </service>
>> <service name="caafConfiguration">
>> <inbound>
>> <inbound-endpoint
> ref="jmsCaafConfiguration"/>
>> </inbound>
>> <bridge-component />
>> <outbound>
>> <outbound-pass-through-router>
>> <vm:outbound-endpoint
> path="vmCaafConfiguration"/>
>> </outbound-pass-through-router>
>> </outbound>
>> </service>
>> </model>
>> </mule>
>>
>>
>>  
>> Here is my publisher(muleclient1) code
>>
>> public static void main(String args[])
>>     {                  
>>            MuleClient client = new MuleClient();
>>            RemoteDispatcher dispatcher =
>> client.getRemoteDispatcher("tcp://localhost:60504");  
>>            int i = 1;
>>             while (true)
>>             {
>>                 dispatcher.dispatchRemote("vm://publisherVM", i + " give
>> me the price of XXX", null);                              
>>                 i++;
>>                 Thread.sleep(1000);
>>             }            
>>     }
>>  
>>
>>
>>
>>
>> Here is my consumer(muleClient2) code public static void main(String
>> args[]) throws Exception
>>     {
>>         MuleClient client = new MuleClient();
>>         RemoteDispatcher dispatcher =
>> client.getRemoteDispatcher("tcp://localhost:60504");
>>         MuleMessage muleMessage = null;      
>>         while (true)
>>         {          
>>             muleMessage =
>> dispatcher.receiveRemote("vm://vmCaafConfiguration", 0);
>
>>             System.out.println("Received " +
>> muleMessage.getPayloadAsString());
>>             Thread.sleep(1000);
>>         }
>>
>>         return exitCode;
>>     }
>>
>>
>>
>>
>> I want consumer & publisher to run independently & they should send &
>> receive messages as an when they comes up.
>> If one goes down, there should not be dependency to restart other.
>> Please let me know how can i acheive this. Is it possible in MULE2?
>>
>> thanks & regards,
>> Jack
>>
>>
>>
>
> --
> View this message in context:
> http://www.nabble.com/Clients-Exenchange-of-Messages-Independently-tp1
> 858720
> 8p18619640.html
> Sent from the Mule - User mailing list archive at Nabble.com.
>
>
> ---------------------------------------------------------------------
> To unsubscribe from this list, please visit:
>
>     http://xircles.codehaus.org/manage_email
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe from this list, please visit:
>
>     http://xircles.codehaus.org/manage_email
>
>
>
>

--
View this message in context:
http://www.nabble.com/Clients-Exenchange-of-Messages-Independently-tp1858720
8p18628862.html
Sent from the Mule - User mailing list archive at Nabble.com.


---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email



---------------------------------------------------------------------
To unsubscribe from this list, please visit:

    http://xircles.codehaus.org/manage_email

[Andrew Perepelytsya]

Ensure the full link is on the same line (or use a mail client which automatically 'unwraps' long links, like gmail).

HTH,
Andrew