test_queues

Documentation

Index

• type MessageQueueFixture
  • func NewMessageQueueFixture(queue queues.IMessageQueue) *MessageQueueFixture
  • func (c *MessageQueueFixture) TestMoveToDeadMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestOnMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestPeekNoMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestReceiveAbandonMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestReceiveCompleteMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestReceiveSendMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestSendPeekMessage(t *testing.T)
  • func (c *MessageQueueFixture) TestSendReceiveMessage(t *testing.T)
• type TestMsgReceiver
  • func (c *TestMsgReceiver) ReceiveMessage(ctx context.Context, message *queues.MessageEnvelope, ...) (err error)

Types

type MessageQueueFixture

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

func NewMessageQueueFixture

func NewMessageQueueFixture(queue queues.IMessageQueue) *MessageQueueFixture

func (*MessageQueueFixture) TestMoveToDeadMessage

func (c *MessageQueueFixture) TestMoveToDeadMessage(t *testing.T)

func (*MessageQueueFixture) TestOnMessage

func (c *MessageQueueFixture) TestOnMessage(t *testing.T)

func (*MessageQueueFixture) TestPeekNoMessage

func (c *MessageQueueFixture) TestPeekNoMessage(t *testing.T)

func (*MessageQueueFixture) TestReceiveAbandonMessage

func (c *MessageQueueFixture) TestReceiveAbandonMessage(t *testing.T)

func (*MessageQueueFixture) TestReceiveCompleteMessage

func (c *MessageQueueFixture) TestReceiveCompleteMessage(t *testing.T)

func (*MessageQueueFixture) TestReceiveSendMessage

func (c *MessageQueueFixture) TestReceiveSendMessage(t *testing.T)

func (*MessageQueueFixture) TestSendPeekMessage

func (c *MessageQueueFixture) TestSendPeekMessage(t *testing.T)

func (*MessageQueueFixture) TestSendReceiveMessage

func (c *MessageQueueFixture) TestSendReceiveMessage(t *testing.T)

type TestMsgReceiver

type TestMsgReceiver struct {
	Message *queues.MessageEnvelope
}

func (*TestMsgReceiver) ReceiveMessage

func (c *TestMsgReceiver) ReceiveMessage(ctx context.Context, message *queues.MessageEnvelope, queue queues.IMessageQueue) (err error)