publish_json_wait

Documentation

Index

• type CorrelationId
• type Exchange
• type Immediate
• type Key
• type Mandatory
• type PublishJsonAndWaitForResponse
• type PublishJsonAndWaitForResponseContract
• type PublishJsonAndWaitForResponseStruct
  • func (t *PublishJsonAndWaitForResponseStruct) PublishJsonAndWaitForResponse() error
  • func (t *PublishJsonAndWaitForResponseStruct) WithCorrelationId(correlationId string) Response
  • func (t *PublishJsonAndWaitForResponseStruct) WithExchange(exchange string) Key
  • func (t *PublishJsonAndWaitForResponseStruct) WithImmediate(immediate bool) ResponseTimeout
  • func (t *PublishJsonAndWaitForResponseStruct) WithKey(key string) Mandatory
  • func (t *PublishJsonAndWaitForResponseStruct) WithMandatory(mandatory bool) Immediate
  • func (t *PublishJsonAndWaitForResponseStruct) WithReplyQueueName(replyQueueName string) CorrelationId
  • func (t *PublishJsonAndWaitForResponseStruct) WithRequest(request interface{}) Exchange
  • func (t *PublishJsonAndWaitForResponseStruct) WithResponse(response interface{}) Request
  • func (t *PublishJsonAndWaitForResponseStruct) WithResponseTimeout(responseTimeout time.Duration) PublishJsonAndWaitForResponse
• type ReplyQueueName
  • func WithChannel(t PublishJsonAndWaitForResponseContract) ReplyQueueName
• type Request
• type Response
• type ResponseTimeout

Types

type CorrelationId

type CorrelationId interface {
	WithCorrelationId(correlationId string) Response
}

type Exchange

type Exchange interface {
	WithExchange(exchange string) Key
}

type Immediate

type Immediate interface {
	WithImmediate(immediate bool) ResponseTimeout
}

type Key

type Key interface {
	WithKey(key string) Mandatory
}

type Mandatory

type Mandatory interface {
	PublishJsonAndWaitForResponse
	WithMandatory(mandatory bool) Immediate
}

type PublishJsonAndWaitForResponse

type PublishJsonAndWaitForResponse interface {
	PublishJsonAndWaitForResponse() error
}

type PublishJsonAndWaitForResponseContract

type PublishJsonAndWaitForResponseContract interface {
	PublishJsonAndWaitForResponse(replyQueueName string, correlationId string, response interface{}, request interface{}, exchange string, key string, mandatory bool, immediate bool, responseTimeout time.Duration) error
}

type PublishJsonAndWaitForResponseStruct

type PublishJsonAndWaitForResponseStruct struct {
	// contains filtered or unexported fields
}

func (*PublishJsonAndWaitForResponseStruct) PublishJsonAndWaitForResponse

func (t *PublishJsonAndWaitForResponseStruct) PublishJsonAndWaitForResponse() error

func (*PublishJsonAndWaitForResponseStruct) WithCorrelationId

func (t *PublishJsonAndWaitForResponseStruct) WithCorrelationId(correlationId string) Response

func (*PublishJsonAndWaitForResponseStruct) WithExchange

func (t *PublishJsonAndWaitForResponseStruct) WithExchange(exchange string) Key

func (*PublishJsonAndWaitForResponseStruct) WithImmediate

func (t *PublishJsonAndWaitForResponseStruct) WithImmediate(immediate bool) ResponseTimeout

func (*PublishJsonAndWaitForResponseStruct) WithKey

func (t *PublishJsonAndWaitForResponseStruct) WithKey(key string) Mandatory

func (*PublishJsonAndWaitForResponseStruct) WithMandatory

func (t *PublishJsonAndWaitForResponseStruct) WithMandatory(mandatory bool) Immediate

func (*PublishJsonAndWaitForResponseStruct) WithReplyQueueName

func (t *PublishJsonAndWaitForResponseStruct) WithReplyQueueName(replyQueueName string) CorrelationId

func (*PublishJsonAndWaitForResponseStruct) WithRequest

func (t *PublishJsonAndWaitForResponseStruct) WithRequest(request interface{}) Exchange

func (*PublishJsonAndWaitForResponseStruct) WithResponse

func (t *PublishJsonAndWaitForResponseStruct) WithResponse(response interface{}) Request

func (*PublishJsonAndWaitForResponseStruct) WithResponseTimeout

func (t *PublishJsonAndWaitForResponseStruct) WithResponseTimeout(responseTimeout time.Duration) PublishJsonAndWaitForResponse

type ReplyQueueName

type ReplyQueueName interface {
	WithReplyQueueName(replyQueueName string) CorrelationId
}

func WithChannel

func WithChannel(t PublishJsonAndWaitForResponseContract) ReplyQueueName

type Request

type Request interface {
	WithRequest(request interface{}) Exchange
}

type Response

type Response interface {
	WithResponse(response interface{}) Request
}

type ResponseTimeout

type ResponseTimeout interface {
	WithResponseTimeout(responseTimeout time.Duration) PublishJsonAndWaitForResponse
}