ElemExpiry return whether the elem is expired.

NewMockMessageWithID creates a new mock instance.

NewMockNotifier creates a new mock instance.

NewMockStore creates a new mock instance.

Elem represents the element store in the queue.

InitOptions is used to pass some required client information to the queue.Init().

InternalError wraps the error of the backend storage.

MockMessageWithID is a mock of MessageWithID interface.

MockMessageWithIDMockRecorder is the mock recorder for MockMessageWithID.

MockNotifier is a mock of Notifier interface.

MockNotifierMockRecorder is the mock recorder for MockNotifier.

MockStore is a mock of Store interface.

MockStoreMockRecorder is the mock recorder for MockStore.

Store represents a queue store for one client.