[rabbitmq-discuss] Feature request: move messages using management UI

Trần Đức Thông humg.thongit at gmail.com
Tue Feb 25 10:41:23 GMT 2014


I am leaning rabbitmq use haproxy to execute failover in a cluster.

IP server rabbitmq_1: 10.0.0.101 port: 15672
IP server rabbitmq_2: 192.168.247.129 port: 15672
IP server haproxy: 192.168.247.131

Haproxy config

# HAProxy Config for Local RabbitMQ SLB Warren
global
log 127.0.0.1 local0 info
maxconn 4096
daemon
nbproc 1
defaults
log global
mode tcp
option tcplog
option dontlognull
retries 3
option redispatch
maxconn 2000
timeout connect 5s
timeout client 120s
timeout server 120s
listen rabbitmq_local_cluster 192.168.247.131:8088
mode tcp
balance roundrobin
server rabbit_a 10.0.0.101:15672 check inter 5000 rise 2 fall 3
server rabbit_b 192.168.247.129:15672 backup inter 5000 rise 2 fall 3
listen private_monitoring :8101
mode http
log global

maxconn 10

clitimeout      100s
        srvtimeout      100s
        contimeout      100s
        timeout queue   100s

option httplog
stats hide-version
stats show-node
stats enable
stats auth admin:123456
stats uri /stats
stats refresh 5s

Code APP send message

class Send
    {
        public static void Main()
        {
            var factory = new ConnectionFactory { HostName =
"192.168.247.131", Port=8088 };
            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //channel.QueueDeclare("hello", false, false, false,
null);
                    channel.QueueDeclare("q_A", false, false, false, null);
                    channel.QueueDeclare("q_B", false, false, false, null);
                    int i = 0;
                    while (true)
                    {
                        string message = "Hello World! " + i.ToString();
                        var body = Encoding.UTF8.GetBytes(message);

                        channel.BasicPublish("", "q_A", null, body);
                        channel.BasicPublish("", "q_B", null, body);
                        Console.WriteLine(" [x] Sent {0}", message);
                        i++;
                        Thread.Sleep(1000);
                    }
                }
            }
            Console.Read();
        }
    }

When APP run exception "None of the specified endpoints were reachable"

[image: Inline images 1]


On 25 February 2014 17:37, Simon MacMullen <simon at rabbitmq.com> wrote:

> In the current nightly builds and thus the next release (3.3.0), you can
> create a temporary shovel through the management interface as a means of
> moving messages around.
>
> Cheers, Simon
>
> On 24/02/2014 20:39, Leo Hernandez wrote:
>
>> Jochen, did you ever find a way to do this?
>>
>> On Wednesday, June 26, 2013 10:36:02 AM UTC-4, Jochen Zeischka wrote:
>>
>>     At our company, we've written a tool to move messages from their
>>     dead-letter queues back to the original queue.
>>
>>     Would it make sense to be able to do so from the management UI?
>>     The feature I'm looking for is the ability to move messages from one
>>     queue to another queue.
>>
>>     Kind regards!
>>
>>     Jochen
>>
>>
>>
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>
>>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>



-- 
-------------------------------------------------------------------------------------------------

*Tran Duc Thong*
Software engineering
Mobile: 0989 452 004
Email: humg.thongit at gmail.com
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140225/9d828d21/attachment.html>
-------------- next part --------------
A non-text attachment was scrubbed...
Name: Untitled.png
Type: image/png
Size: 27550 bytes
Desc: not available
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140225/9d828d21/attachment.png>


More information about the rabbitmq-discuss mailing list