reduce page size
This commit is contained in:
Родитель
25a1d2fb7e
Коммит
805fd9cb1e
|
@ -153,7 +153,7 @@ func testMessageIteratorStartHalfway(ctx context.Context, t *testing.T, queue *Q
|
||||||
}
|
}
|
||||||
|
|
||||||
func testMessageIteratorLargePageSize(ctx context.Context, t *testing.T, queue *Queue) {
|
func testMessageIteratorLargePageSize(ctx context.Context, t *testing.T, queue *Queue) {
|
||||||
const pageSize = 600
|
const pageSize = 500
|
||||||
const deciPageSize = pageSize / 10
|
const deciPageSize = pageSize / 10
|
||||||
|
|
||||||
subject, err := queue.Peek(ctx, PeekWithPageSize(pageSize))
|
subject, err := queue.Peek(ctx, PeekWithPageSize(pageSize))
|
||||||
|
|
8
queue.go
8
queue.go
|
@ -116,14 +116,6 @@ func QueueWithReceiveAndDelete() QueueOption {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//// QueueWithRequiredSession configures a queue to use a session
|
|
||||||
//func QueueWithRequiredSession(sessionID string) QueueOption {
|
|
||||||
// return func(q *Queue) error {
|
|
||||||
// q.requiredSessionID = &sessionID
|
|
||||||
// return nil
|
|
||||||
// }
|
|
||||||
//}
|
|
||||||
|
|
||||||
// NewQueue creates a new Queue Sender / Receiver
|
// NewQueue creates a new Queue Sender / Receiver
|
||||||
func (ns *Namespace) NewQueue(name string, opts ...QueueOption) (*Queue, error) {
|
func (ns *Namespace) NewQueue(name string, opts ...QueueOption) (*Queue, error) {
|
||||||
queue := &Queue{
|
queue := &Queue{
|
||||||
|
|
Загрузка…
Ссылка в новой задаче