Skip to content

Instantly share code, notes, and snippets.

ᕙ(⇀‸↼‶)ᕗ
[2017-10-31T15:47:21,738][ERROR][logstash.outputs.rabbitmq] Error while publishing. Will retry. {:message=>"MarchHare::ChannelAlreadyClosed", :exception=>MarchHare::ChannelAlreadyClosed, :backtrace=>["/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exceptions.rb:121:in `convert_and_reraise'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:980:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:978:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:606:in `basic_publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exchange.rb:77:in `publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-4.0.11-java/lib/logstash/outputs/rabbitmq.rb:62:in `publish'", "org/jruby/RubyPr
ᕙ(⇀‸↼‶)ᕗ
[2017-10-31T15:47:21,738][ERROR][logstash.outputs.rabbitmq] Error while publishing. Will retry. {:message=>"MarchHare::ChannelAlreadyClosed", :exception=>MarchHare::ChannelAlreadyClosed, :backtrace=>["/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exceptions.rb:121:in `convert_and_reraise'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:980:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:978:in `converting_rjc_exceptions_to_ruby'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/channel.rb:606:in `basic_publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/march_hare-3.0.0-java/lib/march_hare/exchange.rb:77:in `publish'", "/usr/share/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-4.0.11-java/lib/logstash/outputs/rabbitmq.rb:62:in `publish'", "org/jruby/RubyPr
Without circular ref
client.choria -> nats1.fed
nats3.fed -> fb builder:1 -> nats2.choria
nats1.choria -> dev1-0.choria -> nats1.choria
nats3.choria -> fb builder:2 -> nats2.fed
nats1.fed -> client.choria
With circular ref:
@smetj
smetj / bootstrap.yaml
Last active March 14, 2017 22:06
Wishbone functions
---
functions:
json_decode:
function: wishbone.function.decode.json
uppercase:
function: wishbone.function.process.uppercase
arguments:
source: "@data.value"
destination: "@data.value"
@smetj
smetj / dict_eval.py
Last active March 4, 2017 07:08
Measure time of eval() a dict string into an actual dict object
#!/usr/bin/python
from testlap import TestLap
class DictEval():
'''
eval() a dict string into an actual dict object
'''
def __init__(self):
@smetj
smetj / simple_validation.py
Created November 13, 2016 22:54
Input validation
#!/usr/bin/env python
# -*- coding: utf-8 -*-
#
import json
from jsonschema import validate
class Greeting(object):
@smetj
smetj / hello_world.py
Last active August 21, 2016 15:27
Hello world (wishbone.readthedocs.org)
from wishbone.module.testevent import TestEvent
from wishbone.module.stdout import STDOUT
from wishbone.router import Default
from wishbone.actor import ActorConfig
input_config = ActorConfig("input")
output_config = ActorConfig("output")
router = Default()
router.registerModule(TestEvent, input_config, {"message": "Hello world!"})
---
lookups:
event:
module: wishbone.lookup.event
modules:
input:
module: wishbone.input.twitter
description: Collects events of the authenticated user
arguments:
@smetj
smetj / bootstrap.yaml
Created April 18, 2016 22:48
Hammering Graphite
---
modules:
input:
module: wishbone.input.hammer
arguments:
batch_size: 100
set_size: 100
graphite:
module: wishbone.encode.graphite
@smetj
smetj / bootstrap.yaml
Last active April 18, 2016 21:30
Quis custodiet ipsos custodes: Monitoring a poll-based monitoring solution
modules:
input:
module: wishbone.input.httpserver
fresh:
module: wishbone.flow.fresh
arguments:
timeout: 120
timeout_payload:
service_key: abcdefghijklmnopqrstuvwxyz