lukebakken

---

_{NOTE: Team RabbitMQ monitors the rabbitmq-users mailing list and only sometimes answers questions on StackOverflow.}

lukebakken

rabbitmq.config

[
    {rabbit, [
        {background_gc_enabled, true},
        {background_gc_target_interval, 60000},
        {tcp_listeners, [5672]},
        {num_tcp_acceptors, 10},
        {connection_max, infinity},

lukebakken

package main

import (
    "fmt"
    "net"
    "os"
    "time"
)

func main() {

lukebakken

#!/usr/bin/env python
import pika
import sys

def callback(ch, method, properties, body):
    pass
    # print(" [x] Received %r" % body)

queue_name = sys.argv[1]
cp = pika.ConnectionParameters('shostakovich')

lukebakken

#!/usr/bin/env ruby
# encoding: utf-8

require 'bunny'
require 'glutton_ratelimit'
require 'pp'

conn = Bunny.new
conn.start
ch  = conn.create_channel

lukebakken

#!/usr/bin/env bash

set -o errexit
set -o nounset

declare -r node='rabbit@shostakovich'
declare -r user='guest'
declare -r pass='guest'
declare -ir queue_count=9

lukebakken

rabbitmq/rabbitmq-server-release#32

lukebakken

f(), {ok, Pid} = rabbit_vhost_sup_sup:get_vhost_sup(<<"/">>), [MPid] = [Pid || {Name, Pid, _, _} <- supervisor:which_children(Pid), Name == msg_store_persistent], erlang:exit(MPid, force_vhost_failure).

lukebakken

-define(COMMANDS_NOT_REQUIRING_APP,
        [stop, shutdown, stop_app, start_app, wait, reset, force_reset, rotate_logs,
         join_cluster, change_cluster_node_type, update_cluster_nodes,
         forget_cluster_node, rename_cluster_node, cluster_status, status,
         environment, eval, force_boot, help, hipe_compile, encode, decode,
         list_ciphers, list_hashes]).

stop
shutdown
stop_app

lukebakken

erl started with +K true:

$ erl +K true
Erlang/OTP 19 [erts-8.3.5] [source] [64-bit] [smp:8:8] [async-threads:10] [hipe] [kernel-poll:true]                                                                                                                                                                             
                                                                                                                                                                                                                                                                                
Eshell V8.3.5  (abort with ^G)
1> erlang:system_info(kernel_poll).
true
2> os:getpid().