flopezluis

//add this to your bookmarks. The default vhost in RabbitMq is "/", 
// so you should have as virtualhost %2F, but due to chrome escape it, i used %252f
//i assume you're in the management site (http://www.rabbitmq.com/management.html)
javascript: 
vhost="%252f";
var purge = function(name) {
    $.ajax({
       url:'api/queues/' + vhost + "/" + name + '/contents/',
       type: 'DELETE',
       success:function(data) {

flopezluis

def require(package):
    with settings(hide('stdout'), warn_only=True):
        out = run('dpkg -s %s' %package)
        if not out.succeeded:
            print "The package is not installed. Installing \n"
            sudo("apt-get install %s" %package)
        else:
            print "The package is installed.\n"

flopezluis

var truncate = function(msg, len, suffix) {
  var truncated = msg.substring(0, len);
  if (msg.length > len) {
    truncated += suffix;
  }
  return truncated;
}

flopezluis

import org.xml.sax.SAXException;


@Component("duplicatedChannels")
public class DuplicatedChannels {
	private final Log logger = LogFactory.getLog(this.getClass());

	@Autowired
	private ApplicationContext appContext;
	

flopezluis

%% 
%%
%% This plugin is based on rabbitmq-recent-history-exchange
%%  from Alvaro Videla https://github.com/videlalvaro/rabbitmq-recent-history-exchange
%%
%% This is plugin has been developed by ShuttleCloud.
%% 
%% This exchange gives you the possibility to set throttling to any 
%% exchange. This exchange receives a message and after a time it's delivered
%% to the final exchange. It works as an intermediary

flopezluis

//add this to your bookmarks. The default vhost in RabbitMq is "/", 
//so you should have as virtualhost %2F, but due to chrome escape it, i used %252f
//i assume you're in the management site (http://www.rabbitmq.com/management.html)
javascript: 
vhost="%252f";
var delete_queues = function(name) {
   $.ajax({
       url:'api/queues/' +vhost+ '/' + name,
       type: 'DELETE',
       success:function(data) {

flopezluis

import sys
import time as timer
import urllib
from datetime import datetime, time
import signal
name = ''
def record():
  url_stream = urllib.urlopen("http://vaughanradio.streaming-pro.com:8012/;stream.nsv")
  f = open("%s_%s.mp3" %(name, datetime.now().strftime("%y-%m-%d")),"wb");
  print ('Recording...')

flopezluis

import logging
import pika
from threading import Timer

BATCH_SIZE = 100
LOG_FORMAT = ('%(levelname) -10s %(asctime)s %(name) -30s %(funcName) '
              '-35s %(lineno) -5d: %(message)s')
LOGGER = logging.getLogger(__name__)

flopezluis

import logging
import sys
import os
import settings
import pika
import re
from threading import Timer

LOG_FORMAT = ('%(levelname) -10s %(asctime)s %(name) -30s %(funcName) '
              '-35s %(lineno) -5d: %(message)s')

flopezluis

import logging
import pika

LOG_FORMAT = ('%(levelname) -10s %(asctime)s %(name) -30s %(funcName) '
              '-35s %(lineno) -5d: %(message)s')
LOGGER = logging.getLogger(__name__)


class ExampleConsumer(object):
    """This is an example consumer that will handle unexpected interactions