113
114
// GetMessagesFromDLQ mocks base method.
115
>
func (m *MockNamespaceReplicationQueue) GetMessagesFromDLQ(ctx context.Context, firstMessageID, lastMessageID int64, pageSize int, pageToken []byte) ([]*repication.ReplicationTask, []byte, error) {
namespace_replication_queue_mock.go
116
>
m.ctrl.T.Helper()
117
>
ret := m.ctrl.Call(m, "GetMessagesFromDLQ", ctx, firstMessageID, lastMessageID, pageSize, pageToken)
118
>
ret0, _ := ret[0].([]*repication.ReplicationTask)
119
>
ret1, _ := ret[1].([]byte)
120
>
ret2, _ := ret[2].(error)
121
>
return ret0, ret1, ret2
122
>
}
123
124
// GetMessagesFromDLQ indicates an expected call of GetMessagesFromDLQ.