smetj

ᕙ(⇀‸↼‶)ᕗ 

[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

smetj

ᕙ(⇀‸↼‶)ᕗ 

[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

smetj

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

---
functions:
  json_decode:
    function: wishbone.function.decode.json

  uppercase:
    function: wishbone.function.process.uppercase
    arguments:
      source: "@data.value"
      destination: "@data.value"

smetj

#!/usr/bin/python

from testlap import TestLap

class DictEval():
    '''
    eval() a dict string into an actual dict object
    '''

    def __init__(self):

smetj

#!/usr/bin/env python
# -*- coding: utf-8 -*-
#

import json
from jsonschema import validate


class Greeting(object):

smetj

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!"})

smetj

---
lookups:
  event:
    module: wishbone.lookup.event

modules:
  input:
    module: wishbone.input.twitter
    description: Collects events of the authenticated user
    arguments:

smetj

---
modules:
  input:
    module: wishbone.input.hammer
    arguments:
      batch_size: 100
      set_size: 100

  graphite:
    module: wishbone.encode.graphite

smetj

modules:
  input:
    module: wishbone.input.httpserver

  fresh:
    module: wishbone.flow.fresh
    arguments:
      timeout: 120
      timeout_payload:
        service_key: abcdefghijklmnopqrstuvwxyz