go-syslog-rabbit: github.com/irom77/go-syslog-rabbit/rabbit Index | Files

package rabbit

import "github.com/irom77/go-syslog-rabbit/rabbit"

Copyright 2017 Irek Romaniuk. All rights reserved.

Rabbit server

Index

Package Files

rabbit.go

func GetChannel Uses

func GetChannel(url string) (*amqp.Connection, *amqp.Channel)

func GetQueue Uses

func GetQueue(qName string, ch *amqp.Channel) *amqp.Queue

func Publish Uses

func Publish(message bytes.Buffer, ch *amqp.Channel, q *amqp.Queue)

Publishing message to channel and queue

func Subscribe Uses

func Subscribe(ch *amqp.Channel, q *amqp.Queue, print bool, timeout int)

type Message Uses

type Message struct {
    Value []byte
}

Package rabbit imports 7 packages (graph) and is imported by 2 packages. Updated 2017-03-26. Refresh now. Tools for package owners.