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[T any](exchange Exchange, queue Queue, consumer Consumer[T])
• func DeclareExchange(exchange Exchange) error
• func DeclareQueue(queue Queue) (amqp.Queue, error)
• func Publish[T any](exchangeName string, routingKey string, body T)
• 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[T any](exchange Exchange, queue Queue, consumer Consumer[T])

, consumer func Consumer[T]

func DeclareExchange

func DeclareExchange(exchange Exchange) error

func DeclareQueue

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

func Publish

func Publish[T any](exchangeName string, routingKey string, body T)

Types

type Connection

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

func NewInstanceRabbitmq

func NewInstanceRabbitmq() *Connection

type Consumer

type Consumer[T any] interface {
	Consume(body T, 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
}