func (d *dlqMessageHandlerImpl) Read(
	ctx context.Context,
	lastMessageID int64,
	pageSize int,
	pageToken []byte,
) ([]*types.ReplicationTask, []byte, error) {

	ackLevel, err := d.replicationQueue.GetDLQAckLevel(ctx)
	if err != nil {
		return nil, nil, err
	}

	return d.replicationQueue.GetMessagesFromDLQ(
		ctx,
		ackLevel,
		lastMessageID,
		pageSize,
		pageToken,
	)
}
// ReadMessages reads domain replication DLQ messages
ReadMessages reads domain replication DLQ messages
// ReadMessages reads domain replication DLQ messages
func (d *dlqMessageHandlerImpl) Read(
	ctx context.Context,
	lastMessageID int64,
	pageSize int,
	pageToken []byte,
) ([]*types.ReplicationTask, []byte, error) {
	ackLevel, err := d.replicationQueue.GetDLQAckLevel(ctx)
	if err != nil {
		return nil, nil, err
	}
	return d.replicationQueue.GetMessagesFromDLQ(
		ctx,
		ackLevel,
		lastMessageID,
		pageSize,
		pageToken,
	)
}
func ( d * dlqMessageHandlerImpl ) Read ( ctx context . Context , lastMessageID int64 , pageSize int , pageToken [ ] byte , ) ( [ ] * types . ReplicationTask , [ ] byte , error ) { ackLevel , err := d . replicationQueue . GetDLQAckLevel ( ctx ) if err != nil { return nil , nil , err } return d . replicationQueue . GetMessagesFromDLQ ( ctx , ackLevel , lastMessageID , pageSize , pageToken , ) }
ReadMessages reads domain replication DLQ messages
ReadMessages reads domain replication DLQ messages