rabbitmq

Documentation

Overview

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

* Copyright 2023 Caio Matheus Marcatti Calimério * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License.

Index

• func BindQueue(exchange Exchange, queue Queue) error
• func Consume(exchange Exchange, queue Queue, consumer Consumer)
• func DeclareExchange(exchange Exchange) error
• func DeclareQueue(queue Queue) (amqp.Queue, error)
• func Publish(exchangeName string, routingKey string, body map[string]interface{})
• type Connection
  • func NewInstanceRabbitmq() *Connection
• type Consumer
• type Exchange
• type ExchangeType
• type Queue

Functions

func BindQueue

func BindQueue(exchange Exchange, queue Queue) error

func Consume

func Consume(exchange Exchange, queue Queue, consumer Consumer)

func DeclareExchange

func DeclareExchange(exchange Exchange) error

func DeclareQueue

func DeclareQueue(queue Queue) (amqp.Queue, error)

func Publish

func Publish(exchangeName string, routingKey string, body map[string]interface{})

Types

type Connection

type Connection struct {
	*amqp.Connection
	Channel *amqp.Channel
}

func NewInstanceRabbitmq

func NewInstanceRabbitmq() *Connection

type Consumer

type Consumer interface {
	Consume(body map[string]interface{}, headers map[string]interface{})
}

type Exchange

type Exchange struct {
	Name     string
	Durable  bool
	Type     ExchangeType
	AutoDel  bool
	Internal bool
	NoWait   bool
}

type ExchangeType

type ExchangeType string

const (
	Direct  ExchangeType = "direct"
	Fanout  ExchangeType = "fanout"
	Topic   ExchangeType = "topic"
	Headers ExchangeType = "headers"
)

type Queue

type Queue struct {
	Name       string
	Key        string
	Durable    bool
	AutoDel    bool
	Exclusive  bool
	NoWait     bool
	Parameters amqp.Table
}