[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