service

Documentation

Index

• type BlockingService
  • func NewBlockingService(provider messaging.MessagingProvider) *BlockingService
  • func (b BlockingService) RequestResponseBlock(requestTopic string, responseTopic string, payload string, headers string) (*messaging.SendAndReceiveResponse, error)

Types

type BlockingService

type BlockingService struct {
	Provider messaging.MessagingProvider
}

func NewBlockingService

func NewBlockingService(provider messaging.MessagingProvider) *BlockingService

Creates new BlockingService with a messaging service provider Which will be used as the transport protocol

func (BlockingService) RequestResponseBlock

func (b BlockingService) RequestResponseBlock(
	requestTopic string,
	responseTopic string,
	payload string,
	headers string,
) (*messaging.SendAndReceiveResponse, error)

This function pushes the payload and headers to requestTopic, and waits for a message in responseTopic with the same key.